testing_api_loop.h File Reference

#include "testing_api_barrier.h"

Include dependency graph for testing_api_loop.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	GNUNET_TESTING_PluginFunctions
	The plugin API every test case plugin has to implement. More...

Typedefs
typedef void(*	GNUNET_TESTING_cmd_helper_write_cb) (const struct GNUNET_MessageHeader *message)
	Callback function to write messages from the helper process running on a netjail node to the master process. More...

Functions
void	GNUNET_TESTING_loop_notify_parent_ (struct GNUNET_TESTING_Interpreter *is, const struct GNUNET_MessageHeader *hdr)
	Send message to our parent. More...
void	GNUNET_TESTING_loop_notify_children_ (struct GNUNET_TESTING_Interpreter *is, const struct GNUNET_MessageHeader *hdr)
	Send message to all netjail children (if there are any). More...
void	GNUNET_TESTING_interpreter_next_ (void *cls)
	Current command is done, run the next one. More...
void	GNUNET_TESTING_interpreter_run_cmd_ (struct GNUNET_TESTING_Interpreter *is, struct GNUNET_TESTING_Command *cmd)
void	GNUNET_TESTING_add_netjail_helper_ (struct GNUNET_TESTING_Interpreter *is, struct GNUNET_HELPER_Handle *helper)
	Adding a helper handle to the interpreter. More...
void	GNUNET_TESTING_add_barrier_ (struct GNUNET_TESTING_Interpreter *is, struct GNUNET_TESTING_Barrier *barrier)
	Add a barrier to the interpreter to share it with all children as an inherited barrier. More...
struct GNUNET_TESTING_Barrier *	GNUNET_TESTING_get_barrier2_ (struct GNUNET_TESTING_Interpreter *is, const struct GNUNET_ShortHashCode *create_key)
struct GNUNET_TESTING_Barrier *	GNUNET_TESTING_get_barrier_ (struct GNUNET_TESTING_Interpreter *is, const char *barrier_name)
unsigned int	GNUNET_TESTING_barrier_count_ (struct GNUNET_TESTING_Interpreter *is)
void	GNUNET_TESTING_barrier_iterate_ (struct GNUNET_TESTING_Interpreter *is, GNUNET_CONTAINER_ShortmapIterator cb, void *cb_cls)

Detailed Description

Author

t3sserakt

Definition in file testing_api_loop.h.

Typedef Documentation

GNUNET_TESTING_cmd_helper_write_cb

typedef void(* GNUNET_TESTING_cmd_helper_write_cb) (const struct GNUNET_MessageHeader *message)

Callback function to write messages from the helper process running on a netjail node to the master process.

Parameters

message

The message to write.

Definition at line 37 of file testing_api_loop.h.

Function Documentation

GNUNET_TESTING_loop_notify_parent_()

void GNUNET_TESTING_loop_notify_parent_	(	struct GNUNET_TESTING_Interpreter *	is,
		const struct GNUNET_MessageHeader *	hdr
	)

Send message to our parent.

Fails very hard if we do not have one.

Parameters

is	The interpreter loop.

Definition at line 265 of file testing_api_loop.c.

{
  /* We must have a parent */
  if (NULL == is->parent_writer)
    GNUNET_TESTING_FAIL (is);
  is->parent_writer (hdr);
}

References GNUNET_TESTING_FAIL, is, and GNUNET_TESTING_Interpreter::parent_writer.

Referenced by barrier_reached_run(), and handle_helper_barrier_reached().

Here is the caller graph for this function:

GNUNET_TESTING_loop_notify_children_()

void GNUNET_TESTING_loop_notify_children_	(	struct GNUNET_TESTING_Interpreter *	is,
		const struct GNUNET_MessageHeader *	hdr
	)

Send message to all netjail children (if there are any).

Parameters

is	The interpreter loop.

Definition at line 239 of file testing_api_loop.c.

{
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Send notification to children of type %u\n",
              (unsigned int) ntohs (hdr->type));
  for (unsigned int i = 0; i<is->n_helpers; i++)
  {
    struct SendContext *sctx;
 
    sctx = GNUNET_new (struct SendContext);
    sctx->is = is;
    GNUNET_CONTAINER_DLL_insert (is->sender_head,
                                 is->sender_tail,
                                 sctx);
    sctx->send_handle
      = GNUNET_HELPER_send (is->helpers[i],
                            hdr,
                            false, /* never drop */
                            &send_finished,
                            sctx);
  }
}

References GNUNET_CONTAINER_DLL_insert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_HELPER_send(), GNUNET_log, GNUNET_new, GNUNET_TESTING_Interpreter::helpers, is, SendContext::is, GNUNET_TESTING_Interpreter::n_helpers, send_finished(), SendContext::send_handle, GNUNET_TESTING_Interpreter::sender_head, GNUNET_TESTING_Interpreter::sender_tail, and GNUNET_MessageHeader::type.

Referenced by barrier_reached_run(), handle_helper_barrier_crossable(), and handle_helper_barrier_reached().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_interpreter_next_()

void GNUNET_TESTING_interpreter_next_

(

void *

cls

)

Current command is done, run the next one.

Definition at line 351 of file testing_api_loop.c.

{
  static unsigned long long ipc;
  static struct GNUNET_TIME_Absolute last_report;
  struct GNUNET_TESTING_Interpreter *is = cls;
  struct GNUNET_TESTING_Command *cmd = &is->commands[is->ip];
 
  if (GNUNET_SYSERR == is->result)
    return; /* ignore, we already failed! */
 
  if (GNUNET_TESTING_cmd_is_batch_ (cmd))
  {
    if (GNUNET_TESTING_cmd_batch_next_ (cmd->cls))
    {
      /* batch is done */
      cmd->finish_time = GNUNET_TIME_absolute_get ();
      is->ip++;
    }
  }
  else
  {
    cmd->finish_time = GNUNET_TIME_absolute_get ();
    is->ip++;
  }
 
  if (0 == (ipc % 1000))
  {
    if (0 != ipc)
      GNUNET_log (GNUNET_ERROR_TYPE_MESSAGE,
                  "Interpreter executed 1000 instructions in %s\n",
                  GNUNET_STRINGS_relative_time_to_string (
                    GNUNET_TIME_absolute_get_duration (last_report),
                    true));
    last_report = GNUNET_TIME_absolute_get ();
  }
  ipc++;
  is->task = GNUNET_SCHEDULER_add_now (&interpreter_run,
                                       is);
}

References GNUNET_TESTING_Command::cls, GNUNET_TESTING_Interpreter::commands, GNUNET_TESTING_Command::finish_time, GNUNET_ERROR_TYPE_MESSAGE, GNUNET_log, GNUNET_SCHEDULER_add_now(), GNUNET_STRINGS_relative_time_to_string(), GNUNET_SYSERR, GNUNET_TESTING_cmd_batch_next_(), GNUNET_TESTING_cmd_is_batch_(), GNUNET_TIME_absolute_get(), GNUNET_TIME_absolute_get_duration(), interpreter_run(), GNUNET_TESTING_Interpreter::ip, is, GNUNET_TESTING_Interpreter::result, and GNUNET_TESTING_Interpreter::task.

Referenced by batch_run(), GNUNET_TESTING_async_finish(), and GNUNET_TESTING_interpreter_run_cmd_().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_interpreter_run_cmd_()

void GNUNET_TESTING_interpreter_run_cmd_	(	struct GNUNET_TESTING_Interpreter *	is,
		struct GNUNET_TESTING_Command *	cmd
	)

Definition at line 393 of file testing_api_loop.c.

{
  cmd->last_req_time
    = GNUNET_TIME_absolute_get ();
  if (0 == cmd->num_tries)
    cmd->start_time = cmd->last_req_time;
  cmd->num_tries = 1;
  if (NULL != cmd->name)
  {
    struct GNUNET_HashCode h_name = {0};
 
    GNUNET_CRYPTO_hash (cmd->name,
                        strlen (cmd->name),
                        &h_name);
    (void) GNUNET_CONTAINER_multihashmap_put (
      is->vars,
      &h_name,
      cmd,
      GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE);
  }
  if (NULL != cmd->ac)
  {
    cmd->ac->is = is;
    cmd->ac->finished = GNUNET_NO;
    cmd->ac->next_called = false;
  }
  cmd->run (cmd->cls,
            is);
  if ( (! GNUNET_TESTING_cmd_is_batch_ (cmd)) &&
       ( (NULL == cmd->ac) ||
         (cmd->asynchronous_finish) ) )
  {
    if (NULL != cmd->ac)
      cmd->ac->next_called = true;
    GNUNET_TESTING_interpreter_next_ (is);
  }
}

References GNUNET_TESTING_Command::ac, GNUNET_TESTING_Command::asynchronous_finish, GNUNET_TESTING_Command::cls, GNUNET_TESTING_AsyncContext::finished, GNUNET_CONTAINER_multihashmap_put(), GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE, GNUNET_CRYPTO_hash(), GNUNET_NO, GNUNET_TESTING_cmd_is_batch_(), GNUNET_TESTING_interpreter_next_(), GNUNET_TIME_absolute_get(), GNUNET_TESTING_AsyncContext::is, is, GNUNET_TESTING_Command::last_req_time, GNUNET_TESTING_Command::name, GNUNET_TESTING_AsyncContext::next_called, GNUNET_TESTING_Command::num_tries, GNUNET_TESTING_Command::run, GNUNET_TESTING_Command::start_time, and GNUNET_TESTING_Interpreter::vars.

