diff options
author | Christian Grothoff <christian@grothoff.org> | 2017-02-27 15:28:00 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2017-02-27 15:28:00 +0100 |
commit | 830137e312e8e565c9113a20411aa3073fbd1cbd (patch) | |
tree | c5c85eb38dc28a353c087ce2058e4cd5c11534ea /src/revocation/gnunet-service-revocation.c | |
parent | ee3327de8fd04b2b8ce8692560c9f1d01a822baa (diff) |
implement revocation block plugin, get revocation test to pass again
Diffstat (limited to 'src/revocation/gnunet-service-revocation.c')
-rw-r--r-- | src/revocation/gnunet-service-revocation.c | 16 |
1 files changed, 9 insertions, 7 deletions
diff --git a/src/revocation/gnunet-service-revocation.c b/src/revocation/gnunet-service-revocation.c index 99bec1fc8..9d077f874 100644 --- a/src/revocation/gnunet-service-revocation.c +++ b/src/revocation/gnunet-service-revocation.c @@ -38,6 +38,7 @@ #include "platform.h" #include <math.h> #include "gnunet_util_lib.h" +#include "gnunet_block_lib.h" #include "gnunet_constants.h" #include "gnunet_protocols.h" #include "gnunet_signatures.h" @@ -215,7 +216,7 @@ client_connect_cb (void *cls, * @param client the new client * @param app_cls must alias @a client */ -static void +static void client_disconnect_cb (void *cls, struct GNUNET_SERVICE_Client *client, void *app_cls) @@ -352,7 +353,7 @@ publicize_rm (const struct RevokeMessage *rm) GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY)); /* add to set for future connections */ e.size = htons (rm->header.size); - e.element_type = 0; + e.element_type = GNUNET_BLOCK_TYPE_REVOCATION; e.data = rm; if (GNUNET_OK != GNUNET_SET_add_element (revocation_set, @@ -452,11 +453,12 @@ add_revocation (void *cls, GNUNET_break_op (0); return; } - if (0 != element->element_type) + if (GNUNET_BLOCK_TYPE_REVOCATION != element->element_type) { GNUNET_STATISTICS_update (stats, gettext_noop ("# unsupported revocations received via set union"), - 1, GNUNET_NO); + 1, + GNUNET_NO); return; } rm = element->data; @@ -604,12 +606,12 @@ handle_core_disconnect (void *cls, void *internal_cls) { struct PeerEntry *peer_entry = internal_cls; - + if (0 == memcmp (peer, &my_identity, sizeof (my_identity))) return; - GNUNET_assert (NULL != peer_entry); + GNUNET_assert (NULL != peer_entry); GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Peer `%s' disconnected from us\n", GNUNET_i2s (peer)); @@ -783,7 +785,7 @@ handle_revocation_union_request (void *cls, static void run (void *cls, const struct GNUNET_CONFIGURATION_Handle *c, - struct GNUNET_SERVICE_Handle *service) + struct GNUNET_SERVICE_Handle *service) { struct GNUNET_MQ_MessageHandler core_handlers[] = { GNUNET_MQ_hd_fixed_size (p2p_revoke, |