regex_api_announce.c File Reference

access regex service to advertise capabilities via regex More...

#include "platform.h"
#include "gnunet_protocols.h"
#include "gnunet_util_lib.h"
#include "gnunet_regex_service.h"
#include "regex_ipc.h"

Include dependency graph for regex_api_announce.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_REGEX_Announcement
	Handle to store cached data about a regex announce. More...

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

Functions
static void	announce_reconnect (struct GNUNET_REGEX_Announcement *a)
	(Re)connect to the REGEX service with the given announcement a. More...
static void	announce_mq_error_handler (void *cls, enum GNUNET_MQ_Error error)
	We got a disconnect after asking regex to do the announcement. More...
struct GNUNET_REGEX_Announcement *	GNUNET_REGEX_announce (const struct GNUNET_CONFIGURATION_Handle *cfg, const char *regex, struct GNUNET_TIME_Relative refresh_delay, uint16_t compression)
	Announce the given peer under the given regular expression. More...
void	GNUNET_REGEX_announce_cancel (struct GNUNET_REGEX_Announcement *a)
	Stop announcing the regex specified by the given handle. More...

Detailed Description

access regex service to advertise capabilities via regex

Author

Maximilian Szengel

Christian Grothoff

Definition in file regex_api_announce.c.

Macro Definition Documentation

LOG

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

Definition at line 32 of file regex_api_announce.c.

Function Documentation

announce_reconnect()

static void announce_reconnect ( struct GNUNET_REGEX_Announcement *  a )

static

(Re)connect to the REGEX service with the given announcement a.

Parameters

a	REGEX to announce.

Definition at line 100 of file regex_api_announce.c.

{
  struct GNUNET_MQ_Envelope *env;
  struct AnnounceMessage *am;
  size_t slen;
 
  a->mq = GNUNET_CLIENT_connect (a->cfg,
                                 "regex",
                                 NULL,
                                 &announce_mq_error_handler,
                                 a);
  if (NULL == a->mq)
    return;
  slen = strlen (a->regex) + 1;
  env = GNUNET_MQ_msg_extra (am,
                             slen,
                             GNUNET_MESSAGE_TYPE_REGEX_ANNOUNCE);
  am->compression = htons (a->compression);
  am->reserved = htons (0);
  am->refresh_delay = GNUNET_TIME_relative_hton (a->refresh_delay);
  GNUNET_memcpy (&am[1],
                 a->regex,
                 slen);
  GNUNET_MQ_send (a->mq,
                  env);
}

References announce_mq_error_handler(), GNUNET_REGEX_Announcement::cfg, GNUNET_REGEX_Announcement::compression, AnnounceMessage::compression, env, GNUNET_CLIENT_connect(), GNUNET_memcpy, GNUNET_MESSAGE_TYPE_REGEX_ANNOUNCE, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_TIME_relative_hton(), GNUNET_REGEX_Announcement::mq, GNUNET_REGEX_Announcement::refresh_delay, AnnounceMessage::refresh_delay, GNUNET_REGEX_Announcement::regex, and AnnounceMessage::reserved.

Referenced by announce_mq_error_handler(), and GNUNET_REGEX_announce().

Here is the call graph for this function:

Here is the caller graph for this function:

announce_mq_error_handler()

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

static

We got a disconnect after asking regex to do the announcement.

Retry.

Parameters

cls	the struct GNUNET_REGEX_Announcement to retry
error	error code

Definition at line 83 of file regex_api_announce.c.

{
  struct GNUNET_REGEX_Announcement *a = cls;
 
  GNUNET_MQ_destroy (a->mq);
  a->mq = NULL;
  announce_reconnect (a);
}

References announce_reconnect(), GNUNET_MQ_destroy(), and GNUNET_REGEX_Announcement::mq.

Referenced by announce_reconnect().

Here is the call graph for this function:

Here is the caller graph for this function: