gnunet-cmds-helper.c File Reference

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_testing_lib.h"
#include "gnunet_testing_ng_lib.h"
#include "gnunet_testing_plugin.h"
#include "gnunet_testing_netjail_lib.h"
#include "testing.h"
#include "testing_cmds.h"
#include "gnunet_testing_barrier.h"
#include <zlib.h>

Include dependency graph for gnunet-cmds-helper.c:

Go to the source code of this file.

Data Structures
struct	NodeIdentifier
	Struct with information about a specific node and the whole network namespace setup. More...
struct	WriteContext
	Context for a single write on a chunk of memory. More...

Macros
#define	LOG(kind, ...)   GNUNET_log (kind, __VA_ARGS__)
	Generic logging shortcut. More...
#define	LOG_DEBUG(...)   LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__)
	Debug logging shorthand. More...
#define	NODE_BASE_IP   "192.168.15."
#define	KNOWN_BASE_IP   "92.68.151."
#define	ROUTER_BASE_IP   "92.68.150."

Functions
static void	do_shutdown (void *cls)
	Task to shut down cleanly. More...
static void	write_task (void *cls)
	Task to write to the standard out. More...
static void	write_message (struct GNUNET_MessageHeader *message, size_t msg_length)
	Callback to write a message to the master loop. More...
static void	delay_shutdown_cb ()
struct GNUNET_MessageHeader *	GNUNET_TESTING_send_local_test_finished_msg ()
static void	finished_cb (enum GNUNET_GenericReturnValue rv)
static int	tokenizer_cb (void *cls, const struct GNUNET_MessageHeader *message)
	Functions with this signature are called whenever a complete message is received by the tokenizer. More...
static void	read_task (void *cls)
	Task to read from stdin. More...
static void	run (void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg)
	Main function that will be run. More...
static void	sighandler_child_death ()
	Signal handler called for SIGCHLD. More...
int	main (int argc, char **argv)
	Main function. More...

Variables
struct GNUNET_SCHEDULER_Task *	finished_task
struct GNUNET_TESTING_Interpreter *	is
struct TestcasePlugin *	plugin
	The process handle to the testbed service. More...
struct GNUNET_MessageStreamTokenizer *	tokenizer
	Our message stream tokenizer. More...
static struct GNUNET_DISK_FileHandle *	stdin_fd
	Disk handle from stdin. More...
static struct GNUNET_DISK_FileHandle *	stdout_fd
	Disk handle for stdout. More...
static struct GNUNET_DISK_PipeHandle *	sigpipe
	Pipe used to communicate shutdown via signal. More...
static struct GNUNET_SCHEDULER_Task *	read_task_id
	Task identifier for the read task. More...
static struct GNUNET_SCHEDULER_Task *	write_task_id
	Task identifier for the write task. More...
static int	done_reading
	Are we done reading messages from stdin? More...
static int	status
	Result to return in case we fail. More...

Macro Definition Documentation

LOG

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

Generic logging shortcut.

Definition at line 55 of file gnunet-cmds-helper.c.

LOG_DEBUG

#define LOG_DEBUG

(

...

)

LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__)

Debug logging shorthand.

Definition at line 60 of file gnunet-cmds-helper.c.

NODE_BASE_IP

#define NODE_BASE_IP   "192.168.15."

Definition at line 62 of file gnunet-cmds-helper.c.

KNOWN_BASE_IP

#define KNOWN_BASE_IP   "92.68.151."

Definition at line 64 of file gnunet-cmds-helper.c.

ROUTER_BASE_IP

#define ROUTER_BASE_IP   "92.68.150."

Definition at line 66 of file gnunet-cmds-helper.c.

Function Documentation

do_shutdown()

static void do_shutdown ( void *  cls )

static

Task to shut down cleanly.

Parameters

cls

NULL

Definition at line 203 of file gnunet-cmds-helper.c.

{
 
  LOG_DEBUG ("Shutting down.\n");
 
  if (NULL != read_task_id)
  {
    GNUNET_SCHEDULER_cancel (read_task_id);
    read_task_id = NULL;
  }
  if (NULL != write_task_id)
  {
    struct WriteContext *wc;
 
    wc = GNUNET_SCHEDULER_cancel (write_task_id);
    write_task_id = NULL;
    GNUNET_free (wc->data);
    GNUNET_free (wc);
  }
  if (NULL != stdin_fd)
    (void) GNUNET_DISK_file_close (stdin_fd);
  if (NULL != stdout_fd)
    (void) GNUNET_DISK_file_close (stdout_fd);
  GNUNET_MST_destroy (tokenizer);
  tokenizer = NULL;
  GNUNET_PLUGIN_unload (plugin->library_name,
                        NULL);
  GNUNET_free (plugin);
}

References WriteContext::data, GNUNET_DISK_file_close(), GNUNET_free, GNUNET_MST_destroy(), GNUNET_PLUGIN_unload(), GNUNET_SCHEDULER_cancel(), TestcasePlugin::library_name, LOG_DEBUG, plugin, read_task_id, stdin_fd, stdout_fd, tokenizer, and write_task_id.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

write_task()

static void write_task ( void *  cls )

