diff options
author | Bart Polot <bart@net.in.tum.de> | 2014-06-25 00:33:11 +0000 |
---|---|---|
committer | Bart Polot <bart@net.in.tum.de> | 2014-06-25 00:33:11 +0000 |
commit | 1e789b4b3e72e217415bfed1fdb40d7a66cc1e94 (patch) | |
tree | f1a0ec37c103a0df2f7cfef398eccf364ac64ceb /src | |
parent | 30b3fb54371ba1000269a9e38e97a73b00c153f9 (diff) | |
download | gnunet-1e789b4b3e72e217415bfed1fdb40d7a66cc1e94.tar.gz gnunet-1e789b4b3e72e217415bfed1fdb40d7a66cc1e94.zip |
- log
Diffstat (limited to 'src')
-rw-r--r-- | src/cadet/gnunet-service-cadet_tunnel.c | 1 | ||||
-rw-r--r-- | src/cadet/test_cadet.c | 14 |
2 files changed, 11 insertions, 4 deletions
diff --git a/src/cadet/gnunet-service-cadet_tunnel.c b/src/cadet/gnunet-service-cadet_tunnel.c index ac24ecfaf..8efdfc2e0 100644 --- a/src/cadet/gnunet-service-cadet_tunnel.c +++ b/src/cadet/gnunet-service-cadet_tunnel.c | |||
@@ -1766,6 +1766,7 @@ handle_ephemeral (struct CadetTunnel *t, | |||
1766 | GNUNET_break_op (0); | 1766 | GNUNET_break_op (0); |
1767 | return; | 1767 | return; |
1768 | } | 1768 | } |
1769 | |||
1769 | if (NULL == t->kx_ctx) | 1770 | if (NULL == t->kx_ctx) |
1770 | create_kx_ctx (t); | 1771 | create_kx_ctx (t); |
1771 | if (0 != memcmp (&t->peers_ephemeral_key, &msg->ephemeral_key, | 1772 | if (0 != memcmp (&t->peers_ephemeral_key, &msg->ephemeral_key, |
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, |