diff options
author | Omar Tarabai <tarabai@devegypt.com> | 2014-06-05 12:05:13 +0000 |
---|---|---|
committer | Omar Tarabai <tarabai@devegypt.com> | 2014-06-05 12:05:13 +0000 |
commit | d33c98924608b9aa01fe5e77330a7d7f11849acb (patch) | |
tree | 4dea172fdc5fcec35db6d71d4457d4f811313d11 /src/peerstore/peerstore_api.c | |
parent | ed152ee424088c09368b865afaa1117f0a207963 (diff) | |
download | gnunet-d33c98924608b9aa01fe5e77330a7d7f11849acb.tar.gz gnunet-d33c98924608b9aa01fe5e77330a7d7f11849acb.zip |
peerstore: stress test + minor fix
Diffstat (limited to 'src/peerstore/peerstore_api.c')
-rw-r--r-- | src/peerstore/peerstore_api.c | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/peerstore/peerstore_api.c b/src/peerstore/peerstore_api.c index 0143c58cc..ea8579517 100644 --- a/src/peerstore/peerstore_api.c +++ b/src/peerstore/peerstore_api.c | |||
@@ -387,8 +387,6 @@ void store_request_sent (void *cls) | |||
387 | void | 387 | void |
388 | GNUNET_PEERSTORE_store_cancel (struct GNUNET_PEERSTORE_StoreContext *sc) | 388 | GNUNET_PEERSTORE_store_cancel (struct GNUNET_PEERSTORE_StoreContext *sc) |
389 | { | 389 | { |
390 | LOG(GNUNET_ERROR_TYPE_DEBUG, | ||
391 | "Canceling store request.\n"); | ||
392 | if(NULL != sc->ev) | 390 | if(NULL != sc->ev) |
393 | { | 391 | { |
394 | GNUNET_MQ_send_cancel(sc->ev); | 392 | GNUNET_MQ_send_cancel(sc->ev); |
@@ -548,7 +546,6 @@ void iterate_timeout (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
548 | void | 546 | void |
549 | GNUNET_PEERSTORE_iterate_cancel (struct GNUNET_PEERSTORE_IterateContext *ic) | 547 | GNUNET_PEERSTORE_iterate_cancel (struct GNUNET_PEERSTORE_IterateContext *ic) |
550 | { | 548 | { |
551 | LOG(GNUNET_ERROR_TYPE_DEBUG, "Canceling iterate request.\n"); | ||
552 | if(GNUNET_SCHEDULER_NO_TASK != ic->timeout_task) | 549 | if(GNUNET_SCHEDULER_NO_TASK != ic->timeout_task) |
553 | { | 550 | { |
554 | GNUNET_SCHEDULER_cancel(ic->timeout_task); | 551 | GNUNET_SCHEDULER_cancel(ic->timeout_task); |
@@ -728,7 +725,8 @@ GNUNET_PEERSTORE_watch (struct GNUNET_PEERSTORE_Handle *h, | |||
728 | GNUNET_CONTAINER_multihashmap_put(h->watches, &wc->keyhash, | 725 | GNUNET_CONTAINER_multihashmap_put(h->watches, &wc->keyhash, |
729 | wc, GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE); | 726 | wc, GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE); |
730 | LOG(GNUNET_ERROR_TYPE_DEBUG, | 727 | LOG(GNUNET_ERROR_TYPE_DEBUG, |
731 | "Sending a watch request for sub system `%s'.\n", sub_system); | 728 | "Sending a watch request for ss `%s', peer `%s', key `%s'.\n", |
729 | sub_system, GNUNET_i2s(peer), key); | ||
732 | GNUNET_MQ_notify_sent(ev, &watch_request_sent, wc); | 730 | GNUNET_MQ_notify_sent(ev, &watch_request_sent, wc); |
733 | GNUNET_MQ_send(h->mq, ev); | 731 | GNUNET_MQ_send(h->mq, ev); |
734 | return wc; | 732 | return wc; |