static

Task to write to the standard out.

Parameters

cls	the WriteContext

Definition at line 240 of file gnunet-cmds-helper.c.

{
  struct WriteContext *wc = cls;
  ssize_t bytes_wrote;
 
  GNUNET_assert (NULL != wc);
  write_task_id = NULL;
  bytes_wrote = GNUNET_DISK_file_write (stdout_fd,
                                        wc->data + wc->pos,
                                        wc->length - wc->pos);
  GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
              "message send to master loop\n");
  if (GNUNET_SYSERR == bytes_wrote)
  {
    LOG (GNUNET_ERROR_TYPE_WARNING,
         "Cannot reply back successful initialization\n");
    GNUNET_free (wc->data);
    GNUNET_free (wc);
    return;
  }
  wc->pos += bytes_wrote;
  if (wc->pos == wc->length)
  {
    GNUNET_free (wc->data);
    GNUNET_free (wc);
    return;
  }
  write_task_id = GNUNET_SCHEDULER_add_write_file (GNUNET_TIME_UNIT_FOREVER_REL,
                                                   stdout_fd,
                                                   &write_task,
                                                   wc);
}

References WriteContext::data, GNUNET_assert, GNUNET_DISK_file_write(), GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, GNUNET_SCHEDULER_add_write_file(), GNUNET_SYSERR, GNUNET_TIME_UNIT_FOREVER_REL, WriteContext::length, LOG, WriteContext::pos, stdout_fd, and write_task_id.

Referenced by write_message().

Here is the call graph for this function:

Here is the caller graph for this function:

write_message()

static void write_message ( struct GNUNET_MessageHeader *  message, size_t  msg_length  )

static

Callback to write a message to the master loop.

Definition at line 279 of file gnunet-cmds-helper.c.

{
  struct WriteContext *wc;
 
  GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
              "write message to master loop\n");
  wc = GNUNET_new (struct WriteContext);
  wc->length = msg_length;
  wc->data = message;
  write_task_id = GNUNET_SCHEDULER_add_write_file (
    GNUNET_TIME_UNIT_FOREVER_REL,
    stdout_fd,
    &write_task,
    wc);
}

References WriteContext::data, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_new, GNUNET_SCHEDULER_add_write_file(), GNUNET_TIME_UNIT_FOREVER_REL, WriteContext::length, stdout_fd, write_task(), and write_task_id.

Referenced by finished_cb(), and tokenizer_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

delay_shutdown_cb()

static void delay_shutdown_cb ( )

static

Definition at line 296 of file gnunet-cmds-helper.c.

{
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "doing shutdown after delay\n");
  GNUNET_SCHEDULER_shutdown ();
}

References GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, and GNUNET_SCHEDULER_shutdown().

Referenced by finished_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_send_local_test_finished_msg()

struct GNUNET_MessageHeader* GNUNET_TESTING_send_local_test_finished_msg

(

)

Definition at line 305 of file gnunet-cmds-helper.c.

{
  struct GNUNET_TESTING_CommandLocalFinished *reply;
  size_t msg_length;
 
  msg_length = sizeof(struct GNUNET_TESTING_CommandLocalFinished);
  reply = GNUNET_new (struct GNUNET_TESTING_CommandLocalFinished);
  reply->header.type = htons (GNUNET_MESSAGE_TYPE_CMDS_HELPER_LOCAL_FINISHED);
  reply->header.size = htons ((uint16_t) msg_length);
 
  return (struct GNUNET_MessageHeader *) reply;
}

References GNUNET_MESSAGE_TYPE_CMDS_HELPER_LOCAL_FINISHED, GNUNET_new, GNUNET_TESTING_CommandLocalFinished::header, GNUNET_MessageHeader::size, and GNUNET_MessageHeader::type.

finished_cb()

static void finished_cb ( enum GNUNET_GenericReturnValue  rv )

static

Definition at line 320 of file gnunet-cmds-helper.c.

{
  struct GNUNET_TESTING_CommandLocalFinished *reply;
  size_t msg_length;
 
  msg_length = sizeof(struct GNUNET_TESTING_CommandLocalFinished);
  reply = GNUNET_new (struct GNUNET_TESTING_CommandLocalFinished);
  reply->header.type = htons (GNUNET_MESSAGE_TYPE_CMDS_HELPER_LOCAL_FINISHED);
  reply->header.size = htons ((uint16_t) msg_length);
  reply->rv = rv;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "message prepared\n");
  write_message ((struct GNUNET_MessageHeader *) reply, msg_length);
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "message send\n");
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "delaying shutdown\n");
  GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
                                delay_shutdown_cb,
                                NULL);
}

