diff options
Diffstat (limited to 'src/dht/gnunet-service-xdht_clients.c')
-rw-r--r-- | src/dht/gnunet-service-xdht_clients.c | 6 |
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 | |||
362 | handle_client_disconnect (void *cls, | 361 | handle_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), |