diff options
author | Christian Grothoff <christian@grothoff.org> | 2013-01-25 13:40:41 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2013-01-25 13:40:41 +0000 |
commit | 27bc9bc00c38d9ae347599d05aa6fffd9db8f34e (patch) | |
tree | 2f59c9ff1657d4ec050960cb2c826406f9c03145 /src/dht | |
parent | d5613dec791f437441a351973b283196b278763d (diff) | |
download | gnunet-27bc9bc00c38d9ae347599d05aa6fffd9db8f34e.tar.gz gnunet-27bc9bc00c38d9ae347599d05aa6fffd9db8f34e.zip |
-allow disconnecting from DHT during GET iterator
Diffstat (limited to 'src/dht')
-rw-r--r-- | src/dht/dht_api.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/dht/dht_api.c b/src/dht/dht_api.c index 0e709a83f..e40e702ee 100644 --- a/src/dht/dht_api.c +++ b/src/dht/dht_api.c | |||
@@ -642,7 +642,7 @@ transmit_pending (void *cls, size_t size, void *buf) | |||
642 | * @param key query of the request | 642 | * @param key query of the request |
643 | * @param value the 'struct GNUNET_DHT_RouteHandle' of a request matching the same key | 643 | * @param value the 'struct GNUNET_DHT_RouteHandle' of a request matching the same key |
644 | * @return GNUNET_YES to continue to iterate over all results, | 644 | * @return GNUNET_YES to continue to iterate over all results, |
645 | * GNUNET_NO if the reply is malformed | 645 | * GNUNET_NO if the reply is malformed or we found a matching request |
646 | */ | 646 | */ |
647 | static int | 647 | static int |
648 | process_reply (void *cls, const struct GNUNET_HashCode * key, void *value) | 648 | process_reply (void *cls, const struct GNUNET_HashCode * key, void *value) |
@@ -703,7 +703,7 @@ process_reply (void *cls, const struct GNUNET_HashCode * key, void *value) | |||
703 | GNUNET_TIME_absolute_ntoh (dht_msg->expiration), key, | 703 | GNUNET_TIME_absolute_ntoh (dht_msg->expiration), key, |
704 | get_path, get_path_length, put_path, put_path_length, | 704 | get_path, get_path_length, put_path, put_path_length, |
705 | ntohl (dht_msg->type), data_length, data); | 705 | ntohl (dht_msg->type), data_length, data); |
706 | return GNUNET_YES; | 706 | return GNUNET_NO; |
707 | } | 707 | } |
708 | 708 | ||
709 | /** | 709 | /** |