References delay_shutdown_cb(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_MESSAGE_TYPE_CMDS_HELPER_LOCAL_FINISHED, GNUNET_new, GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_UNIT_SECONDS, GNUNET_TESTING_CommandLocalFinished::header, GNUNET_TESTING_CommandLocalFinished::rv, GNUNET_MessageHeader::size, GNUNET_MessageHeader::type, and write_message().

Referenced by GDS_u_send(), gnunet_send(), ip_send(), and tokenizer_cb().

Here is the call graph for this function:

Here is the caller graph for this function:

tokenizer_cb()

static int tokenizer_cb ( void *  cls, const struct GNUNET_MessageHeader *  message  )

static

Functions with this signature are called whenever a complete message is received by the tokenizer.

Do not call #GNUNET_mst_destroy() in this callback

Parameters

cls	identification of the client
message	the actual message

Returns

GNUNET_OK on success, GNUNET_NO to stop further processing (no error) GNUNET_SYSERR to stop further processing with error

Definition at line 358 of file gnunet-cmds-helper.c.

{
 
  struct NodeIdentifier *ni = cls;
  const struct GNUNET_TESTING_CommandHelperInit *msg;
  struct GNUNET_TESTING_CommandHelperReply *reply;
  char *binary;
  char *plugin_name;
  size_t plugin_name_size;
  uint16_t msize;
  uint16_t type;
  size_t msg_length;
  char *router_ip;
  char *node_ip;
  unsigned int namespace_n;
 
  type = ntohs (message->type);
  msize = ntohs (message->size);
  LOG (GNUNET_ERROR_TYPE_ERROR,
       "Received message type %u and size %u\n",
       type,
       msize);
  if (GNUNET_MESSAGE_TYPE_CMDS_HELPER_INIT == ntohs (message->type))
  {
    msg = (const struct GNUNET_TESTING_CommandHelperInit *) message;
    plugin_name_size = ntohs (msg->plugin_name_size);
    if ((sizeof(struct GNUNET_TESTING_CommandHelperInit) + plugin_name_size) > msize)
    {
      GNUNET_break (0);
      LOG (GNUNET_ERROR_TYPE_WARNING,
           "Received unexpected message -- exiting\n");
      goto error;
    }
    plugin_name = GNUNET_malloc (plugin_name_size + 1);
    GNUNET_strlcpy (plugin_name,
                    ((char *) &msg[1]),
                    plugin_name_size + 1);
 
    binary = GNUNET_OS_get_libexec_binary_path ("gnunet-cmd");
 
    plugin = GNUNET_new (struct TestcasePlugin);
    plugin->api = GNUNET_PLUGIN_load (plugin_name,
                                      NULL);
    plugin->library_name = GNUNET_strdup (basename (plugin_name));
 
    plugin->global_n = ni->global_n;
    plugin->local_m = ni->local_m;
    plugin->n = ni->n;
    plugin->m = ni->m;
 
    router_ip = GNUNET_malloc (strlen (ROUTER_BASE_IP) + strlen (plugin->n)
                               + 1);
    strcpy (router_ip, ROUTER_BASE_IP);
    strcat (router_ip, plugin->n);
 
    sscanf (plugin->n, "%u", &namespace_n);
 
    if (0 == namespace_n)
    {
      LOG (GNUNET_ERROR_TYPE_ERROR,
           "known node n: %s\n",
           plugin->n);
      node_ip = GNUNET_malloc (strlen (KNOWN_BASE_IP) + strlen (plugin->m) + 1);
      strcat (node_ip, KNOWN_BASE_IP);
    }
    else
    {
      LOG (GNUNET_ERROR_TYPE_ERROR,
           "subnet node n: %s\n",
           plugin->n);
      node_ip = GNUNET_malloc (strlen (NODE_BASE_IP) + strlen (plugin->m) + 1);
      strcat (node_ip, NODE_BASE_IP);
    }
    strcat (node_ip, plugin->m);
 
    is = plugin->api->start_testcase (&write_message, router_ip, node_ip, plugin->m,
 
                                 plugin->n, plugin->local_m, ni->topology_data,
                                 ni->read_file, &finished_cb);
    GNUNET_free (node_ip);
    GNUNET_free (binary);
    GNUNET_free (router_ip);
    GNUNET_free (plugin_name);
 
    msg_length = sizeof(struct GNUNET_TESTING_CommandHelperReply);
    reply = GNUNET_new (struct GNUNET_TESTING_CommandHelperReply);
    reply->header.type = htons (GNUNET_MESSAGE_TYPE_CMDS_HELPER_REPLY);
    reply->header.size = htons ((uint16_t) msg_length);
 
    write_message ((struct GNUNET_MessageHeader *) reply, msg_length);
 
    return GNUNET_OK;
  }
  else if (GNUNET_MESSAGE_TYPE_CMDS_HELPER_BARRIER_CROSSABLE == ntohs (
             message->type))
  {
    const char *barrier_name;
    struct CommandBarrierCrossable *adm = (struct CommandBarrierCrossable *) message;
 
    barrier_name = (const char *) &adm[1];
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "cross barrier %s\n",
         barrier_name);
    TST_interpreter_finish_attached_cmds (is, barrier_name);
    return GNUNET_OK;
  }
  else if (GNUNET_MESSAGE_TYPE_CMDS_HELPER_ALL_PEERS_STARTED == ntohs (
             message->type))
  {
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "all peers started\n");
    plugin->api->all_peers_started ();
    return GNUNET_OK;
  }
  else if (GNUNET_MESSAGE_TYPE_CMDS_HELPER_ALL_LOCAL_TESTS_PREPARED == ntohs (
             message->type))
  {
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "all local tests prepared\n");
    plugin->api->all_local_tests_prepared ();
    return GNUNET_OK;
  }
  else
  {
    LOG (GNUNET_ERROR_TYPE_WARNING, "Received unexpected message -- exiting\n");
    goto error;
  }
 
 
  error:
  status = GNUNET_SYSERR;
  LOG (GNUNET_ERROR_TYPE_ERROR,
       "tokenizer shutting down!\n");
  GNUNET_SCHEDULER_shutdown ();
  return GNUNET_SYSERR;
}

