diff options
Diffstat (limited to 'src/transport')
6 files changed, 19 insertions, 0 deletions
diff --git a/src/transport/test_transport_api_disconnect.c b/src/transport/test_transport_api_disconnect.c index a96a1a152..267c56af6 100644 --- a/src/transport/test_transport_api_disconnect.c +++ b/src/transport/test_transport_api_disconnect.c | |||
@@ -262,6 +262,9 @@ notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) | |||
262 | { | 262 | { |
263 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%4s' disconnected (%p)!\n", | 263 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%4s' disconnected (%p)!\n", |
264 | GNUNET_i2s (peer), cls); | 264 | GNUNET_i2s (peer), cls); |
265 | if (th != NULL) | ||
266 | GNUNET_TRANSPORT_notify_transmit_ready_cancel (th); | ||
267 | th = NULL; | ||
265 | peers_connected--; | 268 | peers_connected--; |
266 | } | 269 | } |
267 | 270 | ||
diff --git a/src/transport/test_transport_api_limited_sockets.c b/src/transport/test_transport_api_limited_sockets.c index a582a8f70..bc8b82538 100644 --- a/src/transport/test_transport_api_limited_sockets.c +++ b/src/transport/test_transport_api_limited_sockets.c | |||
@@ -196,6 +196,9 @@ notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) | |||
196 | { | 196 | { |
197 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%4s' disconnected (%p)!\n", | 197 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%4s' disconnected (%p)!\n", |
198 | GNUNET_i2s (peer), cls); | 198 | GNUNET_i2s (peer), cls); |
199 | if (th != NULL) | ||
200 | GNUNET_TRANSPORT_notify_transmit_ready_cancel (th); | ||
201 | th = NULL; | ||
199 | } | 202 | } |
200 | 203 | ||
201 | static void | 204 | static void |
diff --git a/src/transport/test_transport_api_reliability.c b/src/transport/test_transport_api_reliability.c index 18971a986..1b6d89afe 100644 --- a/src/transport/test_transport_api_reliability.c +++ b/src/transport/test_transport_api_reliability.c | |||
@@ -352,6 +352,10 @@ notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) | |||
352 | { | 352 | { |
353 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%4s' disconnected (%p)!\n", | 353 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%4s' disconnected (%p)!\n", |
354 | GNUNET_i2s (peer), cls); | 354 | GNUNET_i2s (peer), cls); |
355 | if (th != NULL) | ||
356 | GNUNET_TRANSPORT_notify_transmit_ready_cancel (th); | ||
357 | th = NULL; | ||
358 | |||
355 | } | 359 | } |
356 | 360 | ||
357 | static void | 361 | static void |
diff --git a/src/transport/test_transport_api_timeout.c b/src/transport/test_transport_api_timeout.c index cec60e989..0124889ce 100644 --- a/src/transport/test_transport_api_timeout.c +++ b/src/transport/test_transport_api_timeout.c | |||
@@ -188,6 +188,9 @@ notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) | |||
188 | GNUNET_i2s (peer)); | 188 | GNUNET_i2s (peer)); |
189 | disconnects++; | 189 | disconnects++; |
190 | } | 190 | } |
191 | if (th != NULL) | ||
192 | GNUNET_TRANSPORT_notify_transmit_ready_cancel (th); | ||
193 | th = NULL; | ||
191 | } | 194 | } |
192 | 195 | ||
193 | static void | 196 | static void |
diff --git a/src/transport/test_transport_api_unreliability.c b/src/transport/test_transport_api_unreliability.c index c675e18a0..7b7ec2d35 100644 --- a/src/transport/test_transport_api_unreliability.c +++ b/src/transport/test_transport_api_unreliability.c | |||
@@ -416,6 +416,9 @@ notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) | |||
416 | { | 416 | { |
417 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%4s' disconnected (%p)!\n", | 417 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%4s' disconnected (%p)!\n", |
418 | GNUNET_i2s (peer), cls); | 418 | GNUNET_i2s (peer), cls); |
419 | if (th != NULL) | ||
420 | GNUNET_TRANSPORT_notify_transmit_ready_cancel (th); | ||
421 | th = NULL; | ||
419 | } | 422 | } |
420 | 423 | ||
421 | static void | 424 | static void |
diff --git a/src/transport/test_transport_api_unreliability_constant.c b/src/transport/test_transport_api_unreliability_constant.c index 5ad6c6afb..64fe4be37 100644 --- a/src/transport/test_transport_api_unreliability_constant.c +++ b/src/transport/test_transport_api_unreliability_constant.c | |||
@@ -384,6 +384,9 @@ notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) | |||
384 | { | 384 | { |
385 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%4s' disconnected (%p)!\n", | 385 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%4s' disconnected (%p)!\n", |
386 | GNUNET_i2s (peer), cls); | 386 | GNUNET_i2s (peer), cls); |
387 | if (th != NULL) | ||
388 | GNUNET_TRANSPORT_notify_transmit_ready_cancel (th); | ||
389 | th = NULL; | ||
387 | } | 390 | } |
388 | 391 | ||
389 | static void | 392 | static void |