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/test_dht_topo.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/test_dht_topo.c')
-rw-r--r-- | src/dht/test_dht_topo.c | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/dht/test_dht_topo.c b/src/dht/test_dht_topo.c index 8be3064f7..79edb2b0c 100644 --- a/src/dht/test_dht_topo.c +++ b/src/dht/test_dht_topo.c | |||
@@ -332,19 +332,17 @@ dht_get_handler (void *cls, | |||
332 | "Get successful\n"); | 332 | "Get successful\n"); |
333 | #if 0 | 333 | #if 0 |
334 | { | 334 | { |
335 | int i; | ||
336 | |||
337 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 335 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
338 | "PATH: (get %u, put %u)\n", | 336 | "PATH: (get %u, put %u)\n", |
339 | get_path_length, | 337 | get_path_length, |
340 | put_path_length); | 338 | put_path_length); |
341 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 339 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
342 | " LOCAL\n"); | 340 | " LOCAL\n"); |
343 | for (i = get_path_length - 1; i >= 0; i--) | 341 | for (int i = get_path_length - 1; i >= 0; i--) |
344 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 342 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
345 | " %s\n", | 343 | " %s\n", |
346 | GNUNET_i2s (&get_path[i])); | 344 | GNUNET_i2s (&get_path[i])); |
347 | for (i = put_path_length - 1; i >= 0; i--) | 345 | for (int i = put_path_length - 1; i >= 0; i--) |
348 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 346 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
349 | " %s\n", | 347 | " %s\n", |
350 | GNUNET_i2s (&put_path[i])); | 348 | GNUNET_i2s (&put_path[i])); |
@@ -384,12 +382,11 @@ do_puts (void *cls) | |||
384 | struct GNUNET_DHT_Handle **hs = cls; | 382 | struct GNUNET_DHT_Handle **hs = cls; |
385 | struct GNUNET_HashCode key; | 383 | struct GNUNET_HashCode key; |
386 | struct GNUNET_HashCode value; | 384 | struct GNUNET_HashCode value; |
387 | unsigned int i; | ||
388 | 385 | ||
389 | put_task = NULL; | 386 | put_task = NULL; |
390 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 387 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
391 | "Putting values into DHT\n"); | 388 | "Putting values into DHT\n"); |
392 | for (i = 0; i < NUM_PEERS; i++) | 389 | for (unsigned int i = 0; i < NUM_PEERS; i++) |
393 | { | 390 | { |
394 | GNUNET_CRYPTO_hash (&i, | 391 | GNUNET_CRYPTO_hash (&i, |
395 | sizeof (i), | 392 | sizeof (i), |