diff options
author | Florian Dold <florian.dold@gmail.com> | 2013-07-24 10:48:53 +0000 |
---|---|---|
committer | Florian Dold <florian.dold@gmail.com> | 2013-07-24 10:48:53 +0000 |
commit | e36ab4fe73d3eb9b0386e6fb381b34a369878b60 (patch) | |
tree | 2f3016eee812fb347b5992db9598ec1ff47aafe7 /src/set | |
parent | 8fc1908cf91e4c992e9ad9c85f1fa7eda5f7c8e8 (diff) | |
download | gnunet-e36ab4fe73d3eb9b0386e6fb381b34a369878b60.tar.gz gnunet-e36ab4fe73d3eb9b0386e6fb381b34a369878b60.zip |
-consensus fixes
Diffstat (limited to 'src/set')
-rw-r--r-- | src/set/gnunet-service-set_union.c | 5 | ||||
-rw-r--r-- | src/set/set_api.c | 3 |
2 files changed, 5 insertions, 3 deletions
diff --git a/src/set/gnunet-service-set_union.c b/src/set/gnunet-service-set_union.c index 8a6bfa448..644f975b6 100644 --- a/src/set/gnunet-service-set_union.c +++ b/src/set/gnunet-service-set_union.c | |||
@@ -873,8 +873,9 @@ decode_and_send (struct OperationState *eo) | |||
873 | last_key = key; | 873 | last_key = key; |
874 | 874 | ||
875 | res = ibf_decode (diff_ibf, &side, &key); | 875 | res = ibf_decode (diff_ibf, &side, &key); |
876 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "decoded ibf key %lx\n", | 876 | if (res == GNUNET_OK) |
877 | key.key_val); | 877 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "decoded ibf key %lx\n", |
878 | key.key_val); | ||
878 | num_decoded += 1; | 879 | num_decoded += 1; |
879 | if (num_decoded > diff_ibf->size || (num_decoded > 1 && last_key.key_val == key.key_val)) | 880 | if (num_decoded > diff_ibf->size || (num_decoded > 1 && last_key.key_val == key.key_val)) |
880 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "detected cyclic ibf (decoded %u/%u)\n", | 881 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "detected cyclic ibf (decoded %u/%u)\n", |
diff --git a/src/set/set_api.c b/src/set/set_api.c index c2e88e65f..b2e62cb4d 100644 --- a/src/set/set_api.c +++ b/src/set/set_api.c | |||
@@ -564,8 +564,9 @@ GNUNET_SET_listen (const struct GNUNET_CONFIGURATION_Handle *cfg, | |||
564 | void | 564 | void |
565 | GNUNET_SET_listen_cancel (struct GNUNET_SET_ListenHandle *lh) | 565 | GNUNET_SET_listen_cancel (struct GNUNET_SET_ListenHandle *lh) |
566 | { | 566 | { |
567 | GNUNET_CLIENT_disconnect (lh->client); | 567 | LOG (GNUNET_ERROR_TYPE_DEBUG, "canceling listener\n"); |
568 | GNUNET_MQ_destroy (lh->mq); | 568 | GNUNET_MQ_destroy (lh->mq); |
569 | GNUNET_CLIENT_disconnect (lh->client); | ||
569 | GNUNET_free (lh); | 570 | GNUNET_free (lh); |
570 | } | 571 | } |
571 | 572 | ||