diff options
Diffstat (limited to 'src/stream/test_stream_2peers_halfclose.c')
-rw-r--r-- | src/stream/test_stream_2peers_halfclose.c | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/src/stream/test_stream_2peers_halfclose.c b/src/stream/test_stream_2peers_halfclose.c index 2d14acfe3..2502615c2 100644 --- a/src/stream/test_stream_2peers_halfclose.c +++ b/src/stream/test_stream_2peers_halfclose.c | |||
@@ -661,15 +661,19 @@ stream_listen_cb (void *cls, | |||
661 | struct GNUNET_STREAM_Socket *socket, | 661 | struct GNUNET_STREAM_Socket *socket, |
662 | const struct GNUNET_PeerIdentity *initiator) | 662 | const struct GNUNET_PeerIdentity *initiator) |
663 | { | 663 | { |
664 | GNUNET_assert (NULL != socket); | 664 | if ((NULL == socket) || (NULL == initiator)) |
665 | GNUNET_assert (NULL != initiator); | 665 | { |
666 | GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Binding error\n"); | ||
667 | if (GNUNET_SCHEDULER_NO_TASK != abort_task) | ||
668 | GNUNET_SCHEDULER_cancel (abort_task); | ||
669 | abort_task = GNUNET_SCHEDULER_add_now (&do_abort, NULL); | ||
670 | return GNUNET_OK; | ||
671 | } | ||
666 | GNUNET_assert (socket != peer1.socket); | 672 | GNUNET_assert (socket != peer1.socket); |
667 | |||
668 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 673 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
669 | "%s: Peer connected: %s\n", | 674 | "%s: Peer connected: %s\n", |
670 | GNUNET_i2s (&peer2.our_id), | 675 | GNUNET_i2s (&peer2.our_id), |
671 | GNUNET_i2s(initiator)); | 676 | GNUNET_i2s(initiator)); |
672 | |||
673 | peer2.socket = socket; | 677 | peer2.socket = socket; |
674 | /* FIXME: reading should be done right now instead of a scheduled call */ | 678 | /* FIXME: reading should be done right now instead of a scheduled call */ |
675 | read_task = GNUNET_SCHEDULER_add_now (&stream_read, (void *) socket); | 679 | read_task = GNUNET_SCHEDULER_add_now (&stream_read, (void *) socket); |