clean exit while aborting

diff --git a/src/stream/test_stream_2peers.c b/src/stream/test_stream_2peers.c
index d597ac5c34cbd5dbbea33287703d6a651bf7a00d..86d1a84ad008cfa1ba2539be69a539a9c0cf1352 100644 (file)
--- a/src/stream/test_stream_2peers.c
+++ b/src/stream/test_stream_2peers.c
@@ -241,7 +241,10 @@ do_close (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
     GNUNET_SCHEDULER_cancel (abort_task);
   if (NULL != peer1.socket)
     GNUNET_STREAM_close (peer1.socket);
-  GNUNET_TESTBED_operation_done (peer1.op);
+  if (NULL != peer1.op)
+    GNUNET_TESTBED_operation_done (peer1.op);
+  else
+    GNUNET_SCHEDULER_shutdown (); /* For shutting down testbed */
 }
 
 
@@ -461,7 +464,10 @@ stream_da (void *cls, void *op_result)
   {
     lsocket = op_result;
     GNUNET_STREAM_listen_close (lsocket);
-    GNUNET_TESTBED_operation_done (peer2.op);
+    if (NULL != peer2.op)
+      GNUNET_TESTBED_operation_done (peer2.op);
+    else
+      GNUNET_SCHEDULER_shutdown ();
     return;
   }
   if (&peer2 == cls)