aboutsummaryrefslogtreecommitdiff
path: root/src/set
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2013-07-24 10:48:53 +0000
committerFlorian Dold <florian.dold@gmail.com>2013-07-24 10:48:53 +0000
commite36ab4fe73d3eb9b0386e6fb381b34a369878b60 (patch)
tree2f3016eee812fb347b5992db9598ec1ff47aafe7 /src/set
parent8fc1908cf91e4c992e9ad9c85f1fa7eda5f7c8e8 (diff)
downloadgnunet-e36ab4fe73d3eb9b0386e6fb381b34a369878b60.tar.gz
gnunet-e36ab4fe73d3eb9b0386e6fb381b34a369878b60.zip
-consensus fixes
Diffstat (limited to 'src/set')
-rw-r--r--src/set/gnunet-service-set_union.c5
-rw-r--r--src/set/set_api.c3
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,
564void 564void
565GNUNET_SET_listen_cancel (struct GNUNET_SET_ListenHandle *lh) 565GNUNET_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