Referenced by batch_run(), and interpreter_run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_add_netjail_helper_()

void GNUNET_TESTING_add_netjail_helper_	(	struct GNUNET_TESTING_Interpreter *	is,
		struct GNUNET_HELPER_Handle *	helper
	)

Adding a helper handle to the interpreter.

Parameters

is	The interpreter.
helper	The helper handle.

Definition at line 701 of file testing_api_loop.c.

{
  GNUNET_array_append (is->helpers,
                       is->n_helpers,
                       helper);
}

References GNUNET_array_append, GNUNET_TESTING_Interpreter::helpers, is, and GNUNET_TESTING_Interpreter::n_helpers.

Referenced by start_helper().

Here is the caller graph for this function:

GNUNET_TESTING_add_barrier_()

void GNUNET_TESTING_add_barrier_	(	struct GNUNET_TESTING_Interpreter *	is,
		struct GNUNET_TESTING_Barrier *	barrier
	)

Add a barrier to the interpreter to share it with all children as an inherited barrier.

Parameters

is	The interpreter.
barrier	The barrier to add.

Definition at line 735 of file testing_api_loop.c.

{
  if (NULL == is->barriers)
    is->barriers
      = GNUNET_CONTAINER_multishortmap_create (1,
                                               true);
  /* We always use the barrier we encountered
     most recently under a given label, thus replace */
  (void) GNUNET_CONTAINER_multishortmap_put (
    is->barriers,
    &barrier->barrier_id,
    barrier,
    GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE);
}

References GNUNET_TESTING_Barrier::barrier_id, GNUNET_TESTING_Interpreter::barriers, GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE, GNUNET_CONTAINER_multishortmap_create(), GNUNET_CONTAINER_multishortmap_put(), and is.

Referenced by barrier_run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_get_barrier2_()

struct GNUNET_TESTING_Barrier * GNUNET_TESTING_get_barrier2_	(	struct GNUNET_TESTING_Interpreter *	is,
		const struct GNUNET_ShortHashCode *	create_key
	)

Definition at line 711 of file testing_api_loop.c.

{
  return GNUNET_CONTAINER_multishortmap_get (is->barriers,
                                             create_key);
}

References GNUNET_TESTING_Interpreter::barriers, GNUNET_CONTAINER_multishortmap_get(), and is.

Referenced by GNUNET_TESTING_get_barrier_(), handle_helper_barrier_crossable(), and handle_helper_barrier_reached().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_get_barrier_()

struct GNUNET_TESTING_Barrier * GNUNET_TESTING_get_barrier_	(	struct GNUNET_TESTING_Interpreter *	is,
		const char *	barrier_name
	)

Definition at line 720 of file testing_api_loop.c.

{
  struct GNUNET_ShortHashCode create_key;
 
  if (NULL == is->barriers)
    return NULL;
  GNUNET_TESTING_barrier_name_hash_ (barrier_name,
                                     &create_key);
  return GNUNET_TESTING_get_barrier2_ (is,
                                       &create_key);
}

References GNUNET_TESTING_Interpreter::barriers, GNUNET_TESTING_barrier_name_hash_(), GNUNET_TESTING_get_barrier2_(), and is.

Referenced by barrier_reached_run().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_barrier_count_()

unsigned int GNUNET_TESTING_barrier_count_

(

struct GNUNET_TESTING_Interpreter *

is

)

Definition at line 753 of file testing_api_loop.c.

{
  return NULL != is->barriers ? GNUNET_CONTAINER_multishortmap_size (is->barriers) : 0;
}

References GNUNET_TESTING_Interpreter::barriers, GNUNET_CONTAINER_multishortmap_size(), and is.

Referenced by send_start_messages().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTING_barrier_iterate_()

void GNUNET_TESTING_barrier_iterate_	(	struct GNUNET_TESTING_Interpreter *	is,
		GNUNET_CONTAINER_ShortmapIterator	cb,
		void *	cb_cls
	)

Definition at line 761 of file testing_api_loop.c.

{
  if (NULL != is->barriers)
    GNUNET_CONTAINER_multishortmap_iterate (is->barriers,
                                          cb,
                                          cb_cls);
}

References GNUNET_TESTING_Interpreter::barriers, GNUNET_CONTAINER_multishortmap_iterate(), and is.

Referenced by send_start_messages().

Here is the call graph for this function:

Here is the caller graph for this function: