transport_api_hello_get.c File Reference

library to obtain our HELLO from our transport service More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_constants.h"
#include "gnunet_arm_service.h"
#include "gnunet_hello_lib.h"
#include "gnunet_protocols.h"
#include "gnunet_transport_hello_service.h"
#include "transport.h"

Include dependency graph for transport_api_hello_get.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_TRANSPORT_HelloGetHandle
	Functions to call with this peer's HELLO. More...

Functions
static int	check_hello (void *cls, const struct GNUNET_MessageHeader *msg)
	Function we use for checking incoming HELLO messages. More...
static void	handle_hello (void *cls, const struct GNUNET_MessageHeader *msg)
	Function we use for handling incoming HELLO messages. More...
static void	schedule_reconnect (struct GNUNET_TRANSPORT_HelloGetHandle *ghh)
	Function that will schedule the job that will try to connect us again to the client. More...
static void	mq_error_handler (void *cls, enum GNUNET_MQ_Error error)
	Generic error handler, called with the appropriate error code and the same closure specified at the creation of the message queue. More...
static void	reconnect (void *cls)
	Try again to connect to transport service. More...
struct GNUNET_TRANSPORT_HelloGetHandle *	GNUNET_TRANSPORT_hello_get (const struct GNUNET_CONFIGURATION_Handle *cfg, enum GNUNET_TRANSPORT_AddressClass ac, GNUNET_TRANSPORT_HelloUpdateCallback rec, void *rec_cls)
	Obtain the HELLO message for this peer. More...
void	GNUNET_TRANSPORT_hello_get_cancel (struct GNUNET_TRANSPORT_HelloGetHandle *ghh)
	Stop receiving updates about changes to our HELLO message. More...

Detailed Description

library to obtain our HELLO from our transport service

Author

Christian Grothoff

Definition in file transport_api_hello_get.c.

Function Documentation

check_hello()

static int check_hello ( void *  cls, const struct GNUNET_MessageHeader *  msg  )

static

Function we use for checking incoming HELLO messages.

Parameters

cls	closure, a struct GNUNET_TRANSPORT_Handle *
msg	message received

Returns

GNUNET_OK if message is well-formed

Definition at line 91 of file transport_api_hello_get.c.

{
  struct GNUNET_PeerIdentity me;
 
  if (GNUNET_OK !=
      GNUNET_HELLO_get_id ((const struct GNUNET_HELLO_Message *) msg,
                           &me))
  {
    GNUNET_break (0);
    return GNUNET_SYSERR;
  }
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Receiving (my own) HELLO message (%u bytes), I am `%s'.\n",
              (unsigned int) ntohs (msg->size),
              GNUNET_i2s (&me));
  return GNUNET_OK;
}

References GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_HELLO_get_id(), GNUNET_i2s(), GNUNET_log, GNUNET_OK, GNUNET_SYSERR, me, msg, and GNUNET_MessageHeader::size.

Here is the call graph for this function:

handle_hello()

static void handle_hello ( void *  cls, const struct GNUNET_MessageHeader *  msg  )

static

Function we use for handling incoming HELLO messages.

Parameters

cls	closure, a struct GNUNET_TRANSPORT_HelloGetHandle *
msg	message received

Definition at line 118 of file transport_api_hello_get.c.

{
  struct GNUNET_TRANSPORT_HelloGetHandle *ghh = cls;
 
  ghh->rec (ghh->rec_cls,
            msg);
}

References msg, GNUNET_TRANSPORT_HelloGetHandle::rec, and GNUNET_TRANSPORT_HelloGetHandle::rec_cls.

schedule_reconnect()

static void schedule_reconnect ( struct GNUNET_TRANSPORT_HelloGetHandle *  ghh )

static

Function that will schedule the job that will try to connect us again to the client.

Parameters

ghh	transport service to reconnect

Definition at line 206 of file transport_api_hello_get.c.

{
  ghh->reconnect_task =
    GNUNET_SCHEDULER_add_delayed (ghh->reconnect_delay,
                                  &reconnect,
                                  ghh);
  ghh->reconnect_delay = GNUNET_TIME_STD_BACKOFF (ghh->reconnect_delay);
}

References GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_STD_BACKOFF, reconnect(), GNUNET_TRANSPORT_HelloGetHandle::reconnect_delay, and GNUNET_TRANSPORT_HelloGetHandle::reconnect_task.

Referenced by mq_error_handler().

Here is the call graph for this function:

Here is the caller graph for this function:

mq_error_handler()

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

static

Generic error handler, called with the appropriate error code and the same closure specified at the creation of the message queue.

Not every message queue implementation supports an error handler.

Parameters

cls	closure with the struct GNUNET_TRANSPORT_Handle *
error	error code

Definition at line 148 of file transport_api_hello_get.c.

{
  struct GNUNET_TRANSPORT_HelloGetHandle *ghh = cls;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Error receiving from transport service, disconnecting temporarily.\n");
  GNUNET_MQ_destroy (ghh->mq);
  ghh->mq = NULL;
  schedule_reconnect (ghh);
}

References GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_MQ_destroy(), GNUNET_TRANSPORT_HelloGetHandle::mq, and schedule_reconnect().

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

reconnect()

static void reconnect ( void *  cls )

static

Try again to connect to transport service.

Parameters

cls	the handle to the transport service

Definition at line 167 of file transport_api_hello_get.c.

{
  struct GNUNET_TRANSPORT_HelloGetHandle *ghh = cls;
  struct GNUNET_MQ_MessageHandler handlers[] = {
    GNUNET_MQ_hd_var_size (hello,
                           GNUNET_MESSAGE_TYPE_HELLO,
                           struct GNUNET_MessageHeader,
                           ghh),
    GNUNET_MQ_handler_end ()
  };
  struct GNUNET_MQ_Envelope *env;
  struct StartMessage *s;
 
  ghh->reconnect_task = NULL;
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Connecting to transport service.\n");
  GNUNET_assert (NULL == ghh->mq);
  ghh->mq = GNUNET_CLIENT_connect (ghh->cfg,
                                   "transport",
                                   handlers,
                                   &mq_error_handler,
                                   ghh);
  if (NULL == ghh->mq)
    return;
  env = GNUNET_MQ_msg (s,
                       GNUNET_MESSAGE_TYPE_TRANSPORT_START);
  s->options = htonl (0);
  GNUNET_MQ_send (ghh->mq,
                  env);
}

References GNUNET_TRANSPORT_HelloGetHandle::cfg, env, GNUNET_assert, GNUNET_CLIENT_connect(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_MESSAGE_TYPE_HELLO, GNUNET_MESSAGE_TYPE_TRANSPORT_START, GNUNET_MQ_handler_end, GNUNET_MQ_hd_var_size, GNUNET_MQ_msg, GNUNET_MQ_send(), handlers, GNUNET_TRANSPORT_HelloGetHandle::mq, mq_error_handler(), StartMessage::options, and GNUNET_TRANSPORT_HelloGetHandle::reconnect_task.

Referenced by GNUNET_TRANSPORT_hello_get(), and schedule_reconnect().

Here is the call graph for this function:

Here is the caller graph for this function: