aboutsummaryrefslogtreecommitdiff
path: root/src/cadet/test_cadet.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/cadet/test_cadet.c')
-rw-r--r--src/cadet/test_cadet.c14
1 files changed, 10 insertions, 4 deletions
diff --git a/src/cadet/test_cadet.c b/src/cadet/test_cadet.c
index 251858ebd..1b5d2dca3 100644
--- a/src/cadet/test_cadet.c
+++ b/src/cadet/test_cadet.c
@@ -33,7 +33,7 @@
33/** 33/**
34 * How namy messages to send 34 * How namy messages to send
35 */ 35 */
36#define TOTAL_PACKETS 1000 36#define TOTAL_PACKETS 2000
37 37
38/** 38/**
39 * How long until we give up on connecting the peers? 39 * How long until we give up on connecting the peers?
@@ -249,9 +249,14 @@ disconnect_cadet_peers (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc
249 long line = (long) cls; 249 long line = (long) cls;
250 unsigned int i; 250 unsigned int i;
251 251
252 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 252 if ((GNUNET_SCHEDULER_REASON_SHUTDOWN & tc->reason) != 0)
253 "disconnecting cadet service of peers, called from line %ld\n", 253 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
254 line); 254 "disconnecting cadet peers due to SHUTDOWN! called from %ld\n",
255 line);
256 else
257 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
258 "disconnecting cadet service of peers, called from line %ld\n",
259 line);
255 disconnect_task = GNUNET_SCHEDULER_NO_TASK; 260 disconnect_task = GNUNET_SCHEDULER_NO_TASK;
256 for (i = 0; i < 2; i++) 261 for (i = 0; i < 2; i++)
257 { 262 {
@@ -436,6 +441,7 @@ data_callback (void *cls, struct GNUNET_CADET_Channel *channel,
436 { 441 {
437 if (GNUNET_SCHEDULER_NO_TASK != disconnect_task) 442 if (GNUNET_SCHEDULER_NO_TASK != disconnect_task)
438 { 443 {
444 GNUNET_log (GNUNET_ERROR_TYPE_INFO, " reschedule timeout\n");
439 GNUNET_SCHEDULER_cancel (disconnect_task); 445 GNUNET_SCHEDULER_cancel (disconnect_task);
440 disconnect_task = GNUNET_SCHEDULER_add_delayed (SHORT_TIME, 446 disconnect_task = GNUNET_SCHEDULER_add_delayed (SHORT_TIME,
441 &disconnect_cadet_peers, 447 &disconnect_cadet_peers,