aboutsummaryrefslogtreecommitdiff
path: root/src/peerstore/peerstore_api.c
diff options
context:
space:
mode:
authorOmar Tarabai <tarabai@devegypt.com>2014-06-05 12:05:13 +0000
committerOmar Tarabai <tarabai@devegypt.com>2014-06-05 12:05:13 +0000
commitd33c98924608b9aa01fe5e77330a7d7f11849acb (patch)
tree4dea172fdc5fcec35db6d71d4457d4f811313d11 /src/peerstore/peerstore_api.c
parented152ee424088c09368b865afaa1117f0a207963 (diff)
downloadgnunet-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.c6
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)
387void 387void
388GNUNET_PEERSTORE_store_cancel (struct GNUNET_PEERSTORE_StoreContext *sc) 388GNUNET_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)
548void 546void
549GNUNET_PEERSTORE_iterate_cancel (struct GNUNET_PEERSTORE_IterateContext *ic) 547GNUNET_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;