core_api.c File Reference

core service; this is the main API for encrypted P2P communications More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_constants.h"
#include "gnunet_core_service.h"
#include "core.h"

Include dependency graph for core_api.c:

Go to the source code of this file.

Data Structures
struct	PeerRecord
	Information we track for each peer. More...
struct	GNUNET_CORE_Handle
	Context for the core service connection. More...

Macros
#define	LOG(kind, ...)   GNUNET_log_from (kind, "core-api", __VA_ARGS__)

Functions
static void	reconnect (struct GNUNET_CORE_Handle *h)
	Our current client connection went down. More...
static void	reconnect_task (void *cls)
	Task schedule to try to re-connect to core. More...
static int	disconnect_and_free_peer_entry (void *cls, const struct GNUNET_PeerIdentity *key, void *value)
	Notify clients about disconnect and free the entry for connected peer. More...
static void	reconnect_later (struct GNUNET_CORE_Handle *h)
	Close down any existing connection to the CORE service and try re-establishing it later. More...
static void	handle_mq_error (void *cls, enum GNUNET_MQ_Error error)
	Error handler for the message queue to the CORE service. More...
static void	core_mq_send_impl (struct GNUNET_MQ_Handle *mq, const struct GNUNET_MessageHeader *msg, void *impl_state)
	Implement sending functionality of a message queue for us sending messages to a peer. More...
static void	core_mq_destroy_impl (struct GNUNET_MQ_Handle *mq, void *impl_state)
	Handle destruction of a message queue. More...
static void	core_mq_cancel_impl (struct GNUNET_MQ_Handle *mq, void *impl_state)
	Implementation function that cancels the currently sent message. More...
static void	core_mq_error_handler (void *cls, enum GNUNET_MQ_Error error)
	We had an error processing a message we forwarded from a peer to the CORE service. More...
static void	connect_peer (struct GNUNET_CORE_Handle *h, const struct GNUNET_PeerIdentity *peer)
	Add the given peer to the list of our connected peers and create the respective data structures and notify the application. More...
static void	handle_init_reply (void *cls, const struct InitReplyMessage *m)
	Handle init reply message received from CORE service. More...
static void	handle_connect_notify (void *cls, const struct ConnectNotifyMessage *cnm)
	Handle connect message received from CORE service. More...
static void	handle_disconnect_notify (void *cls, const struct DisconnectNotifyMessage *dnm)
	Handle disconnect message received from CORE service. More...
static int	check_notify_inbound (void *cls, const struct NotifyTrafficMessage *ntm)
	Check that message received from CORE service is well-formed. More...
static void	handle_notify_inbound (void *cls, const struct NotifyTrafficMessage *ntm)
	Handle inbound message received from CORE service. More...
static void	handle_send_ready (void *cls, const struct SendMessageReady *smr)
	Handle message received from CORE service notifying us that we are now allowed to send a message to a peer. More...
struct GNUNET_CORE_Handle *	GNUNET_CORE_connect (const struct GNUNET_CONFIGURATION_Handle *cfg, void *cls, GNUNET_CORE_StartupCallback init, GNUNET_CORE_ConnectEventHandler connects, GNUNET_CORE_DisconnectEventHandler disconnects, const struct GNUNET_MQ_MessageHandler *handlers)
	Connect to the core service. More...
void	GNUNET_CORE_disconnect (struct GNUNET_CORE_Handle *handle)
	Disconnect from the core service. More...
struct GNUNET_MQ_Handle *	GNUNET_CORE_get_mq (const struct GNUNET_CORE_Handle *h, const struct GNUNET_PeerIdentity *pid)
	Obtain the message queue for a connected peer. More...

Detailed Description

core service; this is the main API for encrypted P2P communications

Author

Christian Grothoff

Definition in file core_api.c.

Macro Definition Documentation

LOG

#define LOG	(		kind,
			...
	)		GNUNET_log_from (kind, "core-api", __VA_ARGS__)

Definition at line 32 of file core_api.c.

Function Documentation

reconnect()

static void reconnect ( struct GNUNET_CORE_Handle *  h )

static

Our current client connection went down.

Clean it up and try to reconnect!

Parameters

h	our handle to the core service

Definition at line 629 of file core_api.c.

{
  struct GNUNET_MQ_MessageHandler handlers[] =
  { GNUNET_MQ_hd_fixed_size (init_reply,
                             GNUNET_MESSAGE_TYPE_CORE_INIT_REPLY,
                             struct InitReplyMessage,
                             h),
    GNUNET_MQ_hd_fixed_size (connect_notify,
                             GNUNET_MESSAGE_TYPE_CORE_NOTIFY_CONNECT,
                             struct ConnectNotifyMessage,
                             h),
    GNUNET_MQ_hd_fixed_size (disconnect_notify,
                             GNUNET_MESSAGE_TYPE_CORE_NOTIFY_DISCONNECT,
                             struct DisconnectNotifyMessage,
                             h),
    GNUNET_MQ_hd_var_size (notify_inbound,
                           GNUNET_MESSAGE_TYPE_CORE_NOTIFY_INBOUND,
                           struct NotifyTrafficMessage,
                           h),
    GNUNET_MQ_hd_fixed_size (send_ready,
                             GNUNET_MESSAGE_TYPE_CORE_SEND_READY,
                             struct SendMessageReady,
                             h),
    GNUNET_MQ_handler_end () };
  struct InitMessage *init;
  struct GNUNET_MQ_Envelope *env;
  uint16_t *ts;
 
  GNUNET_assert (NULL == h->mq);
  h->mq = GNUNET_CLIENT_connect (h->cfg, "core", handlers, &handle_mq_error, h);
  if (NULL == h->mq)
  {
    reconnect_later (h);
    return;
  }
  env = GNUNET_MQ_msg_extra (init,
                             sizeof(uint16_t) * h->hcnt,
                             GNUNET_MESSAGE_TYPE_CORE_INIT);
  LOG (GNUNET_ERROR_TYPE_INFO, "(Re)connecting to CORE service\n");
  init->options = htonl (0);
  ts = (uint16_t *) &init[1];
  for (unsigned int hpos = 0; hpos < h->hcnt; hpos++)
    ts[hpos] = htons (h->handlers[hpos].type);
  GNUNET_MQ_send (h->mq, env);
}

References GNUNET_ARM_Handle::cfg, connect_notify(), disconnect_notify(), env, GNUNET_assert, GNUNET_CLIENT_connect(), GNUNET_ERROR_TYPE_INFO, GNUNET_MESSAGE_TYPE_CORE_INIT, GNUNET_MESSAGE_TYPE_CORE_INIT_REPLY, GNUNET_MESSAGE_TYPE_CORE_NOTIFY_CONNECT, GNUNET_MESSAGE_TYPE_CORE_NOTIFY_DISCONNECT, GNUNET_MESSAGE_TYPE_CORE_NOTIFY_INBOUND, GNUNET_MESSAGE_TYPE_CORE_SEND_READY, GNUNET_MQ_handler_end, GNUNET_MQ_hd_fixed_size, GNUNET_MQ_hd_var_size, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), h, handle_mq_error(), handlers, init, LOG, GNUNET_ARM_Handle::mq, and reconnect_later().

Referenced by GNUNET_CORE_connect(), and reconnect_task().

Here is the call graph for this function:

Here is the caller graph for this function:

reconnect_task()

static void reconnect_task ( void *  cls )

static

Task schedule to try to re-connect to core.

Parameters

cls	the struct GNUNET_CORE_Handle

Definition at line 163 of file core_api.c.

{
  struct GNUNET_CORE_Handle *h = cls;
 
  h->reconnect_task = NULL;
  LOG (GNUNET_ERROR_TYPE_DEBUG, "Connecting to CORE service after delay\n");
  reconnect (h);
}

References GNUNET_CORE_Handle::cls, GNUNET_ERROR_TYPE_DEBUG, h, LOG, reconnect(), and GNUNET_ARM_Handle::reconnect_task.

Referenced by reconnect_later().

Here is the call graph for this function:

Here is the caller graph for this function:

disconnect_and_free_peer_entry()

static int disconnect_and_free_peer_entry ( void *  cls, const struct GNUNET_PeerIdentity *  key, void *  value  )

static

Notify clients about disconnect and free the entry for connected peer.

Parameters

cls	the struct GNUNET_CORE_Handle *
key	the peer identity (not used)
value	the struct PeerRecord to free.

Returns

GNUNET_YES (continue)

Definition at line 183 of file core_api.c.

{
  struct GNUNET_CORE_Handle *h = cls;
  struct PeerRecord *pr = value;
 
  GNUNET_assert (pr->h == h);
  if (NULL != h->disconnects)
    h->disconnects (h->cls, &pr->peer, pr->client_cls);
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multipeermap_remove (h->peers, key, pr));
  GNUNET_MQ_destroy (pr->mq);
  GNUNET_assert (NULL == pr->mq);
  if (NULL != pr->env)
  {
    GNUNET_MQ_discard (pr->env);
    pr->env = NULL;
  }
  GNUNET_free (pr);
  return GNUNET_YES;
}

References PeerRecord::client_cls, GNUNET_CORE_Handle::cls, PeerRecord::env, GNUNET_assert, GNUNET_CONTAINER_multipeermap_remove(), GNUNET_free, GNUNET_MQ_destroy(), GNUNET_MQ_discard(), GNUNET_YES, h, PeerRecord::h, key, PeerRecord::mq, PeerRecord::peer, and value.

Referenced by GNUNET_CORE_disconnect(), handle_disconnect_notify(), and reconnect_later().

Here is the call graph for this function:

Here is the caller graph for this function:

reconnect_later()

static void reconnect_later ( struct GNUNET_CORE_Handle *  h )

static

Close down any existing connection to the CORE service and try re-establishing it later.

Parameters

h	our handle

Definition at line 214 of file core_api.c.

{
  GNUNET_assert (NULL == h->reconnect_task);
  if (NULL != h->mq)
  {
    GNUNET_MQ_destroy (h->mq);
    h->mq = NULL;
  }
  GNUNET_assert (NULL == h->reconnect_task);
  h->reconnect_task =
    GNUNET_SCHEDULER_add_delayed (h->retry_backoff, &reconnect_task, h);
  GNUNET_CONTAINER_multipeermap_iterate (h->peers,
                                         &disconnect_and_free_peer_entry,
                                         h);
  h->retry_backoff = GNUNET_TIME_STD_BACKOFF (h->retry_backoff);
}

References disconnect_and_free_peer_entry(), GNUNET_assert, GNUNET_CONTAINER_multipeermap_iterate(), GNUNET_MQ_destroy(), GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_STD_BACKOFF, h, GNUNET_ARM_Handle::mq, GNUNET_ARM_Handle::reconnect_task, reconnect_task(), and GNUNET_ARM_Handle::retry_backoff.

Referenced by handle_connect_notify(), handle_disconnect_notify(), handle_mq_error(), handle_notify_inbound(), handle_send_ready(), and reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_mq_error()

static void handle_mq_error ( void *  cls, enum GNUNET_MQ_Error  error  )

static

Error handler for the message queue to the CORE service.

On errors, we reconnect.

Parameters

cls	closure, a struct GNUNET_CORE_Handle *
error	error code

Definition at line 240 of file core_api.c.

{
  struct GNUNET_CORE_Handle *h = cls;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG, "MQ ERROR: %d\n", error);
  reconnect_later (h);
}

References GNUNET_CORE_Handle::cls, GNUNET_ERROR_TYPE_DEBUG, h, LOG, and reconnect_later().

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

core_mq_send_impl()

static void core_mq_send_impl ( struct GNUNET_MQ_Handle *  mq, const struct GNUNET_MessageHeader *  msg, void *  impl_state  )

static

Implement sending functionality of a message queue for us sending messages to a peer.

Parameters

mq	the message queue
msg	the message to send
impl_state	state of the implementation

Definition at line 258 of file core_api.c.

