diff options
author | Christian Grothoff <christian@grothoff.org> | 2016-06-23 16:30:45 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2016-06-23 16:30:45 +0000 |
commit | 021e5d47b4ac2fd2088cee65e551fd7e6114e99b (patch) | |
tree | 703829ff172d75f5417e42041ed4694a53d10e71 /src/dht/gnunet_dht_profiler.c | |
parent | c1bac2613d2e7915ab23c3675918aa839514bd97 (diff) | |
download | gnunet-021e5d47b4ac2fd2088cee65e551fd7e6114e99b.tar.gz gnunet-021e5d47b4ac2fd2088cee65e551fd7e6114e99b.zip |
convert DHT API to new MQ API
Diffstat (limited to 'src/dht/gnunet_dht_profiler.c')
-rw-r--r-- | src/dht/gnunet_dht_profiler.c | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/dht/gnunet_dht_profiler.c b/src/dht/gnunet_dht_profiler.c index 065ea5d1b..3dd93287d 100644 --- a/src/dht/gnunet_dht_profiler.c +++ b/src/dht/gnunet_dht_profiler.c | |||
@@ -755,16 +755,17 @@ delayed_put (void *cls) | |||
755 | GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK, | 755 | GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK, |
756 | ac->put_data, ac->put_data_size); | 756 | ac->put_data, ac->put_data_size); |
757 | GNUNET_CRYPTO_hash (ac->put_data, ac->put_data_size, &ac->hash); | 757 | GNUNET_CRYPTO_hash (ac->put_data, ac->put_data_size, &ac->hash); |
758 | DEBUG ("PUT_REQUEST_START key %s \n", GNUNET_h2s((struct GNUNET_HashCode *)ac->put_data)); | 758 | DEBUG ("PUT_REQUEST_START key %s\n", |
759 | ac->dht_put = GNUNET_DHT_put (ac->dht, &ac->hash, | 759 | GNUNET_h2s((struct GNUNET_HashCode *)ac->put_data)); |
760 | ac->dht_put = GNUNET_DHT_put (ac->dht, | ||
761 | &ac->hash, | ||
760 | replication, | 762 | replication, |
761 | GNUNET_DHT_RO_RECORD_ROUTE, | 763 | GNUNET_DHT_RO_RECORD_ROUTE, |
762 | GNUNET_BLOCK_TYPE_TEST, | 764 | GNUNET_BLOCK_TYPE_TEST, |
763 | ac->put_data_size, | 765 | ac->put_data_size, |
764 | ac->put_data, | 766 | ac->put_data, |
765 | GNUNET_TIME_UNIT_FOREVER_ABS, /* expiration time */ | 767 | GNUNET_TIME_UNIT_FOREVER_ABS, /* expiration time */ |
766 | timeout, /* PUT timeout */ | 768 | &put_cont, ac); /* continuation and its closure */ |
767 | put_cont, ac); /* continuation and its closure */ | ||
768 | n_puts++; | 769 | n_puts++; |
769 | } | 770 | } |
770 | 771 | ||