testing_arm_cmd_start_peer.c File Reference

#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_testing_lib.h"
#include "gnunet_testbed_lib.h"
#include "gnunet_testing_testbed_lib.h"
#include "gnunet_testing_arm_lib.h"

Include dependency graph for testing_arm_cmd_start_peer.c:

Go to the source code of this file.

Data Structures
struct	GNUNET_TESTING_StartPeerState
	Handle for a peer controlled via ARM. More...

Functions
static void	conn_status (void *cls, enum GNUNET_GenericReturnValue connected)
	Function called whenever we connect to or disconnect from ARM. More...
static void	start_peer_run (void *cls, struct GNUNET_TESTING_Interpreter *is)
	The run method of this cmd will start all services of a peer to test the transport service. More...
static void	start_peer_cleanup (void *cls)
	The cleanup function of this cmd frees resources the cmd allocated. More...
static enum GNUNET_GenericReturnValue	start_peer_traits (void *cls, const void **ret, const char *trait, unsigned int index)
	This function prepares an array with traits. More...
struct GNUNET_TESTING_Command	GNUNET_TESTING_ARM_cmd_start_peer (const char *label, const char *system_label, const char *cfgname)
	Create command. More...

Function Documentation

conn_status()

static void conn_status ( void *  cls, enum GNUNET_GenericReturnValue  connected  )

static

Function called whenever we connect to or disconnect from ARM.

Parameters

cls	closure
connected	GNUNET_YES if connected, GNUNET_NO if disconnected, GNUNET_SYSERR if there was an error.

Definition at line 85 of file testing_arm_cmd_start_peer.c.

{
  struct GNUNET_TESTING_StartPeerState *sps = cls;
  struct GNUNET_TESTING_AsyncContext ac = sps->ac;
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "We %s arm\n",
              GNUNET_OK != connected ? "disconnected from" : "connected to");
  if (GNUNET_NO == ac.finished && GNUNET_OK != connected)
  {
    GNUNET_break (0);
    GNUNET_TESTING_async_fail (&sps->ac);
    return;
  }
  else if (GNUNET_NO == ac.finished)
    GNUNET_TESTING_async_finish (&sps->ac);
}

References GNUNET_TESTING_StartPeerState::ac, GNUNET_TESTING_AsyncContext::finished, GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_NO, GNUNET_OK, GNUNET_TESTING_async_fail(), and GNUNET_TESTING_async_finish().

Referenced by start_peer_run().

Here is the call graph for this function:

Here is the caller graph for this function:

start_peer_run()

static void start_peer_run ( void *  cls, struct GNUNET_TESTING_Interpreter *  is  )

static

The run method of this cmd will start all services of a peer to test the transport service.

Definition at line 111 of file testing_arm_cmd_start_peer.c.

{
  struct GNUNET_TESTING_StartPeerState *sps = cls;
  const struct GNUNET_TESTING_Command *system_cmd;
 
  sps->is = is;
  if (GNUNET_NO ==
      GNUNET_DISK_file_test (sps->cfgname))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                "File not found: `%s'\n",
                sps->cfgname);
    GNUNET_TESTING_FAIL (is);
  }
  system_cmd
    = GNUNET_TESTING_interpreter_lookup_command (is,
                                                 sps->system_label);
  if (NULL == system_cmd)
    GNUNET_TESTING_FAIL (is);
  if (GNUNET_OK !=
      GNUNET_TESTING_TESTBED_get_trait_test_system (
        system_cmd,
        &sps->system))
    GNUNET_TESTING_FAIL (is);
  sps->cfg = GNUNET_CONFIGURATION_create (GNUNET_OS_project_data_gnunet ());
  if (GNUNET_OK !=
      GNUNET_CONFIGURATION_load (sps->cfg,
                                 sps->cfgname))
    GNUNET_TESTING_FAIL (is);
  if (GNUNET_SYSERR ==
      GNUNET_TESTBED_configuration_create (sps->system,
                                           sps->cfg,
                                           NULL,
                                           NULL))
    GNUNET_TESTING_FAIL (is);
  {
    char *config_filename;
    char *libexec_binary;
    char *main_binary;
    char *args;
    char *prefix;
    int16_t ret;
 
    GNUNET_assert (
      GNUNET_OK ==
      GNUNET_CONFIGURATION_get_value_filename (
        sps->cfg,
        "PATHS",
        "DEFAULTCONFIG",
        &config_filename));
    if (GNUNET_OK !=
        GNUNET_CONFIGURATION_write (sps->cfg,
                                    config_filename))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  "Failed to write configuration file `%s': %s\n",
                  config_filename,
                  strerror (errno));
      GNUNET_free (config_filename);
      GNUNET_TESTING_FAIL (is);
    }
 
    libexec_binary
      = GNUNET_OS_get_libexec_binary_path (GNUNET_OS_project_data_gnunet (),
                                           "gnunet-service-arm");
 
    ret = GNUNET_CONFIGURATION_get_value_string (sps->cfg,
                                                 "arm",
                                                 "PREFIX",
                                                 &prefix);
    if ((GNUNET_SYSERR == ret) || (NULL == prefix))
    {
      /* No prefix */
      main_binary = libexec_binary;
      args = GNUNET_strdup ("");
    }
    else
    {
      main_binary = prefix;
      args = libexec_binary;
    }
    sps->arm
      = GNUNET_OS_start_process_s (GNUNET_OS_INHERIT_STD_OUT_AND_ERR,
                                   NULL,
                                   main_binary,
                                   args,
                                   "-c",
                                   config_filename,
                                   NULL);
    if (NULL == sps->arm)
    {
      GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
                  _ ("Failed to start `%s': %s\n"),
                  main_binary,
                  strerror (errno));
      GNUNET_TESTING_FAIL (is);
    }
    GNUNET_free (config_filename);
    GNUNET_free (main_binary);
    GNUNET_free (args);
  }
 
  sps->ah = GNUNET_ARM_connect (sps->cfg,
                                &conn_status,
                                sps);
  if (NULL == sps->ah)
    GNUNET_TESTING_FAIL (is);
}

