Mercurial > hg > freeDiameter
comparison freeDiameter/sctps.c @ 207:a68d24defda8
Delay the destruction of the queues in sctps wrapper
| author | Sebastien Decugis <sdecugis@nict.go.jp> |
|---|---|
| date | Mon, 15 Feb 2010 17:36:00 +0900 |
| parents | 1b47afa59358 |
| children | b9f48f2f2a22 |
comparison
equal
deleted
inserted
replaced
| 206:8eda7c917fc6 | 207:a68d24defda8 |
|---|---|
| 116 error: | 116 error: |
| 117 if (!conn->cc_closing) { | 117 if (!conn->cc_closing) { |
| 118 CHECK_FCT_DO( fd_event_send( Target_Queue(conn), FDEVP_CNX_ERROR, 0, NULL), /* continue or destroy everything? */); | 118 CHECK_FCT_DO( fd_event_send( Target_Queue(conn), FDEVP_CNX_ERROR, 0, NULL), /* continue or destroy everything? */); |
| 119 } | 119 } |
| 120 | 120 |
| 121 /* Since the demux thread terminates, we must trig an error for all decipher threads. We do this by destroying all demuxed FIFO queues */ | |
| 122 for (strid = 0; strid < conn->cc_sctp_para.pairs; strid++) { | |
| 123 fd_event_destroy( &conn->cc_sctps_data.array[strid].raw_recv, free ); | |
| 124 } | |
| 125 | |
| 126 goto out; | 121 goto out; |
| 127 } | 122 } |
| 128 | 123 |
| 129 /* Decrypt the data received in this stream pair and store it in the target queue */ | 124 /* Decrypt the data received in this stream pair and store it in the target queue */ |
| 130 static void * decipher(void * arg) | 125 static void * decipher(void * arg) |