aboutsummaryrefslogtreecommitdiff
path: root/src/dht/gnunet-service-xdht_clients.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/dht/gnunet-service-xdht_clients.c')
-rw-r--r--src/dht/gnunet-service-xdht_clients.c6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/dht/gnunet-service-xdht_clients.c b/src/dht/gnunet-service-xdht_clients.c
index 9cc156e3d..72d086606 100644
--- a/src/dht/gnunet-service-xdht_clients.c
+++ b/src/dht/gnunet-service-xdht_clients.c
@@ -21,8 +21,7 @@
21/** 21/**
22 * @file dht/gnunet-service-xdht_clients.c 22 * @file dht/gnunet-service-xdht_clients.c
23 * @brief GNUnet DHT service's client management code 23 * @brief GNUnet DHT service's client management code
24 * @author Christian Grothoff 24 * @author Supriti Singh
25 * @author Nathan Evans
26 */ 25 */
27 26
28#include "platform.h" 27#include "platform.h"
@@ -362,6 +361,7 @@ static void
362handle_client_disconnect (void *cls, 361handle_client_disconnect (void *cls,
363 struct GNUNET_SERVER_Client *client) 362 struct GNUNET_SERVER_Client *client)
364{ 363{
364
365 struct ClientList *pos; 365 struct ClientList *pos;
366 struct PendingMessage *reply; 366 struct PendingMessage *reply;
367 struct ClientMonitorRecord *monitor; 367 struct ClientMonitorRecord *monitor;
@@ -428,6 +428,7 @@ transmit_request (struct ClientQueryRecord *cqr)
428 LOG (GNUNET_ERROR_TYPE_DEBUG, 428 LOG (GNUNET_ERROR_TYPE_DEBUG,
429 "Initiating GET for %s, replication %u, already have %u replies\n", 429 "Initiating GET for %s, replication %u, already have %u replies\n",
430 GNUNET_h2s(&cqr->key), cqr->replication, cqr->seen_replies_count); 430 GNUNET_h2s(&cqr->key), cqr->replication, cqr->seen_replies_count);
431
431 GDS_NEIGHBOURS_handle_get (cqr->type, cqr->msg_options, cqr->replication, 432 GDS_NEIGHBOURS_handle_get (cqr->type, cqr->msg_options, cqr->replication,
432 0 /* hop count */ , 433 0 /* hop count */ ,
433 &cqr->key, cqr->xquery, cqr->xquery_size, reply_bf, 434 &cqr->key, cqr->xquery, cqr->xquery_size, reply_bf,
@@ -532,6 +533,7 @@ handle_dht_local_put (void *cls, struct GNUNET_SERVER_Client *client,
532 peer_bf = 533 peer_bf =
533 GNUNET_CONTAINER_bloomfilter_init (NULL, DHT_BLOOM_SIZE, 534 GNUNET_CONTAINER_bloomfilter_init (NULL, DHT_BLOOM_SIZE,
534 GNUNET_CONSTANTS_BLOOMFILTER_K); 535 GNUNET_CONSTANTS_BLOOMFILTER_K);
536
535 GDS_NEIGHBOURS_handle_put (ntohl (dht_msg->type), ntohl (dht_msg->options), 537 GDS_NEIGHBOURS_handle_put (ntohl (dht_msg->type), ntohl (dht_msg->options),
536 ntohl (dht_msg->desired_replication_level), 538 ntohl (dht_msg->desired_replication_level),
537 GNUNET_TIME_absolute_ntoh (dht_msg->expiration), 539 GNUNET_TIME_absolute_ntoh (dht_msg->expiration),