diff options
Diffstat (limited to 'src/zonemaster/gnunet-service-zonemaster.c')
-rw-r--r-- | src/zonemaster/gnunet-service-zonemaster.c | 22 |
1 files changed, 7 insertions, 15 deletions
diff --git a/src/zonemaster/gnunet-service-zonemaster.c b/src/zonemaster/gnunet-service-zonemaster.c index 590e5aae2..c91c4b679 100644 --- a/src/zonemaster/gnunet-service-zonemaster.c +++ b/src/zonemaster/gnunet-service-zonemaster.c | |||
@@ -359,11 +359,9 @@ publish_zone_dht_start (void *cls); | |||
359 | * by a monitor is done. | 359 | * by a monitor is done. |
360 | * | 360 | * |
361 | * @param cls a `struct DhtPutActivity` | 361 | * @param cls a `struct DhtPutActivity` |
362 | * @param success #GNUNET_OK on success | ||
363 | */ | 362 | */ |
364 | static void | 363 | static void |
365 | dht_put_monitor_continuation (void *cls, | 364 | dht_put_monitor_continuation (void *cls) |
366 | int success) | ||
367 | { | 365 | { |
368 | struct DhtPutActivity *ma = cls; | 366 | struct DhtPutActivity *ma = cls; |
369 | 367 | ||
@@ -512,29 +510,23 @@ update_velocity () | |||
512 | * Continuation called from DHT once the PUT operation is done. | 510 | * Continuation called from DHT once the PUT operation is done. |
513 | * | 511 | * |
514 | * @param cls a `struct DhtPutActivity` | 512 | * @param cls a `struct DhtPutActivity` |
515 | * @param success #GNUNET_OK on success | ||
516 | */ | 513 | */ |
517 | static void | 514 | static void |
518 | dht_put_continuation (void *cls, | 515 | dht_put_continuation (void *cls) |
519 | int success) | ||
520 | { | 516 | { |
521 | struct DhtPutActivity *ma = cls; | 517 | struct DhtPutActivity *ma = cls; |
522 | 518 | ||
523 | num_public_records++; | 519 | num_public_records++; |
524 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 520 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
525 | "PUT complete (%s)\n", | 521 | "PUT complete\n"); |
526 | (GNUNET_OK == success) ? "success" : "failure"); | ||
527 | dht_queue_length--; | 522 | dht_queue_length--; |
528 | GNUNET_CONTAINER_DLL_remove (it_head, | 523 | GNUNET_CONTAINER_DLL_remove (it_head, |
529 | it_tail, | 524 | it_tail, |
530 | ma); | 525 | ma); |
531 | GNUNET_free (ma); | 526 | GNUNET_free (ma); |
532 | if (GNUNET_OK == success) | 527 | put_cnt++; |
533 | { | 528 | if (0 == put_cnt % DELTA_INTERVAL) |
534 | put_cnt++; | 529 | update_velocity (); |
535 | if (0 == put_cnt % DELTA_INTERVAL) | ||
536 | update_velocity (); | ||
537 | } | ||
538 | } | 530 | } |
539 | 531 | ||
540 | 532 | ||
@@ -598,7 +590,7 @@ perform_dht_put (const struct GNUNET_CRYPTO_EcdsaPrivateKey *key, | |||
598 | const char *label, | 590 | const char *label, |
599 | const struct GNUNET_GNSRECORD_Data *rd_public, | 591 | const struct GNUNET_GNSRECORD_Data *rd_public, |
600 | unsigned int rd_public_count, | 592 | unsigned int rd_public_count, |
601 | GNUNET_DHT_PutContinuation cont, | 593 | GNUNET_SCHEDULER_TaskCallback cont, |
602 | void *cont_cls) | 594 | void *cont_cls) |
603 | { | 595 | { |
604 | struct GNUNET_GNSRECORD_Block *block; | 596 | struct GNUNET_GNSRECORD_Block *block; |