aboutsummaryrefslogtreecommitdiff
path: root/src/dht
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2013-01-25 13:40:41 +0000
committerChristian Grothoff <christian@grothoff.org>2013-01-25 13:40:41 +0000
commit27bc9bc00c38d9ae347599d05aa6fffd9db8f34e (patch)
tree2f59c9ff1657d4ec050960cb2c826406f9c03145 /src/dht
parentd5613dec791f437441a351973b283196b278763d (diff)
downloadgnunet-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.c4
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 */
647static int 647static int
648process_reply (void *cls, const struct GNUNET_HashCode * key, void *value) 648process_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/**