aboutsummaryrefslogtreecommitdiff
path: root/src/zonemaster/gnunet-service-zonemaster.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/zonemaster/gnunet-service-zonemaster.c')
-rw-r--r--src/zonemaster/gnunet-service-zonemaster.c22
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 */
364static void 363static void
365dht_put_monitor_continuation (void *cls, 364dht_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 */
517static void 514static void
518dht_put_continuation (void *cls, 515dht_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;