diff options
Diffstat (limited to 'src/transport/test_transport_startonly.c')
-rw-r--r-- | src/transport/test_transport_startonly.c | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/src/transport/test_transport_startonly.c b/src/transport/test_transport_startonly.c index d49e3a8c0..7dd4984e2 100644 --- a/src/transport/test_transport_startonly.c +++ b/src/transport/test_transport_startonly.c | |||
@@ -67,15 +67,9 @@ end () | |||
67 | static void | 67 | static void |
68 | end_badly (void *cls) | 68 | end_badly (void *cls) |
69 | { | 69 | { |
70 | const struct GNUNET_SCHEDULER_TaskContext *tc; | 70 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
71 | 71 | "Fail! Stopping peers\n"); | |
72 | tc = GNUNET_SCHEDULER_get_task_context (); | ||
73 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Fail! Stopping peers\n"); | ||
74 | |||
75 | timeout_task = NULL; | 72 | timeout_task = NULL; |
76 | if ((tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN) != 0) | ||
77 | return; | ||
78 | |||
79 | if (p1 != NULL) | 73 | if (p1 != NULL) |
80 | GNUNET_TRANSPORT_TESTING_stop_peer (tth, p1); | 74 | GNUNET_TRANSPORT_TESTING_stop_peer (tth, p1); |
81 | if (NULL != tth) | 75 | if (NULL != tth) |
@@ -83,6 +77,7 @@ end_badly (void *cls) | |||
83 | ret = GNUNET_SYSERR; | 77 | ret = GNUNET_SYSERR; |
84 | } | 78 | } |
85 | 79 | ||
80 | |||
86 | static void | 81 | static void |
87 | notify_connect (void *cls, const struct GNUNET_PeerIdentity *peer) | 82 | notify_connect (void *cls, const struct GNUNET_PeerIdentity *peer) |
88 | { | 83 | { |
@@ -91,6 +86,7 @@ notify_connect (void *cls, const struct GNUNET_PeerIdentity *peer) | |||
91 | connected++; | 86 | connected++; |
92 | } | 87 | } |
93 | 88 | ||
89 | |||
94 | static void | 90 | static void |
95 | notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) | 91 | notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) |
96 | { | 92 | { |
@@ -98,6 +94,7 @@ notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) | |||
98 | GNUNET_i2s (peer)); | 94 | GNUNET_i2s (peer)); |
99 | } | 95 | } |
100 | 96 | ||
97 | |||
101 | static void | 98 | static void |
102 | notify_receive (void *cls, const struct GNUNET_PeerIdentity *peer, | 99 | notify_receive (void *cls, const struct GNUNET_PeerIdentity *peer, |
103 | const struct GNUNET_MessageHeader *message) | 100 | const struct GNUNET_MessageHeader *message) |