References GNUNET_TESTING_PluginFunctions::all_local_tests_prepared, GNUNET_TESTING_PluginFunctions::all_peers_started, TestcasePlugin::api, finished_cb(), NodeIdentifier::global_n, TestcasePlugin::global_n, GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_malloc, GNUNET_MESSAGE_TYPE_CMDS_HELPER_ALL_LOCAL_TESTS_PREPARED, GNUNET_MESSAGE_TYPE_CMDS_HELPER_ALL_PEERS_STARTED, GNUNET_MESSAGE_TYPE_CMDS_HELPER_BARRIER_CROSSABLE, GNUNET_MESSAGE_TYPE_CMDS_HELPER_INIT, GNUNET_MESSAGE_TYPE_CMDS_HELPER_REPLY, GNUNET_new, GNUNET_OK, GNUNET_OS_get_libexec_binary_path(), GNUNET_PLUGIN_load(), GNUNET_SCHEDULER_shutdown(), GNUNET_strdup, GNUNET_strlcpy(), GNUNET_SYSERR, GNUNET_TESTING_CommandHelperReply::header, is, KNOWN_BASE_IP, TestcasePlugin::library_name, NodeIdentifier::local_m, TestcasePlugin::local_m, LOG, NodeIdentifier::m, TestcasePlugin::m, msg, NodeIdentifier::n, TestcasePlugin::n, NODE_BASE_IP, plugin, plugin_name, GNUNET_TESTING_CommandHelperInit::plugin_name_size, NodeIdentifier::read_file, ROUTER_BASE_IP, GNUNET_MessageHeader::size, GNUNET_TESTING_PluginFunctions::start_testcase, status, NodeIdentifier::topology_data, TST_interpreter_finish_attached_cmds(), GNUNET_MessageHeader::type, type, and write_message().

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

read_task()

static void read_task ( void *  cls )

static

Task to read from stdin.

Parameters

cls

NULL

Definition at line 502 of file gnunet-cmds-helper.c.