{
  struct PeerRecord *pr = impl_state;
  struct GNUNET_CORE_Handle *h = pr->h;
  struct SendMessageRequest *smr;
  struct SendMessage *sm;
  struct GNUNET_MQ_Envelope *env;
  uint16_t msize;
  enum GNUNET_MQ_PriorityPreferences flags;
 
  if (NULL == h->mq)
  {
    /* We're currently reconnecting, pretend this worked */
    GNUNET_MQ_impl_send_continue (mq);
    return;
  }
  GNUNET_assert (NULL == pr->env);
  /* extract options from envelope */
  env = GNUNET_MQ_get_current_envelope (mq);
  flags = GNUNET_MQ_env_get_options (env);
 
  /* check message size for sanity */
  msize = ntohs (msg->size);
  if (msize >= GNUNET_MAX_MESSAGE_SIZE - sizeof(struct SendMessage))
  {
    GNUNET_break (0);
    GNUNET_MQ_impl_send_continue (mq);
    return;
  }
 
  /* ask core for transmission */
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Asking core for transmission of %u bytes to `%s'\n",
       (unsigned int) msize,
       GNUNET_i2s (&pr->peer));
  env = GNUNET_MQ_msg (smr, GNUNET_MESSAGE_TYPE_CORE_SEND_REQUEST);
  smr->priority = htonl ((uint32_t) flags);
  smr->peer = pr->peer;
  smr->size = htons (msize);
  smr->smr_id = htons (++pr->smr_id_gen);
  GNUNET_MQ_send (h->mq, env);
 
  /* prepare message with actual transmission data */
  pr->env = GNUNET_MQ_msg_nested_mh (sm, GNUNET_MESSAGE_TYPE_CORE_SEND, msg);
  sm->priority = htonl ((uint32_t) flags);
  sm->peer = pr->peer;
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Calling get_message with buffer of %u bytes\n",
       (unsigned int) msize);
}

References env, PeerRecord::env, GNUNET_assert, GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_MAX_MESSAGE_SIZE, GNUNET_MESSAGE_TYPE_CORE_SEND, GNUNET_MESSAGE_TYPE_CORE_SEND_REQUEST, GNUNET_MQ_env_get_options(), GNUNET_MQ_get_current_envelope(), GNUNET_MQ_impl_send_continue(), GNUNET_MQ_msg, GNUNET_MQ_msg_nested_mh, GNUNET_MQ_send(), h, PeerRecord::h, LOG, mq, GNUNET_ARM_Handle::mq, msg, SendMessageRequest::peer, SendMessage::peer, PeerRecord::peer, SendMessageRequest::priority, SendMessage::priority, SendMessageRequest::size, GNUNET_MessageHeader::size, SendMessageRequest::smr_id, and PeerRecord::smr_id_gen.

Referenced by connect_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

core_mq_destroy_impl()

static void core_mq_destroy_impl ( struct GNUNET_MQ_Handle *  mq, void *  impl_state  )

static

Handle destruction of a message queue.

Implementations must not free mq, but should take care of impl_state.

Parameters

mq	the message queue to destroy
impl_state	state of the implementation

Definition at line 320 of file core_api.c.

{
  struct PeerRecord *pr = impl_state;
 
  GNUNET_assert (mq == pr->mq);
  pr->mq = NULL;
}

References GNUNET_assert, mq, and PeerRecord::mq.

Referenced by connect_peer().

Here is the caller graph for this function:

core_mq_cancel_impl()

static void core_mq_cancel_impl ( struct GNUNET_MQ_Handle *  mq, void *  impl_state  )

static

Implementation function that cancels the currently sent message.

Should basically undo whatever mq_send_impl() did.

Parameters

mq	message queue
impl_state	state specific to the implementation

Definition at line 337 of file core_api.c.

{
  struct PeerRecord *pr = impl_state;
 
  (void) mq;
  GNUNET_assert (NULL != pr->env);
  GNUNET_MQ_discard (pr->env);
  pr->env = NULL;
}

References PeerRecord::env, GNUNET_assert, GNUNET_MQ_discard(), and mq.

Referenced by connect_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

core_mq_error_handler()

static void core_mq_error_handler ( void *  cls, enum GNUNET_MQ_Error  error  )

static

We had an error processing a message we forwarded from a peer to the CORE service.

We should just complain about it but otherwise continue processing.

Parameters

cls	closure
error	error code

Definition at line 357 of file core_api.c.

{
  /* struct PeerRecord *pr = cls; */
  (void) cls;
  (void) error;
  GNUNET_break_op (0);
}

References GNUNET_break_op.

Referenced by connect_peer().

Here is the caller graph for this function:

connect_peer()

static void connect_peer ( struct GNUNET_CORE_Handle *  h, const struct GNUNET_PeerIdentity *  peer  )

static

Add the given peer to the list of our connected peers and create the respective data structures and notify the application.

Parameters

h	the core handle
peer	the peer that is connecting to us

Definition at line 375 of file core_api.c.

{
  struct PeerRecord *pr;
 
  pr = GNUNET_new (struct PeerRecord);
  pr->peer = *peer;
  pr->h = h;
  GNUNET_assert (GNUNET_YES ==
                 GNUNET_CONTAINER_multipeermap_put (
                   h->peers,
                   &pr->peer,
                   pr,
                   GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
  pr->mq = GNUNET_MQ_queue_for_callbacks (&core_mq_send_impl,
                                          &core_mq_destroy_impl,
                                          &core_mq_cancel_impl,
                                          pr,
                                          h->handlers,
                                          &core_mq_error_handler,
                                          pr);
  if (NULL != h->connects)
  {
    pr->client_cls = h->connects (h->cls, &pr->peer, pr->mq);
    GNUNET_MQ_set_handlers_closure (pr->mq, pr->client_cls);
  }
}

References PeerRecord::client_cls, core_mq_cancel_impl(), core_mq_destroy_impl(), core_mq_error_handler(), core_mq_send_impl(), GNUNET_assert, GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY, GNUNET_CONTAINER_multipeermap_put(), GNUNET_MQ_queue_for_callbacks(), GNUNET_MQ_set_handlers_closure(), GNUNET_new, GNUNET_YES, h, PeerRecord::h, PeerRecord::mq, PeerRecord::peer, and peer.

Referenced by handle_connect_notify(), and handle_init_reply().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_init_reply()

static void handle_init_reply ( void *  cls, const struct InitReplyMessage *  m  )

static

Handle init reply message received from CORE service.

Notify application that we are now connected to the CORE. Also fake loopback connection.

Parameters

cls	the struct GNUNET_CORE_Handle
m	the init reply

Definition at line 413 of file core_api.c.

{
  struct GNUNET_CORE_Handle *h = cls;
  GNUNET_CORE_StartupCallback init;
 
  GNUNET_break (0 == ntohl (m->reserved));
  h->retry_backoff = GNUNET_TIME_UNIT_MILLISECONDS;
  if (NULL != (init = h->init))
  {
    /* mark so we don't call init on reconnect */
    h->init = NULL;
    h->me = m->my_identity;
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "Connected to core service of peer `%s'.\n",
         GNUNET_i2s (&h->me));
    h->have_init = GNUNET_YES;
    init (h->cls, &h->me);
  }
  else
  {
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "Successfully reconnected to core service.\n");
    if (GNUNET_NO == h->have_init)
    {
      h->me = m->my_identity;
      h->have_init = GNUNET_YES;
    }
    else
    {
      GNUNET_break (0 == memcmp (&h->me,
                                 &m->my_identity,
                                 sizeof(struct GNUNET_PeerIdentity)));
    }
  }
  /* fake 'connect to self' */
  connect_peer (h, &h->me);
}

References GNUNET_CORE_Handle::cls, connect_peer(), GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_NO, GNUNET_TIME_UNIT_MILLISECONDS, GNUNET_YES, h, init, LOG, m, and GNUNET_ARM_Handle::retry_backoff.

Here is the call graph for this function:

handle_connect_notify()

static void handle_connect_notify ( void *  cls, const struct ConnectNotifyMessage *  cnm  )

static

Handle connect message received from CORE service.

Notify the application about the new connection.

Parameters

cls	the struct GNUNET_CORE_Handle
cnm	the connect message

Definition at line 460 of file core_api.c.

{
  struct GNUNET_CORE_Handle *h = cls;
  struct PeerRecord *pr;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Received notification about connection from `%s'.\n",
       GNUNET_i2s (&cnm->peer));
  if (0 == memcmp (&h->me, &cnm->peer, sizeof(struct GNUNET_PeerIdentity)))
  {
    /* connect to self!? */
    GNUNET_break (0);
    return;
  }
  pr = GNUNET_CONTAINER_multipeermap_get (h->peers, &cnm->peer);
  if (NULL != pr)
  {
    GNUNET_break (0);
    reconnect_later (h);
    return;
  }
  connect_peer (h, &cnm->peer);
}

References GNUNET_CORE_Handle::cls, connect_peer(), GNUNET_break, GNUNET_CONTAINER_multipeermap_get(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), h, LOG, ConnectNotifyMessage::peer, and reconnect_later().

Here is the call graph for this function:

handle_disconnect_notify()

static void handle_disconnect_notify ( void *  cls, const struct DisconnectNotifyMessage *  dnm  )

static

Handle disconnect message received from CORE service.

Notify the application about the lost connection.

Parameters

cls	the struct GNUNET_CORE_Handle
dnm	message about the disconnect event

Definition at line 493 of file core_api.c.

{
  struct GNUNET_CORE_Handle *h = cls;
  struct PeerRecord *pr;
 
  if (0 == memcmp (&h->me, &dnm->peer, sizeof(struct GNUNET_PeerIdentity)))
  {
    /* disconnect from self!? */
    GNUNET_break (0);
    return;
  }
  GNUNET_break (0 == ntohl (dnm->reserved));
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Received notification about disconnect from `%s'.\n",
       GNUNET_i2s (&dnm->peer));
  pr = GNUNET_CONTAINER_multipeermap_get (h->peers, &dnm->peer);
  if (NULL == pr)
  {
    GNUNET_break (0);
    reconnect_later (h);
    return;
  }
  disconnect_and_free_peer_entry (h, &pr->peer, pr);
}

References GNUNET_CORE_Handle::cls, disconnect_and_free_peer_entry(), GNUNET_break, GNUNET_CONTAINER_multipeermap_get(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), h, LOG, DisconnectNotifyMessage::peer, PeerRecord::peer, reconnect_later(), and DisconnectNotifyMessage::reserved.

Here is the call graph for this function:

check_notify_inbound()

static int check_notify_inbound ( void *  cls, const struct NotifyTrafficMessage *  ntm  )

static

Check that message received from CORE service is well-formed.

Parameters

cls	the struct GNUNET_CORE_Handle
ntm	the message we got

Returns

GNUNET_OK if the message is well-formed

Definition at line 527 of file core_api.c.

{
  uint16_t msize;
  const struct GNUNET_MessageHeader *em;
 
  (void) cls;
  msize = ntohs (ntm->header.size) - sizeof(struct NotifyTrafficMessage);
  if (msize < sizeof(struct GNUNET_MessageHeader))
  {
    GNUNET_break (0);
    return GNUNET_SYSERR;
  }
  em = (const struct GNUNET_MessageHeader *) &ntm[1];
  if (msize != ntohs (em->size))
  {
    GNUNET_break (0);
    return GNUNET_SYSERR;
  }
  return GNUNET_OK;
}

References GNUNET_break, GNUNET_OK, GNUNET_SYSERR, NotifyTrafficMessage::header, and GNUNET_MessageHeader::size.

handle_notify_inbound()

static void handle_notify_inbound ( void *  cls, const struct NotifyTrafficMessage *  ntm  )

static

Handle inbound message received from CORE service.

If applicable, notify the application.

Parameters

cls	the struct GNUNET_CORE_Handle
ntm	the message we got from CORE.

Definition at line 557 of file core_api.c.

{
  struct GNUNET_CORE_Handle *h = cls;
  const struct GNUNET_MessageHeader *em;
  struct PeerRecord *pr;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Received inbound message from `%s'.\n",
       GNUNET_i2s (&ntm->peer));
  em = (const struct GNUNET_MessageHeader *) &ntm[1];
  pr = GNUNET_CONTAINER_multipeermap_get (h->peers, &ntm->peer);
  if (NULL == pr)
  {
    GNUNET_break (0);
    reconnect_later (h);
    return;
  }
  GNUNET_MQ_inject_message (pr->mq, em);
}

References GNUNET_CORE_Handle::cls, GNUNET_break, GNUNET_CONTAINER_multipeermap_get(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_MQ_inject_message(), h, LOG, PeerRecord::mq, NotifyTrafficMessage::peer, and reconnect_later().

Here is the call graph for this function:

handle_send_ready()

static void handle_send_ready ( void *  cls, const struct SendMessageReady *  smr  )

static

Handle message received from CORE service notifying us that we are now allowed to send a message to a peer.

If that message is still pending, put it into the queue to be transmitted.

Parameters

cls	the struct GNUNET_CORE_Handle
smr	the message we got

Definition at line 587 of file core_api.c.

{
  struct GNUNET_CORE_Handle *h = cls;
  struct PeerRecord *pr;
 
  pr = GNUNET_CONTAINER_multipeermap_get (h->peers, &smr->peer);
  if (NULL == pr)
  {
    GNUNET_break (0);
    reconnect_later (h);
    return;
  }
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Received notification about transmission readiness to `%s'.\n",
       GNUNET_i2s (&smr->peer));
  if (NULL == pr->env)
  {
    /* request must have been cancelled between the original request
     * and the response from CORE, ignore CORE's readiness */
    return;
  }
  if (ntohs (smr->smr_id) != pr->smr_id_gen)
  {
    /* READY message is for expired or cancelled message,
     * ignore! (we should have already sent another request) */
    return;
  }
 
  /* ok, all good, send message out! */
  GNUNET_MQ_send (h->mq, pr->env);
  pr->env = NULL;
  GNUNET_MQ_impl_send_continue (pr->mq);
}

References GNUNET_CORE_Handle::cls, PeerRecord::env, GNUNET_break, GNUNET_CONTAINER_multipeermap_get(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_i2s(), GNUNET_MQ_impl_send_continue(), GNUNET_MQ_send(), h, LOG, GNUNET_ARM_Handle::mq, PeerRecord::mq, SendMessageReady::peer, reconnect_later(), SendMessageReady::smr_id, and PeerRecord::smr_id_gen.

Here is the call graph for this function: