aboutsummaryrefslogtreecommitdiff
path: root/src/dht/gnunet-service-dht_clients.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2018-04-30 11:31:22 +0200
committerChristian Grothoff <christian@grothoff.org>2018-04-30 11:31:22 +0200
commitccf723196e9ff7f31a56a8e8ebd8319d07fa17c8 (patch)
tree0ccec2bc54f5f80f35054dda5a1cfe8202ab522f /src/dht/gnunet-service-dht_clients.c
parent82c1ee4d147f28e919d82f87fcd787e719d7e572 (diff)
downloadgnunet-ccf723196e9ff7f31a56a8e8ebd8319d07fa17c8.tar.gz
gnunet-ccf723196e9ff7f31a56a8e8ebd8319d07fa17c8.zip
eliminate DHT PUT OK message by using MQ feature of calling continuation when transmission is complete
Diffstat (limited to 'src/dht/gnunet-service-dht_clients.c')
-rw-r--r--src/dht/gnunet-service-dht_clients.c8
1 files changed, 0 insertions, 8 deletions
diff --git a/src/dht/gnunet-service-dht_clients.c b/src/dht/gnunet-service-dht_clients.c
index cb155c484..503d7867b 100644
--- a/src/dht/gnunet-service-dht_clients.c
+++ b/src/dht/gnunet-service-dht_clients.c
@@ -477,8 +477,6 @@ handle_dht_local_put (void *cls,
477 struct ClientHandle *ch = cls; 477 struct ClientHandle *ch = cls;
478 struct GNUNET_CONTAINER_BloomFilter *peer_bf; 478 struct GNUNET_CONTAINER_BloomFilter *peer_bf;
479 uint16_t size; 479 uint16_t size;
480 struct GNUNET_MQ_Envelope *env;
481 struct GNUNET_DHT_ClientPutConfirmationMessage *conf;
482 480
483 size = ntohs (dht_msg->header.size); 481 size = ntohs (dht_msg->header.size);
484 GNUNET_STATISTICS_update (GDS_stats, 482 GNUNET_STATISTICS_update (GDS_stats,
@@ -537,12 +535,6 @@ handle_dht_local_put (void *cls,
537 &dht_msg[1], 535 &dht_msg[1],
538 size - sizeof (struct GNUNET_DHT_ClientPutMessage)); 536 size - sizeof (struct GNUNET_DHT_ClientPutMessage));
539 GNUNET_CONTAINER_bloomfilter_free (peer_bf); 537 GNUNET_CONTAINER_bloomfilter_free (peer_bf);
540 env = GNUNET_MQ_msg (conf,
541 GNUNET_MESSAGE_TYPE_DHT_CLIENT_PUT_OK);
542 conf->reserved = htonl (0);
543 conf->unique_id = dht_msg->unique_id;
544 GNUNET_MQ_send (ch->mq,
545 env);
546 GNUNET_SERVICE_client_continue (ch->client); 538 GNUNET_SERVICE_client_continue (ch->client);
547} 539}
548 540