diff options
author | Christian Grothoff <christian@grothoff.org> | 2018-04-30 11:31:22 +0200 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2018-04-30 11:31:22 +0200 |
commit | ccf723196e9ff7f31a56a8e8ebd8319d07fa17c8 (patch) | |
tree | 0ccec2bc54f5f80f35054dda5a1cfe8202ab522f /src/dht/gnunet-service-dht_clients.c | |
parent | 82c1ee4d147f28e919d82f87fcd787e719d7e572 (diff) | |
download | gnunet-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.c | 8 |
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 | ||