aboutsummaryrefslogtreecommitdiff
path: root/src/stream/test_stream_2peers_halfclose.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/stream/test_stream_2peers_halfclose.c')
-rw-r--r--src/stream/test_stream_2peers_halfclose.c12
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);