transport_api_blacklist.c File Reference

library to access the blacklisting functions of the transport service More...

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_arm_service.h"
#include "gnunet_hello_lib.h"
#include "gnunet_protocols.h"
#include "gnunet_transport_service.h"
#include "transport.h"

Include dependency graph for transport_api_blacklist.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_TRANSPORT_Blacklist
	Handle for blacklisting requests. More...

Functions
static void	reconnect (struct GNUNET_TRANSPORT_Blacklist *br)
	Establish blacklist connection to transport service. More...
static void	handle_query (void *cls, const struct BlacklistMessage *bm)
	Handle blacklist queries. 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...
struct GNUNET_TRANSPORT_Blacklist *	GNUNET_TRANSPORT_blacklist (const struct GNUNET_CONFIGURATION_Handle *cfg, GNUNET_TRANSPORT_BlacklistCallback cb, void *cb_cls)
	Install a blacklist callback. More...
void	GNUNET_TRANSPORT_blacklist_cancel (struct GNUNET_TRANSPORT_Blacklist *br)
	Abort the blacklist. More...

Detailed Description

library to access the blacklisting functions of the transport service

Author

Christian Grothoff

Definition in file transport_api_blacklist.c.

Function Documentation

reconnect()

static void reconnect ( struct GNUNET_TRANSPORT_Blacklist *  br )

static

Establish blacklist connection to transport service.

Parameters

br	overall handle

Definition at line 120 of file transport_api_blacklist.c.

{
  struct GNUNET_MQ_MessageHandler handlers[] = {
    GNUNET_MQ_hd_fixed_size (query,
                             GNUNET_MESSAGE_TYPE_TRANSPORT_BLACKLIST_QUERY,
                             struct BlacklistMessage,
                             br),
    GNUNET_MQ_handler_end ()
  };
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_MessageHeader *req;
 
  if (NULL != br->mq)
    GNUNET_MQ_destroy (br->mq);
  br->mq = GNUNET_CLIENT_connect (br->cfg,
                                  "transport",
                                  handlers,
                                  &mq_error_handler,
                                  br);
  if (NULL == br->mq)
    return;
  env = GNUNET_MQ_msg (req,
                       GNUNET_MESSAGE_TYPE_TRANSPORT_BLACKLIST_INIT);
  GNUNET_MQ_send (br->mq,
                  env);
}

References GNUNET_TRANSPORT_Blacklist::cfg, env, GNUNET_CLIENT_connect(), GNUNET_MESSAGE_TYPE_TRANSPORT_BLACKLIST_INIT, GNUNET_MESSAGE_TYPE_TRANSPORT_BLACKLIST_QUERY, GNUNET_MQ_destroy(), GNUNET_MQ_handler_end, GNUNET_MQ_hd_fixed_size, GNUNET_MQ_msg, GNUNET_MQ_send(), handlers, GNUNET_TRANSPORT_Blacklist::mq, and mq_error_handler().

Referenced by GNUNET_TRANSPORT_blacklist(), and mq_error_handler().

Here is the call graph for this function:

Here is the caller graph for this function:

handle_query()

static void handle_query ( void *  cls, const struct BlacklistMessage *  bm  )

static

Handle blacklist queries.

Parameters

cls	our overall handle
bm	query

Definition at line 78 of file transport_api_blacklist.c.

{
  struct GNUNET_TRANSPORT_Blacklist *br = cls;
  struct GNUNET_MQ_Envelope *env;
  struct BlacklistMessage *res;
 
  GNUNET_break (0 == ntohl (bm->is_allowed));
  env = GNUNET_MQ_msg (res,
                       GNUNET_MESSAGE_TYPE_TRANSPORT_BLACKLIST_REPLY);
  res->is_allowed = htonl (br->cb (br->cb_cls,
                                   &bm->peer));
  res->peer = bm->peer;
  GNUNET_MQ_send (br->mq,
                  env);
}

References GNUNET_TRANSPORT_Blacklist::cb, GNUNET_TRANSPORT_Blacklist::cb_cls, env, GNUNET_break, GNUNET_MESSAGE_TYPE_TRANSPORT_BLACKLIST_REPLY, GNUNET_MQ_msg, GNUNET_MQ_send(), BlacklistMessage::is_allowed, GNUNET_TRANSPORT_Blacklist::mq, BlacklistMessage::peer, and res.

Here is the call 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_Blacklist *
error	error code

Definition at line 105 of file transport_api_blacklist.c.

{
  struct GNUNET_TRANSPORT_Blacklist *br = cls;
 
  reconnect (br);
}

References reconnect().

Referenced by reconnect().

Here is the call graph for this function:

Here is the caller graph for this function: