diff options
| author | Matthias Wachs <wachs@net.in.tum.de> | 2011-04-20 08:29:52 +0000 |
|---|---|---|
| committer | Matthias Wachs <wachs@net.in.tum.de> | 2011-04-20 08:29:52 +0000 |
| commit | 167c1552f3db95705317f32e21f6cd73ef75c9c6 (patch) | |
| tree | f0846b7fc3f043c43f8aeb31ec393e0158f27a0e /src | |
| parent | 46aedb2a4c5ada8aa2fff6a4b860b1300ab7303f (diff) | |
| download | gnunet-167c1552f3db95705317f32e21f6cd73ef75c9c6.tar.gz gnunet-167c1552f3db95705317f32e21f6cd73ef75c9c6.zip | |
timeout
Diffstat (limited to 'src')
| -rw-r--r-- | src/dht/gnunet-dht-driver.c | 4 | ||||
| -rw-r--r-- | src/dht/test_dht_api.c | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/dht/gnunet-dht-driver.c b/src/dht/gnunet-dht-driver.c index c09ac9ad0..2010326e6 100644 --- a/src/dht/gnunet-dht-driver.c +++ b/src/dht/gnunet-dht-driver.c | |||
| @@ -2042,7 +2042,7 @@ get_stop_task(void *cls, const struct GNUNET_SCHEDULER_TaskContext * tc) | |||
| 2042 | { | 2042 | { |
| 2043 | struct TestGetContext *test_get = cls; | 2043 | struct TestGetContext *test_get = cls; |
| 2044 | 2044 | ||
| 2045 | if (tc->reason == GNUNET_SCHEDULER_REASON_TIMEOUT) | 2045 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_TIMEOUT) != 0) |
| 2046 | gets_failed++; | 2046 | gets_failed++; |
| 2047 | else | 2047 | else |
| 2048 | cumulative_successful_gets++; | 2048 | cumulative_successful_gets++; |
| @@ -2180,7 +2180,7 @@ put_finished(void *cls, const struct GNUNET_SCHEDULER_TaskContext * tc) | |||
| 2180 | outstanding_puts--; | 2180 | outstanding_puts--; |
| 2181 | puts_completed++; | 2181 | puts_completed++; |
| 2182 | 2182 | ||
| 2183 | if (tc->reason == GNUNET_SCHEDULER_REASON_TIMEOUT) | 2183 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_TIMEOUT) != 0) |
| 2184 | fprintf (stderr, "PUT Request failed!\n"); | 2184 | fprintf (stderr, "PUT Request failed!\n"); |
| 2185 | 2185 | ||
| 2186 | /* Reset the daemon (which peer to insert at) for later put request iterations */ | 2186 | /* Reset the daemon (which peer to insert at) for later put request iterations */ |
diff --git a/src/dht/test_dht_api.c b/src/dht/test_dht_api.c index 49dae1217..5ae53b1f0 100644 --- a/src/dht/test_dht_api.c +++ b/src/dht/test_dht_api.c | |||
| @@ -169,7 +169,7 @@ test_find_peer_stop (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
| 169 | struct PeerContext *peer = cls; | 169 | struct PeerContext *peer = cls; |
| 170 | 170 | ||
| 171 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Called test_find_peer_stop!\n"); | 171 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Called test_find_peer_stop!\n"); |
| 172 | if (tc->reason == GNUNET_SCHEDULER_REASON_TIMEOUT) | 172 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_TIMEOUT) != 0) |
| 173 | { | 173 | { |
| 174 | GNUNET_break (0); | 174 | GNUNET_break (0); |
| 175 | GNUNET_SCHEDULER_cancel (die_task); | 175 | GNUNET_SCHEDULER_cancel (die_task); |
| @@ -348,7 +348,7 @@ test_get_stop (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
| 348 | struct PeerContext *peer = cls; | 348 | struct PeerContext *peer = cls; |
| 349 | 349 | ||
| 350 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Called test_get_stop!\n"); | 350 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Called test_get_stop!\n"); |
| 351 | if (tc->reason == GNUNET_SCHEDULER_REASON_TIMEOUT) | 351 | if ( (tc->reason & GNUNET_SCHEDULER_REASON_TIMEOUT) != 0) |
| 352 | { | 352 | { |
| 353 | GNUNET_break (0); | 353 | GNUNET_break (0); |
| 354 | GNUNET_SCHEDULER_cancel (die_task); | 354 | GNUNET_SCHEDULER_cancel (die_task); |