References _, GNUNET_TESTING_StartPeerState::ah, consensus-simulation::args, GNUNET_TESTING_StartPeerState::arm, GNUNET_TESTING_StartPeerState::cfg, GNUNET_TESTING_StartPeerState::cfgname, conn_status(), GNUNET_ARM_connect(), GNUNET_assert, GNUNET_CONFIGURATION_create(), GNUNET_CONFIGURATION_get_value_filename(), GNUNET_CONFIGURATION_get_value_string(), GNUNET_CONFIGURATION_load(), GNUNET_CONFIGURATION_write(), GNUNET_DISK_file_test(), GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_log, GNUNET_NO, GNUNET_OK, GNUNET_OS_get_libexec_binary_path(), GNUNET_OS_INHERIT_STD_OUT_AND_ERR, GNUNET_OS_project_data_gnunet(), GNUNET_OS_start_process_s(), GNUNET_strdup, GNUNET_SYSERR, GNUNET_TESTBED_configuration_create(), GNUNET_TESTING_FAIL, GNUNET_TESTING_interpreter_lookup_command(), GNUNET_TESTING_TESTBED_get_trait_test_system(), is, GNUNET_TESTING_StartPeerState::is, prefix, ret, GNUNET_TESTING_StartPeerState::system, and GNUNET_TESTING_StartPeerState::system_label.

Referenced by GNUNET_TESTING_ARM_cmd_start_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

start_peer_cleanup()

static void start_peer_cleanup ( void *  cls )

static

The cleanup function of this cmd frees resources the cmd allocated.

Definition at line 227 of file testing_arm_cmd_start_peer.c.

{
  struct GNUNET_TESTING_StartPeerState *sps = cls;
 
  if (NULL != sps->ah)
  {
    GNUNET_ARM_disconnect (sps->ah);
    sps->ah = NULL;
  }
  if (NULL != sps->arm)
  {
    GNUNET_break (0 ==
                  GNUNET_OS_process_kill (sps->arm,
                                          SIGTERM));
    GNUNET_break (GNUNET_OK ==
                  GNUNET_OS_process_wait (sps->arm));
    GNUNET_OS_process_destroy (sps->arm);
    sps->ah = NULL;
  }
 
  if (NULL != sps->cfg)
  {
    GNUNET_CONFIGURATION_destroy (sps->cfg);
    sps->cfg = NULL;
  }
  GNUNET_free (sps);
}

References GNUNET_TESTING_StartPeerState::ah, GNUNET_TESTING_StartPeerState::arm, GNUNET_TESTING_StartPeerState::cfg, GNUNET_ARM_disconnect(), GNUNET_break, GNUNET_CONFIGURATION_destroy(), GNUNET_free, GNUNET_OK, GNUNET_OS_process_destroy(), GNUNET_OS_process_kill(), and GNUNET_OS_process_wait().

Referenced by GNUNET_TESTING_ARM_cmd_start_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

start_peer_traits()

static enum GNUNET_GenericReturnValue start_peer_traits ( void *  cls, const void **  ret, const char *  trait, unsigned int  index  )

static

This function prepares an array with traits.

Definition at line 261 of file testing_arm_cmd_start_peer.c.

{
  struct GNUNET_TESTING_StartPeerState *sps = cls;
  struct GNUNET_TESTING_Trait traits[] = {
    GNUNET_TESTING_make_trait_process (
      &sps->arm),
    GNUNET_TESTING_ARM_make_trait_config (
      sps->cfg),
    GNUNET_TESTING_ARM_make_trait_arm_handle (
      sps->ah),
    GNUNET_TESTING_trait_end ()
  };
 
  return GNUNET_TESTING_get_trait (traits,
                                   ret,
                                   trait,
                                   index);
}

References GNUNET_TESTING_StartPeerState::ah, GNUNET_TESTING_StartPeerState::arm, GNUNET_TESTING_StartPeerState::cfg, GNUNET_TESTING_get_trait(), GNUNET_TESTING_make_trait_process(), GNUNET_TESTING_trait_end(), GNUNET_TESTING_Trait::index, ret, and traits().

Referenced by GNUNET_TESTING_ARM_cmd_start_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_ARM_cmd_start_peer()

struct GNUNET_TESTING_Command GNUNET_TESTING_ARM_cmd_start_peer	(	const char *	label,
		const char *	system_label,
		const char *	cfgname
	)

Create command.

Parameters

label	name for command.
system_label	Label of the cmd to setup a test environment.
cfgname	Configuration file name for this peer.

Returns

command.

Definition at line 285 of file testing_arm_cmd_start_peer.c.

{
  struct GNUNET_TESTING_StartPeerState *sps;
 
  sps = GNUNET_new (struct GNUNET_TESTING_StartPeerState);
  sps->system_label = GNUNET_strdup (system_label);
  sps->cfgname = cfgname;
  return GNUNET_TESTING_command_new_ac (sps,
                                        label,
                                        &start_peer_run,
                                        &start_peer_cleanup,
                                        &start_peer_traits,
                                        &sps->ac);
}

References GNUNET_TESTING_StartPeerState::ac, GNUNET_TESTING_StartPeerState::cfgname, GNUNET_new, GNUNET_strdup, GNUNET_TESTING_command_new_ac(), start_peer_cleanup(), start_peer_run(), start_peer_traits(), and GNUNET_TESTING_StartPeerState::system_label.

Here is the call graph for this function: