testbed_api_peers.c File Reference

management of the knowledge about peers in this library (we know the peer ID, its host, pending operations, etc.) More...

#include "platform.h"
#include "testbed_api_peers.h"
#include "testbed_api.h"
#include "testbed.h"
#include "testbed_api_hosts.h"
#include "testbed_api_operations.h"

Include dependency graph for testbed_api_peers.c:

Go to the source code of this file.

Functions
void	GNUNET_TESTBED_peer_register_ (struct GNUNET_TESTBED_Peer *peer)
	Adds a peer to the peer list. More...
void	GNUNET_TESTBED_peer_deregister_ (struct GNUNET_TESTBED_Peer *peer)
	Removes a peer from the peer list. More...
void	GNUNET_TESTBED_cleanup_peers_ (void)
	Frees all peers. More...
static void	opstart_peer_create (void *cls)
	Function to call to start a peer_create type operation once all queues the operation is part of declare that the operation can be activated. More...
static void	oprelease_peer_create (void *cls)
	Callback which will be called when peer_create type operation is released. More...
static void	opstart_peer_destroy (void *cls)
	Function called when a peer destroy operation is ready. More...
static void	oprelease_peer_destroy (void *cls)
	Callback which will be called when peer_create type operation is released. More...
static void	opstart_peer_start (void *cls)
	Function called when a peer start operation is ready. More...
static void	oprelease_peer_start (void *cls)
	Callback which will be called when peer start type operation is released. More...
static void	opstart_peer_stop (void *cls)
	Function called when a peer stop operation is ready. More...
static void	oprelease_peer_stop (void *cls)
	Callback which will be called when peer stop type operation is released. More...
struct GNUNET_TESTBED_PeerGetConfigurationMessage *	GNUNET_TESTBED_generate_peergetconfig_msg_ (uint32_t peer_id, uint64_t operation_id)
	Generate PeerGetConfigurationMessage. More...
static void	opstart_peer_getinfo (void *cls)
	Function called when a peer get information operation is ready. More...
static void	oprelease_peer_getinfo (void *cls)
	Callback which will be called when peer stop type operation is released. More...
static void	opstart_overlay_connect (void *cls)
	Function called when a overlay connect operation is ready. More...
static void	oprelease_overlay_connect (void *cls)
	Callback which will be called when overlay connect operation is released. More...
static void	opstart_peer_reconfigure (void *cls)
	Function called when a peer reconfigure operation is ready. More...
static void	oprelease_peer_reconfigure (void *cls)
	Callback which will be called when a peer reconfigure operation is released. More...
struct GNUNET_TESTBED_Peer *	GNUNET_TESTBED_peer_lookup_by_id_ (uint32_t id)
	Lookup a peer by ID. More...
struct GNUNET_TESTBED_Operation *	GNUNET_TESTBED_peer_create (struct GNUNET_TESTBED_Controller *controller, struct GNUNET_TESTBED_Host *host, const struct GNUNET_CONFIGURATION_Handle *cfg, GNUNET_TESTBED_PeerCreateCallback cb, void *cls)
	Create the given peer at the specified host using the given controller. More...
struct GNUNET_TESTBED_Operation *	GNUNET_TESTBED_peer_start (void *op_cls, struct GNUNET_TESTBED_Peer *peer, GNUNET_TESTBED_PeerChurnCallback pcc, void *pcc_cls)
	Start the given peer. More...
struct GNUNET_TESTBED_Operation *	GNUNET_TESTBED_peer_stop (void *op_cls, struct GNUNET_TESTBED_Peer *peer, GNUNET_TESTBED_PeerChurnCallback pcc, void *pcc_cls)
	Stop the given peer. More...
struct GNUNET_TESTBED_Operation *	GNUNET_TESTBED_peer_get_information (struct GNUNET_TESTBED_Peer *peer, enum GNUNET_TESTBED_PeerInformationType pit, GNUNET_TESTBED_PeerInfoCallback cb, void *cb_cls)
	Request information about a peer. More...
struct GNUNET_TESTBED_Operation *	GNUNET_TESTBED_peer_update_configuration (struct GNUNET_TESTBED_Peer *peer, const struct GNUNET_CONFIGURATION_Handle *cfg)
	Change peer configuration. More...
struct GNUNET_TESTBED_Operation *	GNUNET_TESTBED_peer_destroy (struct GNUNET_TESTBED_Peer *peer)
	Destroy the given peer; the peer should have been stopped first (if it was started). More...
struct GNUNET_TESTBED_Operation *	GNUNET_TESTBED_underlay_configure_link (void *op_cls, struct GNUNET_TESTBED_Peer *p1, struct GNUNET_TESTBED_Peer *p2, enum GNUNET_TESTBED_ConnectOption co,...)
	Manipulate the P2P underlay topology by configuring a link between two peers. More...
struct GNUNET_TESTBED_Operation *	GNUNET_TESTBED_overlay_connect (void *op_cls, GNUNET_TESTBED_OperationCompletionCallback cb, void *cb_cls, struct GNUNET_TESTBED_Peer *p1, struct GNUNET_TESTBED_Peer *p2)
	Both peers must have been started before calling this function. More...
static void	opstart_manage_service (void *cls)
	Function called when a peer manage service operation is ready. More...
static void	oprelease_manage_service (void *cls)
	Callback which will be called when peer manage server operation is released. More...
struct GNUNET_TESTBED_Operation *	GNUNET_TESTBED_peer_manage_service (void *op_cls, struct GNUNET_TESTBED_Peer *peer, const char *service_name, GNUNET_TESTBED_OperationCompletionCallback cb, void *cb_cls, unsigned int start)
	Start or stop given service at a peer. More...

Variables
static struct GNUNET_TESTBED_Peer *	peer_list_head
	Peer list DLL head. More...
static struct GNUNET_TESTBED_Peer *	peer_list_tail
	Peer list DLL tail. More...

Detailed Description

management of the knowledge about peers in this library (we know the peer ID, its host, pending operations, etc.)

Author

Christian Grothoff

Sree Harsha Totakura

Definition in file testbed_api_peers.c.

Function Documentation

GNUNET_TESTBED_peer_register_()

void GNUNET_TESTBED_peer_register_

(

struct GNUNET_TESTBED_Peer *

peer

)

Adds a peer to the peer list.

Parameters

peer	the peer to add to the peer list

Definition at line 54 of file testbed_api_peers.c.

{
  GNUNET_CONTAINER_DLL_insert_tail (peer_list_head, peer_list_tail, peer);
}

References GNUNET_CONTAINER_DLL_insert_tail, peer, peer_list_head, and peer_list_tail.

Referenced by handle_peer_create_success().

Here is the caller graph for this function:

GNUNET_TESTBED_peer_deregister_()

void GNUNET_TESTBED_peer_deregister_

(

struct GNUNET_TESTBED_Peer *

peer

)

Removes a peer from the peer list.

Parameters

peer	the peer to remove

Definition at line 66 of file testbed_api_peers.c.

{
  GNUNET_CONTAINER_DLL_remove (peer_list_head, peer_list_tail, peer);
}

References GNUNET_CONTAINER_DLL_remove, peer, peer_list_head, and peer_list_tail.

Referenced by GNUNET_TESTBED_cleanup_peers_(), and handle_opsuccess().

Here is the caller graph for this function:

GNUNET_TESTBED_cleanup_peers_()

void GNUNET_TESTBED_cleanup_peers_

(

void

)

Frees all peers.

Definition at line 76 of file testbed_api_peers.c.

{
  struct GNUNET_TESTBED_Peer *peer;
 
  while (NULL != (peer = peer_list_head))
  {
    GNUNET_TESTBED_peer_deregister_ (peer);
    GNUNET_free (peer);
  }
}

References GNUNET_free, GNUNET_TESTBED_peer_deregister_(), peer, and peer_list_head.

Referenced by handle_opsuccess().

Here is the call graph for this function:

Here is the caller graph for this function:

opstart_peer_create()

static void opstart_peer_create ( void *  cls )

static

Function to call to start a peer_create type operation once all queues the operation is part of declare that the operation can be activated.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 96 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct PeerCreateData *data = opc->data;
  struct GNUNET_TESTBED_PeerCreateMessage *msg;
  struct GNUNET_MQ_Envelope *env;
  char *config;
  char *xconfig;
  size_t c_size;
  size_t xc_size;
 
  GNUNET_assert (OP_PEER_CREATE == opc->type);
  GNUNET_assert (NULL != data);
  GNUNET_assert (NULL != data->peer);
  opc->state = OPC_STATE_STARTED;
  config = GNUNET_CONFIGURATION_serialize (data->cfg,
                                           &c_size);
  xc_size = GNUNET_TESTBED_compress_config_ (config,
                                             c_size,
                                             &xconfig);
  GNUNET_free (config);
  env = GNUNET_MQ_msg_extra (msg,
                             xc_size,
                             GNUNET_MESSAGE_TYPE_TESTBED_CREATE_PEER);
  msg->operation_id = GNUNET_htonll (opc->id);
  msg->host_id = htonl (GNUNET_TESTBED_host_get_id_ (data->peer->host));
  msg->peer_id = htonl (data->peer->unique_id);
  msg->config_size = htons ((uint16_t) c_size);
  GNUNET_memcpy (&msg[1],
                 xconfig,
                 xc_size);
  GNUNET_MQ_send (opc->c->mq,
                  env);
  GNUNET_free (xconfig);
  GNUNET_TESTBED_insert_opc_ (opc->c, opc);
}

References OperationContext::c, config, OperationContext::data, data, env, GNUNET_assert, GNUNET_CONFIGURATION_serialize(), GNUNET_free, GNUNET_htonll(), GNUNET_memcpy, GNUNET_MESSAGE_TYPE_TESTBED_CREATE_PEER, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_TESTBED_compress_config_(), GNUNET_TESTBED_host_get_id_(), GNUNET_TESTBED_insert_opc_(), OperationContext::id, GNUNET_TESTBED_Controller::mq, msg, OP_PEER_CREATE, OPC_STATE_STARTED, OperationContext::state, and OperationContext::type.

Referenced by GNUNET_TESTBED_peer_create().

Here is the call graph for this function:

Here is the caller graph for this function:

oprelease_peer_create()

static void oprelease_peer_create ( void *  cls )

static

Callback which will be called when peer_create type operation is released.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 140 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
 
  switch (opc->state)
  {
  case OPC_STATE_STARTED:
    GNUNET_TESTBED_remove_opc_ (opc->c, opc);
 
  /* No break we continue flow */
  case OPC_STATE_INIT:
    GNUNET_free (((struct PeerCreateData *) opc->data)->peer);
    GNUNET_free (opc->data);
    break;
 
  case OPC_STATE_FINISHED:
    break;
  }
  GNUNET_free (opc);
}

References OperationContext::c, OperationContext::data, GNUNET_free, GNUNET_TESTBED_remove_opc_(), OPC_STATE_FINISHED, OPC_STATE_INIT, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_peer_create().

Here is the call graph for this function:

Here is the caller graph for this function:

opstart_peer_destroy()

static void opstart_peer_destroy ( void *  cls )

static

Function called when a peer destroy operation is ready.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 168 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct GNUNET_TESTBED_Peer *peer = opc->data;
  struct GNUNET_TESTBED_PeerDestroyMessage *msg;
  struct GNUNET_MQ_Envelope *env;
 
  GNUNET_assert (OP_PEER_DESTROY == opc->type);
  GNUNET_assert (NULL != peer);
  opc->state = OPC_STATE_STARTED;
  env = GNUNET_MQ_msg (msg,
                       GNUNET_MESSAGE_TYPE_TESTBED_DESTROY_PEER);
  msg->peer_id = htonl (peer->unique_id);
  msg->operation_id = GNUNET_htonll (opc->id);
  GNUNET_TESTBED_insert_opc_ (opc->c, opc);
  GNUNET_MQ_send (peer->controller->mq,
                  env);
}

References OperationContext::c, GNUNET_TESTBED_Peer::controller, OperationContext::data, env, GNUNET_assert, GNUNET_htonll(), GNUNET_MESSAGE_TYPE_TESTBED_DESTROY_PEER, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_TESTBED_insert_opc_(), OperationContext::id, GNUNET_TESTBED_Controller::mq, msg, OP_PEER_DESTROY, OPC_STATE_STARTED, peer, OperationContext::state, OperationContext::type, and GNUNET_TESTBED_Peer::unique_id.

Referenced by GNUNET_TESTBED_peer_destroy().

Here is the call graph for this function:

Here is the caller graph for this function:

oprelease_peer_destroy()

static void oprelease_peer_destroy ( void *  cls )

static

Callback which will be called when peer_create type operation is released.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 194 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
 
  switch (opc->state)
  {
  case OPC_STATE_STARTED:
    GNUNET_TESTBED_remove_opc_ (opc->c, opc);
 
  /* no break; continue */
  case OPC_STATE_INIT:
    break;
 
  case OPC_STATE_FINISHED:
    break;
  }
  GNUNET_free (opc);
}

References OperationContext::c, GNUNET_free, GNUNET_TESTBED_remove_opc_(), OPC_STATE_FINISHED, OPC_STATE_INIT, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_peer_destroy().

Here is the call graph for this function:

Here is the caller graph for this function:

opstart_peer_start()

static void opstart_peer_start ( void *  cls )

static

Function called when a peer start operation is ready.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 220 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct GNUNET_TESTBED_PeerStartMessage *msg;
  struct GNUNET_MQ_Envelope *env;
  struct PeerEventData *data;
  struct GNUNET_TESTBED_Peer *peer;
 
  GNUNET_assert (OP_PEER_START == opc->type);
  GNUNET_assert (NULL != (data = opc->data));
  GNUNET_assert (NULL != (peer = data->peer));
  GNUNET_assert ((TESTBED_PS_CREATED == peer->state) || (TESTBED_PS_STOPPED ==
                                                         peer->state));
  opc->state = OPC_STATE_STARTED;
  env = GNUNET_MQ_msg (msg,
                       GNUNET_MESSAGE_TYPE_TESTBED_START_PEER);
  msg->peer_id = htonl (peer->unique_id);
  msg->operation_id = GNUNET_htonll (opc->id);
  GNUNET_TESTBED_insert_opc_ (opc->c, opc);
  GNUNET_MQ_send (peer->controller->mq,
                  env);
}

References OperationContext::c, GNUNET_TESTBED_Peer::controller, OperationContext::data, data, env, GNUNET_assert, GNUNET_htonll(), GNUNET_MESSAGE_TYPE_TESTBED_START_PEER, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_TESTBED_insert_opc_(), OperationContext::id, GNUNET_TESTBED_Controller::mq, msg, OP_PEER_START, OPC_STATE_STARTED, peer, OperationContext::state, GNUNET_TESTBED_Peer::state, TESTBED_PS_CREATED, TESTBED_PS_STOPPED, OperationContext::type, and GNUNET_TESTBED_Peer::unique_id.

Referenced by GNUNET_TESTBED_peer_start().

Here is the call graph for this function:

Here is the caller graph for this function:

oprelease_peer_start()

static void oprelease_peer_start ( void *  cls )

static

Callback which will be called when peer start type operation is released.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 250 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
 
  switch (opc->state)
  {
  case OPC_STATE_STARTED:
    GNUNET_TESTBED_remove_opc_ (opc->c, opc);
 
  /* no break; continue */
  case OPC_STATE_INIT:
    GNUNET_free (opc->data);
    break;
 
  case OPC_STATE_FINISHED:
    break;
  }
  GNUNET_free (opc);
}

References OperationContext::c, OperationContext::data, GNUNET_free, GNUNET_TESTBED_remove_opc_(), OPC_STATE_FINISHED, OPC_STATE_INIT, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_peer_start().

Here is the call graph for this function:

Here is the caller graph for this function:

opstart_peer_stop()

static void opstart_peer_stop ( void *  cls )

static

Function called when a peer stop operation is ready.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 277 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct GNUNET_TESTBED_PeerStopMessage *msg;
  struct PeerEventData *data;
  struct GNUNET_TESTBED_Peer *peer;
  struct GNUNET_MQ_Envelope *env;
 
  GNUNET_assert (NULL != (data = opc->data));
  GNUNET_assert (NULL != (peer = data->peer));
  GNUNET_assert (TESTBED_PS_STARTED == peer->state);
  opc->state = OPC_STATE_STARTED;
  env = GNUNET_MQ_msg (msg,
                       GNUNET_MESSAGE_TYPE_TESTBED_STOP_PEER);
  msg->peer_id = htonl (peer->unique_id);
  msg->operation_id = GNUNET_htonll (opc->id);
  GNUNET_TESTBED_insert_opc_ (opc->c, opc);
  GNUNET_MQ_send (peer->controller->mq,
                  env);
}

References OperationContext::c, GNUNET_TESTBED_Peer::controller, OperationContext::data, data, env, GNUNET_assert, GNUNET_htonll(), GNUNET_MESSAGE_TYPE_TESTBED_STOP_PEER, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_TESTBED_insert_opc_(), OperationContext::id, GNUNET_TESTBED_Controller::mq, msg, OPC_STATE_STARTED, peer, OperationContext::state, GNUNET_TESTBED_Peer::state, TESTBED_PS_STARTED, and GNUNET_TESTBED_Peer::unique_id.

Referenced by GNUNET_TESTBED_peer_stop().

Here is the call graph for this function:

Here is the caller graph for this function:

oprelease_peer_stop()

static void oprelease_peer_stop ( void *  cls )

static

Callback which will be called when peer stop type operation is released.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 305 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
 
  switch (opc->state)
  {
  case OPC_STATE_STARTED:
    GNUNET_TESTBED_remove_opc_ (opc->c, opc);
 
  /* no break; continue */
  case OPC_STATE_INIT:
    GNUNET_free (opc->data);
    break;
 
  case OPC_STATE_FINISHED:
    break;
  }
  GNUNET_free (opc);
}

References OperationContext::c, OperationContext::data, GNUNET_free, GNUNET_TESTBED_remove_opc_(), OPC_STATE_FINISHED, OPC_STATE_INIT, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_peer_stop().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTBED_generate_peergetconfig_msg_()

struct GNUNET_TESTBED_PeerGetConfigurationMessage* GNUNET_TESTBED_generate_peergetconfig_msg_	(	uint32_t	peer_id,
		uint64_t	operation_id
	)

Generate PeerGetConfigurationMessage.

Parameters

peer_id	the id of the peer whose information we have to get
operation_id	the ip of the operation that should be represented in the message

Returns

the PeerGetConfigurationMessage

Definition at line 335 of file testbed_api_peers.c.

{
  struct GNUNET_TESTBED_PeerGetConfigurationMessage *msg;
 
  msg =
    GNUNET_malloc (sizeof
                   (struct GNUNET_TESTBED_PeerGetConfigurationMessage));
  msg->header.size =
    htons (sizeof(struct GNUNET_TESTBED_PeerGetConfigurationMessage));
  msg->header.type = htons (GNUNET_MESSAGE_TYPE_TESTBED_GET_PEER_INFORMATION);
  msg->peer_id = htonl (peer_id);
  msg->operation_id = GNUNET_htonll (operation_id);
  return msg;
}

References GNUNET_htonll(), GNUNET_malloc, GNUNET_MESSAGE_TYPE_TESTBED_GET_PEER_INFORMATION, msg, GNUNET_TESTBED_PeerGetConfigurationMessage::operation_id, peer_id, GNUNET_MessageHeader::size, and GNUNET_MessageHeader::type.

Referenced by opstart_peer_getinfo(), and opstart_service_connect().

Here is the call graph for this function:

Here is the caller graph for this function:

opstart_peer_getinfo()

static void opstart_peer_getinfo ( void *  cls )

static

Function called when a peer get information operation is ready.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 358 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct PeerInfoData *data = opc->data;
  struct GNUNET_TESTBED_PeerGetConfigurationMessage *msg;
 
  GNUNET_assert (NULL != data);
  opc->state = OPC_STATE_STARTED;
  msg =
    GNUNET_TESTBED_generate_peergetconfig_msg_ (data->peer->unique_id,
                                                opc->id);
  GNUNET_TESTBED_insert_opc_ (opc->c, opc);
  GNUNET_TESTBED_queue_message_ (opc->c, &msg->header);
}

References OperationContext::c, OperationContext::data, data, GNUNET_assert, GNUNET_TESTBED_generate_peergetconfig_msg_(), GNUNET_TESTBED_insert_opc_(), GNUNET_TESTBED_queue_message_(), OperationContext::id, msg, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_peer_get_information().

Here is the call graph for this function:

Here is the caller graph for this function:

oprelease_peer_getinfo()

static void oprelease_peer_getinfo ( void *  cls )

static

Callback which will be called when peer stop type operation is released.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 380 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct GNUNET_TESTBED_PeerInformation *data;
 
  switch (opc->state)
  {
  case OPC_STATE_STARTED:
    GNUNET_TESTBED_remove_opc_ (opc->c, opc);
 
  /* no break; continue */
  case OPC_STATE_INIT:
    GNUNET_free (opc->data);
    break;
 
  case OPC_STATE_FINISHED:
    data = opc->data;
    GNUNET_assert (NULL != data);
    switch (data->pit)
    {
    case GNUNET_TESTBED_PIT_CONFIGURATION:
      if (NULL != data->result.cfg)
        GNUNET_CONFIGURATION_destroy (data->result.cfg);
      break;
 
    case GNUNET_TESTBED_PIT_IDENTITY:
      GNUNET_free (data->result.id);
      break;
 
    default:
      GNUNET_assert (0);        /* We should never reach here */
    }
    GNUNET_free (data);
    break;
  }
  GNUNET_free (opc);
}

References OperationContext::c, OperationContext::data, data, GNUNET_assert, GNUNET_CONFIGURATION_destroy(), GNUNET_free, GNUNET_TESTBED_PIT_CONFIGURATION, GNUNET_TESTBED_PIT_IDENTITY, GNUNET_TESTBED_remove_opc_(), OPC_STATE_FINISHED, OPC_STATE_INIT, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_peer_get_information().

Here is the call graph for this function:

Here is the caller graph for this function:

opstart_overlay_connect()

static void opstart_overlay_connect ( void *  cls )

static

Function called when a overlay connect operation is ready.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 425 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_TESTBED_OverlayConnectMessage *msg;
  struct OverlayConnectData *data;
 
  opc->state = OPC_STATE_STARTED;
  data = opc->data;
  GNUNET_assert (NULL != data);
  env = GNUNET_MQ_msg (msg,
                       GNUNET_MESSAGE_TYPE_TESTBED_OVERLAY_CONNECT);
  msg->peer1 = htonl (data->p1->unique_id);
  msg->peer2 = htonl (data->p2->unique_id);
  msg->operation_id = GNUNET_htonll (opc->id);
  msg->peer2_host_id = htonl (GNUNET_TESTBED_host_get_id_ (data->p2->host));
  GNUNET_TESTBED_insert_opc_ (opc->c,
                              opc);
  GNUNET_MQ_send (opc->c->mq,
                  env);
}

References OperationContext::c, OperationContext::data, data, env, GNUNET_assert, GNUNET_htonll(), GNUNET_MESSAGE_TYPE_TESTBED_OVERLAY_CONNECT, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_TESTBED_host_get_id_(), GNUNET_TESTBED_insert_opc_(), OperationContext::id, GNUNET_TESTBED_Controller::mq, msg, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_overlay_connect().

Here is the call graph for this function:

Here is the caller graph for this function:

oprelease_overlay_connect()

static void oprelease_overlay_connect ( void *  cls )

static

Callback which will be called when overlay connect operation is released.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 454 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct OverlayConnectData *data;
 
  data = opc->data;
  switch (opc->state)
  {
  case OPC_STATE_INIT:
    break;
 
  case OPC_STATE_STARTED:
    GNUNET_TESTBED_remove_opc_ (opc->c, opc);
    break;
 
  case OPC_STATE_FINISHED:
    break;
  }
  GNUNET_free (data);
  GNUNET_free (opc);
}

References OperationContext::c, OperationContext::data, data, GNUNET_free, GNUNET_TESTBED_remove_opc_(), OPC_STATE_FINISHED, OPC_STATE_INIT, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_overlay_connect().

Here is the call graph for this function:

Here is the caller graph for this function:

opstart_peer_reconfigure()

static void opstart_peer_reconfigure ( void *  cls )

static

Function called when a peer reconfigure operation is ready.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 483 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct PeerReconfigureData *data = opc->data;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_TESTBED_PeerReconfigureMessage *msg;
  char *xconfig;
  size_t xc_size;
 
  opc->state = OPC_STATE_STARTED;
  GNUNET_assert (NULL != data);
  xc_size = GNUNET_TESTBED_compress_config_ (data->config,
                                             data->cfg_size,
                                             &xconfig);
  GNUNET_free (data->config);
  data->config = NULL;
  GNUNET_assert (xc_size < UINT16_MAX - sizeof(*msg));
  env = GNUNET_MQ_msg_extra (msg,
                             xc_size,
                             GNUNET_MESSAGE_TYPE_TESTBED_RECONFIGURE_PEER);
  msg->peer_id = htonl (data->peer->unique_id);
  msg->operation_id = GNUNET_htonll (opc->id);
  msg->config_size = htons (data->cfg_size);
  GNUNET_memcpy (&msg[1],
                 xconfig,
                 xc_size);
  GNUNET_free (xconfig);
  GNUNET_free (data);
  opc->data = NULL;
  GNUNET_TESTBED_insert_opc_ (opc->c, opc);
  GNUNET_MQ_send (opc->c->mq,
                  env);
}

References OperationContext::c, OperationContext::data, data, env, GNUNET_assert, GNUNET_free, GNUNET_htonll(), GNUNET_memcpy, GNUNET_MESSAGE_TYPE_TESTBED_RECONFIGURE_PEER, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_TESTBED_compress_config_(), GNUNET_TESTBED_insert_opc_(), OperationContext::id, GNUNET_TESTBED_Controller::mq, msg, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_peer_update_configuration().

Here is the call graph for this function:

Here is the caller graph for this function:

oprelease_peer_reconfigure()

static void oprelease_peer_reconfigure ( void *  cls )

static

Callback which will be called when a peer reconfigure operation is released.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 524 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct PeerReconfigureData *data = opc->data;
 
  switch (opc->state)
  {
  case OPC_STATE_INIT:
    GNUNET_free (data->config);
    GNUNET_free (data);
    break;
 
  case OPC_STATE_STARTED:
    GNUNET_TESTBED_remove_opc_ (opc->c, opc);
    break;
 
  case OPC_STATE_FINISHED:
    break;
  }
  GNUNET_free (opc);
}

References OperationContext::c, OperationContext::data, data, GNUNET_free, GNUNET_TESTBED_remove_opc_(), OPC_STATE_FINISHED, OPC_STATE_INIT, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_peer_update_configuration().

Here is the call graph for this function:

Here is the caller graph for this function:

GNUNET_TESTBED_peer_lookup_by_id_()

struct GNUNET_TESTBED_Peer* GNUNET_TESTBED_peer_lookup_by_id_

(

uint32_t

id

)

Lookup a peer by ID.

Parameters

id	global peer ID assigned to the peer

Returns

handle to the host, NULL on error

Definition at line 554 of file testbed_api_peers.c.

{
  GNUNET_break (0);
  return NULL;
}

References GNUNET_break.

opstart_manage_service()

static void opstart_manage_service ( void *  cls )

static

Function called when a peer manage service operation is ready.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 861 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct ManageServiceData *data = opc->data;
  struct GNUNET_MQ_Envelope *env;
  struct GNUNET_TESTBED_ManagePeerServiceMessage *msg;
  size_t xlen;
 
  GNUNET_assert (NULL != data);
  xlen = data->msize - sizeof(struct GNUNET_TESTBED_ManagePeerServiceMessage);
  env = GNUNET_MQ_msg_extra (msg,
                             xlen,
                             GNUNET_MESSAGE_TYPE_TESTBED_MANAGE_PEER_SERVICE);
  msg->peer_id = htonl (data->peer->unique_id);
  msg->operation_id = GNUNET_htonll (opc->id);
  msg->start = (uint8_t) data->start;
  GNUNET_memcpy (&msg[1],
                 data->service_name,
                 xlen);
  GNUNET_free (data->service_name);
  data->service_name = NULL;
  opc->state = OPC_STATE_STARTED;
  GNUNET_TESTBED_insert_opc_ (opc->c, opc);
  GNUNET_MQ_send (opc->c->mq,
                  env);
}

References OperationContext::c, OperationContext::data, data, env, GNUNET_assert, GNUNET_free, GNUNET_htonll(), GNUNET_memcpy, GNUNET_MESSAGE_TYPE_TESTBED_MANAGE_PEER_SERVICE, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_TESTBED_insert_opc_(), OperationContext::id, GNUNET_TESTBED_Controller::mq, msg, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_peer_manage_service().

Here is the call graph for this function:

Here is the caller graph for this function:

oprelease_manage_service()

static void oprelease_manage_service ( void *  cls )

static

Callback which will be called when peer manage server operation is released.

Parameters

cls	the closure from GNUNET_TESTBED_operation_create_()

Definition at line 895 of file testbed_api_peers.c.

{
  struct OperationContext *opc = cls;
  struct ManageServiceData *data;
 
  data = opc->data;
  switch (opc->state)
  {
  case OPC_STATE_STARTED:
    GNUNET_TESTBED_remove_opc_ (opc->c, opc);
    break;
 
  case OPC_STATE_INIT:
    GNUNET_assert (NULL != data);
    GNUNET_free (data->service_name);
    break;
 
  case OPC_STATE_FINISHED:
    break;
  }
  GNUNET_free (data);
  GNUNET_free (opc);
}

References OperationContext::c, OperationContext::data, data, GNUNET_assert, GNUNET_free, GNUNET_TESTBED_remove_opc_(), OPC_STATE_FINISHED, OPC_STATE_INIT, OPC_STATE_STARTED, and OperationContext::state.

Referenced by GNUNET_TESTBED_peer_manage_service().

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

peer_list_head

struct GNUNET_TESTBED_Peer* peer_list_head

static

Peer list DLL head.

Definition at line 40 of file testbed_api_peers.c.

Referenced by GNUNET_TESTBED_cleanup_peers_(), GNUNET_TESTBED_peer_deregister_(), and GNUNET_TESTBED_peer_register_().

peer_list_tail

struct GNUNET_TESTBED_Peer* peer_list_tail

static

Peer list DLL tail.

Definition at line 45 of file testbed_api_peers.c.

Referenced by GNUNET_TESTBED_peer_deregister_(), and GNUNET_TESTBED_peer_register_().