{
  char buf[GNUNET_MAX_MESSAGE_SIZE];
  ssize_t sread;
 
  read_task_id = NULL;
  sread = GNUNET_DISK_file_read (stdin_fd, buf, sizeof(buf));
  if ((GNUNET_SYSERR == sread) || (0 == sread))
  {
    LOG_DEBUG ("STDIN closed\n");
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
  if (GNUNET_YES == done_reading)
  {
    /* didn't expect any more data! */
    GNUNET_break_op (0);
    LOG (GNUNET_ERROR_TYPE_ERROR,
         "tokenizer shutting down during reading, didn't expect any more data!\n");
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
  LOG_DEBUG ("Read %u bytes\n", (unsigned int) sread);
  /* FIXME: could introduce a GNUNET_MST_read2 to read
     directly from 'stdin_fd' and save a memcpy() here */
  if (GNUNET_OK !=
      GNUNET_MST_from_buffer (tokenizer, buf, sread, GNUNET_NO, GNUNET_NO))
  {
    GNUNET_break (0);
    LOG (GNUNET_ERROR_TYPE_ERROR,
         "tokenizer shutting down during reading, writing to buffer failed!\n");
    GNUNET_SCHEDULER_shutdown ();
    return;
  }
  read_task_id /* No timeout while reading */
    = GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL,
                                      stdin_fd,
                                      &read_task,
                                      NULL);
}

References buf, done_reading, GNUNET_break, GNUNET_break_op, GNUNET_DISK_file_read(), GNUNET_ERROR_TYPE_ERROR, GNUNET_MAX_MESSAGE_SIZE, GNUNET_MST_from_buffer(), GNUNET_NO, GNUNET_OK, GNUNET_SCHEDULER_add_read_file(), GNUNET_SCHEDULER_shutdown(), GNUNET_SYSERR, GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_YES, LOG, LOG_DEBUG, read_task_id, stdin_fd, and tokenizer.

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

run()

static void run ( void *  cls, char *const *  args, const char *  cfgfile, const struct GNUNET_CONFIGURATION_Handle *  cfg  )

static

Main function that will be run.

Parameters

cls	closure
args	remaining command-line arguments
cfgfile	name of the configuration file used (for saving, can be NULL!)
cfg	configuration

Definition at line 553 of file gnunet-cmds-helper.c.

{
  struct NodeIdentifier *ni = cls;
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Starting interpreter loop helper...\n");
 
  tokenizer = GNUNET_MST_create (&tokenizer_cb, ni);
  stdin_fd = GNUNET_DISK_get_handle_from_native (stdin);
  stdout_fd = GNUNET_DISK_get_handle_from_native (stdout);
  read_task_id = GNUNET_SCHEDULER_add_read_file (GNUNET_TIME_UNIT_FOREVER_REL,
                                                 stdin_fd,
                                                 &read_task,
                                                 NULL);
  GNUNET_SCHEDULER_add_shutdown (&do_shutdown, NULL);
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Interpreter loop helper started.\n");
}

References do_shutdown(), GNUNET_DISK_get_handle_from_native(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_MST_create(), GNUNET_SCHEDULER_add_read_file(), GNUNET_SCHEDULER_add_shutdown(), GNUNET_TIME_UNIT_FOREVER_REL, LOG, read_task(), read_task_id, stdin_fd, stdout_fd, tokenizer, and tokenizer_cb().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

sighandler_child_death()

static void sighandler_child_death ( void  )

static

Signal handler called for SIGCHLD.

Definition at line 580 of file gnunet-cmds-helper.c.

{
  static char c;
  int old_errno; /* back-up errno */
 
  old_errno = errno;
  GNUNET_break (
    1 ==
    GNUNET_DISK_file_write (GNUNET_DISK_pipe_handle (sigpipe,
                                                     GNUNET_DISK_PIPE_END_WRITE),
                            &c,
                            sizeof(c)));
  errno = old_errno;
}

References GNUNET_break, GNUNET_DISK_file_write(), GNUNET_DISK_PIPE_END_WRITE, GNUNET_DISK_pipe_handle(), and sigpipe.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

main()

int main	(	int	argc,
		char **	argv
	)

Main function.

Parameters

argc	the number of command line arguments
argv	command line arg array

Returns

return code

Definition at line 604 of file gnunet-cmds-helper.c.

{
  struct NodeIdentifier *ni;
  struct GNUNET_SIGNAL_Context *shc_chld;
  struct GNUNET_GETOPT_CommandLineOption options[] =
  { GNUNET_GETOPT_OPTION_END };
  int ret;
  unsigned int sscanf_ret;
  int i;
  size_t topology_data_length = 0;
  unsigned int read_file;
  char cr[2] = "\n\0";
 
  GNUNET_log_setup ("gnunet-cmds-helper",
                    "DEBUG",
                    NULL);
  ni = GNUNET_new (struct NodeIdentifier);
  ni->global_n = argv[1];
  ni->local_m = argv[2];
  ni->m = argv[3];
  ni->n = argv[4];
 
  errno = 0;
  sscanf_ret = sscanf (argv[5], "%u", &read_file);
 
  if (errno != 0)
  {
    GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "sscanf");
  }
  else if (1 == read_file)
    ni->topology_data = argv[6];
  else if (0 == read_file)
  {
    for (i = 6; i<argc; i++)
      topology_data_length += strlen (argv[i]) + 1;
    LOG (GNUNET_ERROR_TYPE_DEBUG,
         "topo data length %lu\n",
         topology_data_length);
    ni->topology_data = GNUNET_malloc (topology_data_length);
    memset (ni->topology_data, '\0', topology_data_length);
    for (i = 6; i<argc; i++)
    {
      strcat (ni->topology_data, argv[i]);
      strcat (ni->topology_data, cr);
    }
  }
  else
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "Wrong input for the fourth argument\n");
  }
  GNUNET_assert (0 < sscanf_ret);
  ni->read_file = &read_file;
  ni->topology_data[topology_data_length - 1] = '\0';
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "topo data %s\n",
       ni->topology_data);
 
  status = GNUNET_OK;
  if (NULL ==
      (sigpipe = GNUNET_DISK_pipe (GNUNET_DISK_PF_NONE)))
  {
    GNUNET_break (0);
    return 1;
  }
  shc_chld =
    GNUNET_SIGNAL_handler_install (GNUNET_SIGCHLD, &sighandler_child_death);
 
  ret = GNUNET_PROGRAM_run (argc,
                            argv,
                            "gnunet-cmds-helper",
                            "Helper for starting a local interpreter loop",
                            options,
                            &run,
                            ni);
 
  LOG (GNUNET_ERROR_TYPE_DEBUG,
       "Finishing helper\n");
  GNUNET_SIGNAL_handler_uninstall (shc_chld);
  shc_chld = NULL;
  GNUNET_DISK_pipe_close (sigpipe);
  GNUNET_free (ni);
  if (GNUNET_OK != ret)
    return 1;
  return (GNUNET_OK == status) ? 0 : 1;
}

References NodeIdentifier::global_n, GNUNET_assert, GNUNET_break, GNUNET_DISK_PF_NONE, GNUNET_DISK_pipe(), GNUNET_DISK_pipe_close(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_GETOPT_OPTION_END, GNUNET_log, GNUNET_log_setup(), GNUNET_log_strerror, GNUNET_malloc, GNUNET_new, GNUNET_OK, GNUNET_PROGRAM_run(), GNUNET_SIGCHLD, GNUNET_SIGNAL_handler_install(), GNUNET_SIGNAL_handler_uninstall(), NodeIdentifier::local_m, LOG, NodeIdentifier::m, NodeIdentifier::n, options, read_file(), NodeIdentifier::read_file, ret, run(), shc_chld, sighandler_child_death(), sigpipe, status, and NodeIdentifier::topology_data.

Here is the call graph for this function:

Variable Documentation

finished_task

struct GNUNET_SCHEDULER_Task* finished_task

Definition at line 80 of file gnunet-cmds-helper.c.

is

struct GNUNET_TESTING_Interpreter* is

Definition at line 82 of file gnunet-cmds-helper.c.

Referenced by backchannel_check_run(), barrier_reached_run(), barrier_run(), batch_run(), block_until_all_peers_started_run(), check_backchannel_encapsulation(), check_communicator_backchannel(), connect_peers_run(), delete_networks(), do_timeout(), finish_test(), free_barrier_node_cb(), free_barriers_cb(), get_addresses(), get_command(), GNUNET_NT_scanner_done(), GNUNET_NT_scanner_init(), GNUNET_TESTING_add_netjail_helper(), GNUNET_TESTING_command_new(), GNUNET_TESTING_interpreter_fail(), GNUNET_TESTING_interpreter_get_current_command(), GNUNET_TESTING_interpreter_get_current_label(), GNUNET_TESTING_interpreter_lookup_command(), GNUNET_TESTING_interpreter_lookup_command_all(), GNUNET_TESTING_interpreter_lookup_future_command(), handle_communicator_backchannel(), interface_proc(), interpreter_delete_barriers(), interpreter_next(), interpreter_run(), netjail_exec_run(), netjail_stop_run(), notify_connect(), run_finish(), send_message_to_netjail(), send_simple_run(), start_peer_run(), stop_peer_run(), stop_testing_system_run(), system_destroy_run(), tokenizer_cb(), TST_interpreter_add_barrier(), TST_interpreter_finish_attached_cmds(), TST_interpreter_get_barrier(), and TST_interpreter_send_barrier_crossable().

plugin

struct TestcasePlugin* plugin

The process handle to the testbed service.

static struct GNUNET_OS_Process *cmd_binary_process; Plugin to dynamically load a test case.

Definition at line 154 of file gnunet-cmds-helper.c.

Referenced by __attribute__(), ack_message_sent(), ack_proc(), add_plugin(), address_notification(), analyze_send_error(), append_port(), broadcast_mst_cb(), check_port(), client_configure_plugin(), client_connect(), client_delete_session(), client_lookup_session(), client_receive_mst_cb(), client_run(), client_schedule(), client_send_cb(), client_start(), connect_notify(), core_connect_cb(), core_disconnect_cb(), core_init_cb(), create_macendpoint(), create_session(), create_source(), create_target(), database_connect(), database_setup(), database_shutdown(), delete_by_rowid(), delete_entries(), delete_old_block(), delete_value(), dequeue(), destroy_session_cb(), disconnect_and_free_it(), disconnect_notify(), do_delete_entry(), do_shutdown(), do_transmit(), enqueue(), enqueue_fragment(), execute_get(), execute_select(), expi_proc(), expire_blocks(), expire_entries(), find_closest(), find_plugin(), find_source(), find_target(), fragmented_message_done(), free_macendpoint(), free_value(), get_any(), get_cb(), get_session_delete_it(), get_typed(), get_wlan_header(), GNUNET_BLOCK_check_block(), GNUNET_BLOCK_context_destroy(), gnunet_drop(), GNUNET_GNSRECORD_is_critical(), GNUNET_GNSRECORD_string_to_value(), GNUNET_GNSRECORD_typename_to_number(), GNUNET_GNSRECORD_value_to_string(), gnunet_hold(), GNUNET_RECLAIM_attribute_number_to_typename(), GNUNET_RECLAIM_attribute_string_to_value(), GNUNET_RECLAIM_attribute_typename_to_number(), GNUNET_RECLAIM_attribute_value_to_string(), GNUNET_RECLAIM_credential_get_attributes(), GNUNET_RECLAIM_credential_get_expiration(), GNUNET_RECLAIM_credential_get_issuer(), GNUNET_RECLAIM_credential_get_presentation(), GNUNET_RECLAIM_credential_number_to_typename(), GNUNET_RECLAIM_credential_string_to_value(), GNUNET_RECLAIM_credential_typename_to_number(), GNUNET_RECLAIM_credential_value_to_string(), GNUNET_RECLAIM_presentation_get_attributes(), GNUNET_RECLAIM_presentation_get_expiration(), GNUNET_RECLAIM_presentation_get_issuer(), GNUNET_RECLAIM_presentation_number_to_typename(), GNUNET_RECLAIM_presentation_string_to_value(), GNUNET_RECLAIM_presentation_typename_to_number(), GNUNET_RECLAIM_presentation_value_to_string(), gnunet_try_connect(), handle_core_message(), handle_helper_message(), handle_tcp_data(), handle_tcp_nat_probe(), handle_tcp_welcome(), heap_get_keys(), heap_plugin_estimate_size(), heap_plugin_get_closest(), heap_plugin_get_expiration(), heap_plugin_get_key(), heap_plugin_get_replication(), heap_plugin_get_zero_anonymity(), heap_plugin_put(), heap_plugin_remove_key(), hello_offered_cb(), http_client_plugin_get_session(), http_client_plugin_peer_disconnect(), http_client_plugin_send(), http_client_plugin_session_disconnect(), http_client_plugin_setup_monitor(), http_common_plugin_address_to_string(), http_common_plugin_dnsresult_to_address(), http_common_plugin_string_to_address(), http_server_plugin_address_suggested(), http_server_plugin_disconnect_peer(), http_server_plugin_send(), http_server_plugin_setup_monitor(), iface_proc(), ip_send(), ip_try_connect(), iterate_entries(), kill_session(), libgnunet_plugin_datacache_heap_done(), libgnunet_plugin_datacache_heap_init(), libgnunet_plugin_datacache_postgres_done(), libgnunet_plugin_datacache_postgres_init(), libgnunet_plugin_datacache_sqlite_done(), libgnunet_plugin_datacache_sqlite_init(), libgnunet_plugin_datacache_template_done(), libgnunet_plugin_datacache_template_init(), libgnunet_plugin_datastore_heap_init(), libgnunet_plugin_datastore_mysql_done(), libgnunet_plugin_datastore_mysql_init(), libgnunet_plugin_datastore_postgres_done(), libgnunet_plugin_datastore_postgres_init(), libgnunet_plugin_datastore_sqlite_done(), libgnunet_plugin_datastore_sqlite_init(), libgnunet_plugin_datastore_template_done(), libgnunet_plugin_datastore_template_init(), libgnunet_plugin_dhtu_gnunet_done(), libgnunet_plugin_dhtu_gnunet_init(), libgnunet_plugin_dhtu_ip_done(), libgnunet_plugin_dhtu_ip_init(), libgnunet_plugin_namecache_flat_done(), libgnunet_plugin_namecache_flat_init(), libgnunet_plugin_namecache_postgres_done(), libgnunet_plugin_namecache_postgres_init(), libgnunet_plugin_namecache_sqlite_done(), libgnunet_plugin_namecache_sqlite_init(), libgnunet_plugin_namestore_flat_done(), libgnunet_plugin_namestore_flat_init(), libgnunet_plugin_namestore_postgres_done(), libgnunet_plugin_namestore_postgres_init(), libgnunet_plugin_namestore_sqlite_done(), libgnunet_plugin_namestore_sqlite_init(), libgnunet_plugin_peerstore_flat_done(), libgnunet_plugin_peerstore_flat_init(), libgnunet_plugin_peerstore_sqlite_done(), libgnunet_plugin_peerstore_sqlite_init(), libgnunet_plugin_rest_config_done(), libgnunet_plugin_rest_config_init(), libgnunet_plugin_rest_copying_done(), libgnunet_plugin_rest_copying_init(), libgnunet_plugin_rest_gns_done(), libgnunet_plugin_rest_gns_init(), libgnunet_plugin_rest_identity_done(), libgnunet_plugin_rest_identity_init(), libgnunet_plugin_rest_namestore_done(), libgnunet_plugin_rest_namestore_init(), libgnunet_plugin_rest_openid_connect_done(), libgnunet_plugin_rest_openid_connect_init(), libgnunet_plugin_rest_pabc_init(), libgnunet_plugin_rest_peerinfo_done(), libgnunet_plugin_rest_peerinfo_init(), libgnunet_plugin_rest_reclaim_done(), libgnunet_plugin_rest_reclaim_init(), LIBGNUNET_PLUGIN_TRANSPORT_DONE(), libgnunet_plugin_transport_http_client_done(), libgnunet_plugin_transport_http_client_init(), libgnunet_plugin_transport_tcp_done(), libgnunet_plugin_transport_tcp_init(), libgnunet_plugin_transport_template_init(), libgnunet_plugin_transport_unix_done(), libgnunet_plugin_transport_unix_init(), load_plugin(), lookup_session(), mysql_plugin_drop(), mysql_plugin_estimate_size(), mysql_plugin_get_expiration(), mysql_plugin_get_key(), mysql_plugin_get_keys(), mysql_plugin_get_replication(), mysql_plugin_get_zero_anonymity(), mysql_plugin_put(), mysql_plugin_remove_key(), namecache_cache_block(), namecache_expire_blocks(), namecache_lookup_block(), namecache_postgres_expire_blocks(), namecache_sqlite_cache_block(), namecache_sqlite_expire_blocks(), namecache_sqlite_lookup_block(), namestore_flat_iterate_records(), namestore_flat_lookup_records(), namestore_flat_store_records(), namestore_flat_zone_to_name(), notify_send_probe(), notify_session_monitor(), nse_cb(), peerinfo_cb(), peerstore_flat_delete_records(), peerstore_flat_expire_records(), peerstore_flat_iterate_records(), peerstore_flat_store_record(), peerstore_sqlite_delete_records(), peerstore_sqlite_expire_records(), peerstore_sqlite_iterate_records(), peerstore_sqlite_store_record(), postgres_plugin_del(), postgres_plugin_drop(), postgres_plugin_estimate_size(), postgres_plugin_get_closest(), postgres_plugin_get_expiration(), postgres_plugin_get_key(), postgres_plugin_get_keys(), postgres_plugin_get_replication(), postgres_plugin_get_zero_anonymity(), postgres_plugin_put(), postgres_plugin_remove_key(), prepare_beacon(), process_data(), process_inbound_tokenized_messages(), process_result(), process_udp_message(), qc_fragment_sent(), qc_message_sent(), read_cb(), read_process_ack(), read_process_fragment(), remove_timeout_messages_and_select(), repl_proc(), run(), run_mhd_start_daemon(), scan(), schedule_select_v4(), schedule_select_v6(), send_hello_beacon(), send_session_info_iter(), send_with_fragmentation(), server_accept_cb(), server_access_cb(), server_add_address(), server_configure_plugin(), server_connection_cb(), server_delete_session(), server_disconnect_cb(), server_get_addresses(), server_lookup_connection(), server_mhd_connection_timeout(), server_nat_port_map_callback(), server_notify_external_hostname(), server_parse_url(), server_receive_mst_cb(), server_remove_address(), server_reschedule(), server_schedule(), server_start(), server_start_report_addresses(), server_stop_report_addresses(), server_v4_run(), server_v6_run(), session_disconnect_it(), session_timeout(), setup_broadcast(), setup_sockets(), sqlite_plugin_drop(), sqlite_plugin_estimate_size(), sqlite_plugin_get_closest(), sqlite_plugin_get_expiration(), sqlite_plugin_get_key(), sqlite_plugin_get_keys(), sqlite_plugin_get_replication(), sqlite_plugin_get_zero_anonymity(), sqlite_plugin_put(), sqlite_plugin_remove_key(), start_helper(), tcp_nat_port_map_callback(), tcp_plugin_address_pretty_printer(), tcp_plugin_check_address(), tcp_plugin_disconnect(), tcp_plugin_disconnect_session(), tcp_plugin_get_network(), tcp_plugin_get_session(), tcp_plugin_send(), tcp_plugin_setup_monitor(), tcp_plugin_string_to_address(), template_plugin_setup_monitor(), tokenizer_cb(), udp_broadcast_receive(), udp_disconnect(), udp_disconnect_session(), udp_ipv4_broadcast_send(), udp_ipv6_broadcast_send(), udp_nat_port_map_callback(), udp_plugin_address_pretty_printer(), udp_plugin_check_address(), udp_plugin_create_session(), udp_plugin_get_session(), udp_plugin_lookup_session(), udp_plugin_select_v4(), udp_plugin_select_v6(), udp_plugin_send(), udp_plugin_setup_monitor(), udp_plugin_update_session_timeout(), udp_select_read(), udp_select_send(), udp_string_to_address(), unix_demultiplexer(), unix_plugin_check_address(), unix_plugin_do_read(), unix_plugin_do_write(), unix_plugin_get_network(), unix_plugin_get_session(), unix_plugin_peer_disconnect(), unix_plugin_select_read(), unix_plugin_select_write(), unix_plugin_send(), unix_plugin_session_disconnect(), unix_plugin_setup_monitor(), unix_plugin_string_to_address(), unix_plugin_update_session_timeout(), unix_transport_server_start(), wlan_data_message_handler(), wlan_plugin_address_suggested(), wlan_plugin_disconnect_peer(), wlan_plugin_disconnect_session(), wlan_plugin_get_session(), wlan_plugin_send(), wlan_plugin_setup_monitor(), and wlan_plugin_string_to_address().

tokenizer

struct GNUNET_MessageStreamTokenizer* tokenizer

Our message stream tokenizer.

Definition at line 159 of file gnunet-cmds-helper.c.

Referenced by do_shutdown(), read_task(), and run().

stdin_fd

struct GNUNET_DISK_FileHandle* stdin_fd

static

Disk handle from stdin.

Definition at line 164 of file gnunet-cmds-helper.c.

Referenced by do_shutdown(), read_task(), and run().

stdout_fd

struct GNUNET_DISK_FileHandle* stdout_fd

static

Disk handle for stdout.

Definition at line 169 of file gnunet-cmds-helper.c.

Referenced by do_shutdown(), run(), write_message(), and write_task().

sigpipe

struct GNUNET_DISK_PipeHandle* sigpipe

static

Pipe used to communicate shutdown via signal.

Definition at line 174 of file gnunet-cmds-helper.c.

Referenced by main(), and sighandler_child_death().

read_task_id

struct GNUNET_SCHEDULER_Task* read_task_id

static

Task identifier for the read task.

Definition at line 179 of file gnunet-cmds-helper.c.

Referenced by do_shutdown(), read_task(), and run().

write_task_id

struct GNUNET_SCHEDULER_Task* write_task_id

static

Task identifier for the write task.

Definition at line 184 of file gnunet-cmds-helper.c.

Referenced by do_shutdown(), write_message(), and write_task().

done_reading

int done_reading

static

Are we done reading messages from stdin?

Definition at line 189 of file gnunet-cmds-helper.c.

Referenced by read_task().

status

int status

static

Result to return in case we fail.

Definition at line 194 of file gnunet-cmds-helper.c.

Referenced by main(), and tokenizer_cb().