gns_api.c File Reference

library to access the GNS service More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_constants.h"
#include "gnunet_arm_service.h"
#include "gnunet_protocols.h"
#include "gnunet_dht_service.h"
#include "gns.h"
#include "gns_api.h"

Include dependency graph for gns_api.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_GNS_LookupRequest
	Handle to a lookup request. More...

Macros
#define	LOG(kind, ...)   GNUNET_log_from (kind, "gns-api", __VA_ARGS__)
#define	DEFAULT_LIMIT   128
	Default recursion depth limit to apply if the application does not specify any.

Functions
static void	reconnect (struct GNUNET_GNS_Handle *handle)
	Reconnect to GNS service.
static void	reconnect_task (void *cls)
	Reconnect to GNS.
static void	force_reconnect (struct GNUNET_GNS_Handle *handle)
	Disconnect from service and then reconnect.
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.
static int	check_result (void *cls, const struct LookupResultMessage *lookup_msg)
	Check validity of message received from the GNS service.
static void	handle_result (void *cls, const struct LookupResultMessage *lookup_msg)
	Handler for messages received from the GNS service.
struct GNUNET_GNS_Handle *	GNUNET_GNS_connect (const struct GNUNET_CONFIGURATION_Handle *cfg)
	Initialize the connection with the GNS service.
void	GNUNET_GNS_disconnect (struct GNUNET_GNS_Handle *handle)
	Shutdown connection with the GNS service.
void *	GNUNET_GNS_lookup_cancel (struct GNUNET_GNS_LookupRequest *lr)
	Cancel pending lookup request.
struct GNUNET_GNS_LookupRequest *	GNUNET_GNS_lookup_limited (struct GNUNET_GNS_Handle *handle, const char *name, const struct GNUNET_CRYPTO_BlindablePublicKey *zone, uint32_t type, enum GNUNET_GNS_LocalOptions options, uint16_t recursion_depth_limit, GNUNET_GNS_LookupResultProcessor proc, void *proc_cls)
	Perform an asynchronous lookup operation on the GNS.
struct GNUNET_GNS_LookupRequest *	GNUNET_GNS_lookup (struct GNUNET_GNS_Handle *handle, const char *name, const struct GNUNET_CRYPTO_BlindablePublicKey *zone, uint32_t type, enum GNUNET_GNS_LocalOptions options, GNUNET_GNS_LookupResultProcessor proc, void *proc_cls)
	Perform an asynchronous lookup operation on the GNS.

Detailed Description

library to access the GNS service

Author

Martin Schanzenbach

Christian Grothoff

Definition in file gns_api.c.

Macro Definition Documentation

LOG

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

Definition at line 36 of file gns_api.c.

DEFAULT_LIMIT

#define DEFAULT_LIMIT   128

Default recursion depth limit to apply if the application does not specify any.

Definition at line 42 of file gns_api.c.

Function Documentation

reconnect()

static void reconnect ( struct GNUNET_GNS_Handle *  handle )

static

Reconnect to GNS service.

Parameters

handle

the handle to the GNS service

Definition at line 232 of file gns_api.c.

{
  struct GNUNET_MQ_MessageHandler handlers[] = {
    GNUNET_MQ_hd_var_size (result,
                           GNUNET_MESSAGE_TYPE_GNS_LOOKUP_RESULT,
                           struct LookupResultMessage,
                           handle),
    GNUNET_MQ_handler_end ()
  };
 
  GNUNET_assert (NULL == handle->mq);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Trying to connect to GNS\n");
  handle->mq = GNUNET_CLIENT_connect (handle->cfg,
                                      "gns",
                                      handlers,
                                      &mq_error_handler,
                                      handle);
  if (NULL == handle->mq)
    return;
  for (struct GNUNET_GNS_LookupRequest *lh = handle->lookup_head;
       NULL != lh;
       lh = lh->next)
    GNUNET_MQ_send_copy (handle->mq,
                         lh->env);
}

References GNUNET_VPN_Handle::cfg, GNUNET_assert, GNUNET_CLIENT_connect(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_MESSAGE_TYPE_GNS_LOOKUP_RESULT, GNUNET_MQ_handler_end, GNUNET_MQ_hd_var_size, GNUNET_MQ_send_copy(), handle, handlers, LOG, GNUNET_VPN_Handle::mq, mq_error_handler(), and result.

Here is the call graph for this function:

reconnect_task()

static void reconnect_task ( void *  cls )

static

Reconnect to GNS.

Parameters

cls	the handle

Definition at line 101 of file gns_api.c.

{
  struct GNUNET_GNS_Handle *handle = cls;
 
  handle->reconnect_task = NULL;
  reconnect (handle);
}

References handle, and reconnect().

Referenced by force_reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

force_reconnect()

static void force_reconnect ( struct GNUNET_GNS_Handle *  handle )

static

Disconnect from service and then reconnect.

Parameters

handle

our handle

Definition at line 116 of file gns_api.c.

{
  GNUNET_MQ_destroy (handle->mq);
  handle->mq = NULL;
  handle->reconnect_backoff
    = GNUNET_TIME_STD_BACKOFF (handle->reconnect_backoff);
  handle->reconnect_task
    = GNUNET_SCHEDULER_add_delayed (handle->reconnect_backoff,
                                    &reconnect_task,
                                    handle);
}

References GNUNET_MQ_destroy(), GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_STD_BACKOFF, handle, GNUNET_VPN_Handle::mq, and 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_GNS_Handle *
error	error code

Definition at line 138 of file gns_api.c.

{
  struct GNUNET_GNS_Handle *handle = cls;
 
  LOG (GNUNET_ERROR_TYPE_WARNING,
       "Problem with message queue. error: %i\n",
       error);
  force_reconnect (handle);
}

References force_reconnect(), GNUNET_ERROR_TYPE_WARNING, handle, and LOG.

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

check_result()

static int check_result ( void *  cls, const struct LookupResultMessage *  lookup_msg  )

static

Check validity of message received from the GNS service.

Parameters

cls	the struct GNUNET_GNS_Handle *
loookup_msg	the incoming message

Definition at line 157 of file gns_api.c.

{
  size_t mlen = ntohs (lookup_msg->header.size) - sizeof(*lookup_msg);
  uint32_t rd_count = ntohl (lookup_msg->rd_count);
  struct GNUNET_GNSRECORD_Data rd[rd_count];
 
  (void) cls;
  if (GNUNET_SYSERR ==
      GNUNET_GNSRECORD_records_deserialize (mlen,
                                            (const char *) &lookup_msg[1],
                                            rd_count,
                                            rd))
  {
    GNUNET_break (0);
    return GNUNET_SYSERR;
  }
  return GNUNET_OK;
}

References GNUNET_break, GNUNET_GNSRECORD_records_deserialize(), GNUNET_OK, GNUNET_SYSERR, LookupResultMessage::header, rd, rd_count, LookupResultMessage::rd_count, and GNUNET_MessageHeader::size.

Here is the call graph for this function:

handle_result()

static void handle_result ( void *  cls, const struct LookupResultMessage *  lookup_msg  )

static

Handler for messages received from the GNS service.

Parameters

cls	the struct GNUNET_GNS_Handle *
loookup_msg	the incoming message

Definition at line 185 of file gns_api.c.

{
  struct GNUNET_GNS_Handle *handle = cls;
  size_t mlen = ntohs (lookup_msg->header.size) - sizeof(*lookup_msg);
  uint32_t rd_count = ntohl (lookup_msg->rd_count);
  struct GNUNET_GNSRECORD_Data rd[rd_count];
  uint32_t r_id = ntohl (lookup_msg->id);
  struct GNUNET_GNS_LookupRequest *lr;
  GNUNET_GNS_LookupResultProcessor proc;
  void *proc_cls;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Received lookup reply from GNS service (%u records)\n",
       (unsigned int) rd_count);
  for (lr = handle->lookup_head; NULL != lr; lr = lr->next)
    if (lr->r_id == r_id)
      break;
  if (NULL == lr)
    return;
  proc = lr->lookup_proc;
  proc_cls = lr->proc_cls;
 
  GNUNET_assert (GNUNET_OK ==
                 GNUNET_GNSRECORD_records_deserialize (mlen,
                                                       (const
                                                        char *) &lookup_msg[1],
                                                       rd_count,
                                                       rd));
  proc (proc_cls,
        rd_count,
        rd);
  GNUNET_CONTAINER_DLL_remove (handle->lookup_head,
                               handle->lookup_tail,
                               lr);
  if (NULL != lr->env)
    GNUNET_MQ_discard (lr->env);
  GNUNET_free (lr);
}

References GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_GNSRECORD_records_deserialize(), GNUNET_MQ_discard(), GNUNET_OK, handle, LookupResultMessage::header, LookupResultMessage::id, LOG, GNUNET_GNS_LookupWithTldRequest::lookup_proc, lr, GNUNET_GNS_LookupRequest::proc_cls, GNUNET_GNS_LookupRequest::r_id, rd, rd_count, LookupResultMessage::rd_count, and GNUNET_MessageHeader::size.

Here is the call graph for this function: