gnunet-service-testbed-logger.c File Reference

service for collecting messages and writing to a file More...

#include "platform.h"
#include "gnunet_util_lib.h"

Include dependency graph for gnunet-service-testbed-logger.c:

Go to the source code of this file.

Macros
#define	LOG(type, ...)    GNUNET_log (type, __VA_ARGS__)
	Generic logging shorthand. More...
#define	LOG_DEBUG(...)    LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__)
	Debug logging shorthand. More...

Functions
static int	check_log_msg (void *cls, const struct GNUNET_MessageHeader *msg)
	Check GNUNET_MESSAGE_TYPE_TESTBED_LOGGER_MSG messages. More...
static void	handle_log_msg (void *cls, const struct GNUNET_MessageHeader *msg)
	Message handler for GNUNET_MESSAGE_TYPE_TESTBED_LOGGER_MSG messages. More...
static void	shutdown_task (void *cls)
	Task to clean up and shutdown nicely. More...
static void *	client_connect_cb (void *cls, struct GNUNET_SERVICE_Client *c, struct GNUNET_MQ_Handle *mq)
	Callback called when a client connects to the service. More...
static void	client_disconnect_cb (void *cls, struct GNUNET_SERVICE_Client *c, void *internal_cls)
	Callback called when a client disconnected from the service. More...
static void	logger_run (void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg, struct GNUNET_SERVICE_Handle *service)
	Testbed setup. More...
	GNUNET_SERVICE_MAIN ("testbed-logger", GNUNET_SERVICE_OPTION_NONE, &logger_run, &client_connect_cb, &client_disconnect_cb, NULL, GNUNET_MQ_hd_var_size(log_msg, GNUNET_MESSAGE_TYPE_TESTBED_LOGGER_MSG, struct GNUNET_MessageHeader, NULL), GNUNET_MQ_handler_end())
	Define "main" method using service macro. More...

Variables
struct GNUNET_BIO_WriteHandle *	bio
	Handle for buffered writing. More...
static unsigned int	nconn
	The number of connections we have. More...
static int	in_shutdown
	Are we shutting down? More...

Detailed Description

service for collecting messages and writing to a file

Author

Sree Harsha Totakura

Definition in file gnunet-service-testbed-logger.c.

Macro Definition Documentation

LOG

#define LOG	(		type,
			...
	)		GNUNET_log (type, __VA_ARGS__)

Generic logging shorthand.

Definition at line 33 of file gnunet-service-testbed-logger.c.

LOG_DEBUG

#define LOG_DEBUG

(

...

)

LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__)

Debug logging shorthand.

Definition at line 39 of file gnunet-service-testbed-logger.c.

Function Documentation

check_log_msg()

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

static

Check GNUNET_MESSAGE_TYPE_TESTBED_LOGGER_MSG messages.

Parameters

cls	client identification of the client
msg	the actual message

Returns

GNUNET_OK (they are all always OK)

Definition at line 66 of file gnunet-service-testbed-logger.c.

{
  return GNUNET_OK;
}

References GNUNET_OK.

handle_log_msg()

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

static

Message handler for GNUNET_MESSAGE_TYPE_TESTBED_LOGGER_MSG messages.

Parameters

cls	client identification of the client
msg	the actual message

Definition at line 80 of file gnunet-service-testbed-logger.c.

{
  struct GNUNET_SERVICE_Client *client = cls;
  uint16_t ms;
 
  ms = ntohs (msg->size) - sizeof(struct GNUNET_MessageHeader);
  GNUNET_BIO_write (bio,
                    "testbed-logger-handle-log-msg",
                    &msg[1],
                    ms);
  GNUNET_SERVICE_client_continue (client);
}

References bio, GNUNET_BIO_write(), GNUNET_SERVICE_client_continue(), msg, and GNUNET_MessageHeader::size.

Here is the call graph for this function:

shutdown_task()

static void shutdown_task ( void *  cls )

static

Task to clean up and shutdown nicely.

Parameters

cls

NULL

Definition at line 101 of file gnunet-service-testbed-logger.c.

{
  in_shutdown = GNUNET_YES;
  if (0 != nconn)
  {
    /* Delay shutdown if there are active connections */
    GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
                                   NULL);
    return;
  }
  GNUNET_break (GNUNET_OK ==
                GNUNET_BIO_write_close (bio, NULL));
}

References bio, GNUNET_BIO_write_close(), GNUNET_break, GNUNET_OK, GNUNET_SCHEDULER_add_shutdown(), GNUNET_YES, in_shutdown, and nconn.

Referenced by logger_run().

Here is the call graph for this function:

Here is the caller graph for this function:

client_connect_cb()

static void* client_connect_cb ( void *  cls, struct GNUNET_SERVICE_Client *  c, struct GNUNET_MQ_Handle *  mq  )

static

Callback called when a client connects to the service.

Parameters

cls	closure for the service
c	the new client that connected to the service
mq	the message queue used to send messages to the client

Returns

c

Definition at line 125 of file gnunet-service-testbed-logger.c.

{
  /* FIXME: is this really what we want here? */
  GNUNET_SERVICE_client_persist (c);
  nconn++;
  return c;
}

References GNUNET_SERVICE_client_persist(), and nconn.

Here is the call graph for this function:

client_disconnect_cb()

static void client_disconnect_cb ( void *  cls, struct GNUNET_SERVICE_Client *  c, void *  internal_cls  )

static

Callback called when a client disconnected from the service.

Parameters

cls	closure for the service
c	the client that disconnected
internal_cls	should be equal to c

Definition at line 144 of file gnunet-service-testbed-logger.c.

{
  nconn--;
  if (GNUNET_YES == in_shutdown)
    GNUNET_SCHEDULER_shutdown ();
  GNUNET_assert (c == internal_cls);
}

References GNUNET_assert, GNUNET_SCHEDULER_shutdown(), GNUNET_YES, in_shutdown, and nconn.

Here is the call graph for this function:

logger_run()

static void logger_run ( void *  cls, const struct GNUNET_CONFIGURATION_Handle *  cfg, struct GNUNET_SERVICE_Handle *  service  )

static

Testbed setup.

Parameters

cls	closure
cfg	configuration to use
service	the initialized service

Definition at line 163 of file gnunet-service-testbed-logger.c.

{
  char *dir;
  char *fn;
  char *hname;
  size_t hname_len;
  pid_t pid;
 
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_get_value_filename (cfg,
                                               "TESTBED-LOGGER",
                                               "DIR",
                                               &dir))
  {
    GNUNET_log_config_missing (GNUNET_ERROR_TYPE_ERROR,
                               "TESTBED-LOGGER",
                               "DIR");
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
  pid = getpid ();
  hname_len = GNUNET_OS_get_hostname_max_length ();
  hname = GNUNET_malloc (hname_len);
  if (0 != gethostname (hname,
                        hname_len))
  {
    LOG (GNUNET_ERROR_TYPE_ERROR,
         "Cannot get hostname.  Exiting\n");
    GNUNET_free (hname);
    GNUNET_free (dir);
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
  GNUNET_asprintf (&fn,
                   "%s/%.*s_%jd.dat",
                   dir,
                   (int) hname_len,
                   hname,
                   (intmax_t) pid);
  GNUNET_free (hname);
  GNUNET_free (dir);
  if (NULL == (bio = GNUNET_BIO_write_open_file (fn)))
  {
    GNUNET_free (fn);
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
  GNUNET_free (fn);
  GNUNET_SCHEDULER_add_shutdown (&shutdown_task,
                                 NULL);
  LOG_DEBUG ("TESTBED-LOGGER startup complete\n");
}

References bio, cfg, dir, GNUNET_asprintf(), GNUNET_BIO_write_open_file(), GNUNET_CONFIGURATION_get_value_filename(), GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log_config_missing(), GNUNET_malloc, GNUNET_OK, GNUNET_OS_get_hostname_max_length, GNUNET_SCHEDULER_add_shutdown(), GNUNET_SCHEDULER_shutdown(), LOG, LOG_DEBUG, pid, and shutdown_task().

Here is the call graph for this function:

GNUNET_SERVICE_MAIN()

GNUNET_SERVICE_MAIN	(	"testbed-logger"	,
		GNUNET_SERVICE_OPTION_NONE	,
		&	logger_run,
		&	client_connect_cb,
		&	client_disconnect_cb,
		NULL	,
		GNUNET_MQ_hd_var_size(log_msg, GNUNET_MESSAGE_TYPE_TESTBED_LOGGER_MSG, struct GNUNET_MessageHeader, NULL)	,
		GNUNET_MQ_handler_end()
	)

Define "main" method using service macro.

Variable Documentation

bio

struct GNUNET_BIO_WriteHandle* bio

Handle for buffered writing.

Definition at line 45 of file gnunet-service-testbed-logger.c.

Referenced by handle_log_msg(), logger_run(), and shutdown_task().

nconn

unsigned int nconn

static

The number of connections we have.

Definition at line 50 of file gnunet-service-testbed-logger.c.

Referenced by client_connect_cb(), client_disconnect_cb(), and shutdown_task().

in_shutdown

int in_shutdown

static

Are we shutting down?

Definition at line 55 of file gnunet-service-testbed-logger.c.

Referenced by client_disconnect_cb(), and shutdown_task().