X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Fpeerinfo%2Fpeerinfo_api.c;h=716802389b6de7bea21dafece62b0b53726f24ac;hb=f57cbab24fb7a22fc982eb8b6c4a2d18402be460;hp=faa56e908b54e43b03acde434c13bbb6522210e5;hpb=425e9cdea733ca7be9a901abff7a070c460fa84d;p=oweals%2Fgnunet.git diff --git a/src/peerinfo/peerinfo_api.c b/src/peerinfo/peerinfo_api.c index faa56e908..716802389 100644 --- a/src/peerinfo/peerinfo_api.c +++ b/src/peerinfo/peerinfo_api.c @@ -24,11 +24,8 @@ * @author Christian Grothoff */ #include "platform.h" -#include "gnunet_client_lib.h" -#include "gnunet_container_lib.h" -#include "gnunet_peerinfo_service.h" +#include "gnunet_util_lib.h" #include "gnunet_protocols.h" -#include "gnunet_time_lib.h" #include "peerinfo.h" #define LOG(kind,...) GNUNET_log_from (kind, "peerinfo-api",__VA_ARGS__) @@ -204,7 +201,7 @@ GNUNET_PEERINFO_connect (const struct GNUNET_CONFIGURATION_Handle *cfg) { struct GNUNET_PEERINFO_Handle *h; - h = GNUNET_malloc (sizeof (struct GNUNET_PEERINFO_Handle)); + h = GNUNET_new (struct GNUNET_PEERINFO_Handle); h->client = GNUNET_CLIENT_connect ("peerinfo", cfg); h->cfg = cfg; return h; @@ -458,7 +455,7 @@ GNUNET_PEERINFO_add_peer (struct GNUNET_PEERINFO_Handle *h, * * @param ac handle for the add operation to cancel */ -void +void GNUNET_PEERINFO_add_peer_cancel (struct GNUNET_PEERINFO_AddContext *ac) { struct GNUNET_PEERINFO_Handle *h = ac->h; @@ -531,7 +528,7 @@ peerinfo_handler (void *cls, const struct GNUNET_MessageHeader *msg) h->in_receive = GNUNET_YES; GNUNET_CLIENT_receive (h->client, &peerinfo_handler, h, GNUNET_TIME_absolute_get_remaining (h->ic_head->timeout)); - } + } if (NULL != cb) cb (cb_cls, NULL, NULL, NULL); return; @@ -558,13 +555,13 @@ peerinfo_handler (void *cls, const struct GNUNET_MessageHeader *msg) /* bogus message (from a different iteration call?); out of sequence! */ LOG (GNUNET_ERROR_TYPE_ERROR, "Received HELLO for peer `%s', expected peer `%s'\n", - GNUNET_h2s (&im->peer.hashPubKey), + GNUNET_i2s (&im->peer), GNUNET_i2s (&ic->peer)); - + GNUNET_break (0); GNUNET_PEERINFO_iterate_cancel (ic); reconnect (h); - if (NULL != cb) + if (NULL != cb) cb (cb_cls, NULL, NULL, _("Received invalid message from `PEERINFO' service.")); return; @@ -579,7 +576,7 @@ peerinfo_handler (void *cls, const struct GNUNET_MessageHeader *msg) GNUNET_break (0); GNUNET_PEERINFO_iterate_cancel (ic); reconnect (h); - if (NULL != cb) + if (NULL != cb) cb (cb_cls, NULL, NULL, _("Received invalid message from `PEERINFO' service.")); return; @@ -590,7 +587,7 @@ peerinfo_handler (void *cls, const struct GNUNET_MessageHeader *msg) GNUNET_break (0); GNUNET_PEERINFO_iterate_cancel (ic); reconnect (h); - if (NULL != cb) + if (NULL != cb) cb (cb_cls, NULL, NULL, _("Received invalid message from `PEERINFO' service.")); return; @@ -601,7 +598,7 @@ peerinfo_handler (void *cls, const struct GNUNET_MessageHeader *msg) GNUNET_break (0); GNUNET_PEERINFO_iterate_cancel (ic); reconnect (h); - if (NULL != cb) + if (NULL != cb) cb (cb_cls, NULL, NULL, _("Received invalid message from `PEERINFO' service.")); return; @@ -711,7 +708,7 @@ GNUNET_PEERINFO_iterate (struct GNUNET_PEERINFO_Handle *h, struct GNUNET_PEERINFO_IteratorContext *ic; struct GNUNET_PEERINFO_AddContext *ac; - ic = GNUNET_malloc (sizeof (struct GNUNET_PEERINFO_IteratorContext)); + ic = GNUNET_new (struct GNUNET_PEERINFO_IteratorContext); if (NULL == peer) { LOG (GNUNET_ERROR_TYPE_DEBUG,