data structures shared amongst components of TESTBED service More...
#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_testbed_service.h"
#include "gnunet_transport_service.h"
#include "gnunet_core_service.h"
#include "testbed.h"
#include "testbed_api.h"
#include "testbed_api_operations.h"
#include "testbed_api_hosts.h"
#include "gnunet_testing_lib.h"
#include "gnunet-service-testbed_links.h"
Go to the source code of this file.
Data Structures | |
struct | Route |
A routing entry. More... | |
struct | ForwardedOperationContext |
Context information for operations forwarded to subcontrollers. More... | |
struct | HostRegistration |
A DLL of host registrations to be made. More... | |
struct | LinkControllersContext |
Context information used while linking controllers. More... | |
struct | Peer |
A peer. More... | |
struct | Context |
Context to hold data of peer. More... | |
struct | SharedService |
The structure for identifying a shared service. More... | |
struct | ForwardedOverlayConnectContext |
Context information to used during operations which forward the overlay connect message. More... | |
struct | RegisteredHostContext |
This context information will be created for each host that is registered at slave controllers during overlay connects. More... | |
struct | HandlerContext_ShutdownPeers |
Context data for GNUNET_MESSAGE_TYPE_TESTBED_SHUTDOWN_PEERS handler. More... | |
Macros | |
#define | LOG(kind, ...) GNUNET_log (kind, __VA_ARGS__) |
Generic logging. More... | |
#define | LOG_DEBUG(...) LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__) |
Debug logging. More... | |
#define | LIST_GROW_STEP 10 |
By how much should the arrays lists grow. More... | |
#define | VALID_HOST_ID(id) (((id) < GST_host_list_size) && (NULL != GST_host_list[id])) |
Condition to check if host id is valid. More... | |
#define | VALID_PEER_ID(id) (((id) < GST_peer_list_size) && (NULL != GST_peer_list[id])) |
Condition to check if peer id is valid. More... | |
#define | GST_array_grow_large_enough(ptr, size, accommodate_size) |
Similar to GNUNET_array_grow(); however instead of calling GNUNET_array_grow() several times we call it only once. More... | |
Functions | |
void | GST_destroy_peer (struct Peer *peer) |
Function to destroy a peer. More... | |
void | GST_destroy_peers (void) |
Stops and destroys all peers. More... | |
struct Route * | GST_find_dest_route (uint32_t host_id) |
Finds the route with directly connected host as destination through which the destination host can be reached. More... | |
void | handle_overlay_connect (void *cls, const struct GNUNET_TESTBED_OverlayConnectMessage *msg) |
Handler for GNUNET_MESSAGE_TYPE_TESTBED_OVERLAY_CONNECT messages. More... | |
void | GST_queue_host_registration (struct Slave *slave, GNUNET_TESTBED_HostRegistrationCompletion cb, void *cb_cls, struct GNUNET_TESTBED_Host *host) |
Adds a host registration's request to a slave's registration queue. More... | |
void | GST_forwarded_operation_reply_relay (void *cls, const struct GNUNET_MessageHeader *msg) |
Callback to relay the reply msg of a forwarded operation back to the client. More... | |
void | GST_forwarded_operation_timeout (void *cls) |
Task to free resources when forwarded operation has been timed out. More... | |
void | GST_clear_fopcq (void) |
Clears the forwarded operations queue. More... | |
void | GST_send_operation_fail_msg (struct GNUNET_SERVICE_Client *client, uint64_t operation_id, const char *emsg) |
Send operation failure message to client. More... | |
void | GST_notify_client_disconnect_oc (struct GNUNET_SERVICE_Client *client) |
Notify OC subsystem that client disconnected. More... | |
void | GST_notify_client_disconnect_peers (struct GNUNET_SERVICE_Client *client) |
Notify peers subsystem that client disconnected. More... | |
void | GST_send_operation_success_msg (struct GNUNET_SERVICE_Client *client, uint64_t operation_id) |
Function to send generic operation success message to given client. More... | |
int | check_remote_overlay_connect (void *cls, const struct GNUNET_TESTBED_RemoteOverlayConnectMessage *msg) |
Check GNUNET_MESSAGE_TYPE_TESTBED_REMOTE_OVERLAY_CONNECT messages. More... | |
void | handle_remote_overlay_connect (void *cls, const struct GNUNET_TESTBED_RemoteOverlayConnectMessage *msg) |
Handler for GNUNET_MESSAGE_TYPE_TESTBED_REMOTE_OVERLAY_CONNECT messages. More... | |
int | check_peer_create (void *cls, const struct GNUNET_TESTBED_PeerCreateMessage *msg) |
Check #GNUNET_MESSAGE_TYPE_TESTBED_CREATEPEER messages. More... | |
void | handle_peer_create (void *cls, const struct GNUNET_TESTBED_PeerCreateMessage *msg) |
Handler for #GNUNET_MESSAGE_TYPE_TESTBED_CREATEPEER messages. More... | |
void | handle_peer_destroy (void *cls, const struct GNUNET_TESTBED_PeerDestroyMessage *msg) |
Message handler for #GNUNET_MESSAGE_TYPE_TESTBED_DESTROYPEER messages. More... | |
void | handle_peer_start (void *cls, const struct GNUNET_TESTBED_PeerStartMessage *msg) |
Message handler for GNUNET_MESSAGE_TYPE_TESTBED_START_PEER messages. More... | |
void | handle_peer_stop (void *cls, const struct GNUNET_TESTBED_PeerStopMessage *msg) |
Message handler for #GNUNET_MESSAGE_TYPE_TESTBED_DESTROYPEER messages. More... | |
void | handle_peer_get_config (void *cls, const struct GNUNET_TESTBED_PeerGetConfigurationMessage *msg) |
Handler for #GNUNET_MESSAGE_TYPE_TESTBED_GETPEERCONFIG messages. More... | |
void | handle_shutdown_peers (void *cls, const struct GNUNET_TESTBED_ShutdownPeersMessage *msg) |
Handler for GNUNET_MESSAGE_TYPE_TESTBED_SHUTDOWN_PEERS messages. More... | |
int | check_manage_peer_service (void *cls, const struct GNUNET_TESTBED_ManagePeerServiceMessage *msg) |
Check GNUNET_MESSAGE_TYPE_TESTBED_MANAGE_PEER_SERVICE message. More... | |
void | handle_manage_peer_service (void *cls, const struct GNUNET_TESTBED_ManagePeerServiceMessage *msg) |
Handler for GNUNET_MESSAGE_TYPE_TESTBED_MANAGE_PEER_SERVICE messages. More... | |
int | check_peer_reconfigure (void *cls, const struct GNUNET_TESTBED_PeerReconfigureMessage *msg) |
Check #GNUNET_MESSAGE_TYPDE_TESTBED_RECONFIGURE_PEER type messages. More... | |
void | handle_peer_reconfigure (void *cls, const struct GNUNET_TESTBED_PeerReconfigureMessage *msg) |
Handler for #GNUNET_MESSAGE_TYPDE_TESTBED_RECONFIGURE_PEER type messages. More... | |
void | GST_free_mctxq (void) |
Frees the ManageServiceContext queue. More... | |
void | GST_free_lcf (void) |
Cleans up the queue used for forwarding link controllers requests. More... | |
void | GST_route_list_clear (void) |
Cleans up the route list. More... | |
void | GST_process_next_focc (struct RegisteredHostContext *rhc) |
Processes a forwarded overlay connect context in the queue of the given RegisteredHostContext. More... | |
void | GST_cleanup_focc (struct ForwardedOverlayConnectContext *focc) |
Cleans up ForwardedOverlayConnectContext. More... | |
void | GST_free_occq (void) |
Clears all pending overlay connect contexts in queue. More... | |
void | GST_free_roccq (void) |
Clears all pending remote overlay connect contexts in queue. More... | |
void | GST_free_prcq (void) |
Cleans up the Peer reconfigure context list. More... | |
void | GST_cache_init (unsigned int size) |
Initializes the cache. More... | |
void | GST_cache_clear (void) |
Clear cache. More... | |
const struct GNUNET_MessageHeader * | GST_cache_lookup_hello (const unsigned int peer_id) |
Looks up in the hello cache and returns the HELLO of the given peer. More... | |
void | GST_cache_add_hello (const unsigned int peer_id, const struct GNUNET_MessageHeader *hello) |
Caches the HELLO of the given peer. More... | |
void | GST_stats_init (const struct GNUNET_CONFIGURATION_Handle *cfg) |
Initialize logging CPU and IO statisticfs. More... | |
void | GST_stats_destroy (void) |
Shutdown the status calls module. More... | |
Variables | |
struct GNUNET_CONFIGURATION_Handle * | GST_config |
Our configuration. More... | |
struct Context * | GST_context |
The master context; generated with the first INIT message. More... | |
struct ForwardedOperationContext * | fopcq_head |
DLL head for forwarded operation contexts. More... | |
struct ForwardedOperationContext * | fopcq_tail |
DLL tail for forwarded operation contexts. More... | |
struct Peer ** | GST_peer_list |
A list of peers we know about. More... | |
struct GNUNET_TESTBED_Host ** | GST_host_list |
Array of hosts. More... | |
struct OperationQueue * | GST_opq_openfds |
Operation queue for open file descriptors. More... | |
struct GNUNET_TIME_Relative | GST_timeout |
Timeout for operations which may take some time. More... | |
unsigned int | GST_peer_list_size |
The size of the peer list. More... | |
unsigned int | GST_num_local_peers |
The current number of peers running locally under this controller. More... | |
unsigned int | GST_host_list_size |
The size of the host list. More... | |
char * | GST_stats_dir |
The directory where to store load statistics data. More... | |
data structures shared amongst components of TESTBED service
Definition in file gnunet-service-testbed.h.
#define LOG | ( | kind, | |
... | |||
) | GNUNET_log (kind, __VA_ARGS__) |
Generic logging.
Definition at line 44 of file gnunet-service-testbed.h.
#define LOG_DEBUG | ( | ... | ) | LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__) |
Debug logging.
Definition at line 50 of file gnunet-service-testbed.h.
#define LIST_GROW_STEP 10 |
By how much should the arrays lists grow.
Definition at line 56 of file gnunet-service-testbed.h.
#define VALID_HOST_ID | ( | id | ) | (((id) < GST_host_list_size) && (NULL != GST_host_list[id])) |
Condition to check if host id is valid.
Definition at line 473 of file gnunet-service-testbed.h.
#define VALID_PEER_ID | ( | id | ) | (((id) < GST_peer_list_size) && (NULL != GST_peer_list[id])) |
Condition to check if peer id is valid.
Definition at line 479 of file gnunet-service-testbed.h.
#define GST_array_grow_large_enough | ( | ptr, | |
size, | |||
accommodate_size | |||
) |
Similar to GNUNET_array_grow(); however instead of calling GNUNET_array_grow() several times we call it only once.
The array is also made to grow in steps of LIST_GROW_STEP.
ptr | the array pointer to grow |
size | the size of array |
accommodate_size | the size which the array has to accommdate; after this call the array will be big enough to accommdate sizes up to accommodate_size |
Definition at line 494 of file gnunet-service-testbed.h.
void GST_destroy_peer | ( | struct Peer * | peer | ) |
Function to destroy a peer.
peer | the peer structure to destroy |
Definition at line 260 of file gnunet-service-testbed_peers.c.
References GNUNET_break, GNUNET_CONFIGURATION_destroy(), GNUNET_free, GNUNET_NO, GNUNET_TESTING_peer_destroy(), GNUNET_TESTING_peer_stop(), GNUNET_YES, peer, and peer_list_remove().
Referenced by cleanup_mctx(), cleanup_occ(), cleanup_rocc(), handle_peer_destroy(), and peer_destroy_success_cb().
void GST_destroy_peers | ( | void | ) |
Stops and destroys all peers.
Definition at line 1410 of file gnunet-service-testbed_peers.c.
References GNUNET_break, GNUNET_CONFIGURATION_destroy(), GNUNET_free, GNUNET_NO, GNUNET_TESTING_peer_destroy(), GNUNET_TESTING_peer_kill(), GNUNET_TESTING_peer_wait(), GNUNET_YES, GST_peer_list, GST_peer_list_size, id, and peer.
Referenced by handle_shutdown_peers(), and shutdown_task().
struct Route* GST_find_dest_route | ( | uint32_t | host_id | ) |
Finds the route with directly connected host as destination through which the destination host can be reached.
host_id | the id of the destination host |
Definition at line 526 of file gnunet-service-testbed_links.c.
References GST_context, Context::host_id, route_list, route_list_size, and Route::thru.
Referenced by forward_overlay_connect(), handle_link_controllers(), and handle_peer_create().
void handle_overlay_connect | ( | void * | cls, |
const struct GNUNET_TESTBED_OverlayConnectMessage * | msg | ||
) |
Handler for GNUNET_MESSAGE_TYPE_TESTBED_OVERLAY_CONNECT messages.
cls | identification of the client |
msg | the actual message |
Definition at line 1531 of file gnunet-service-testbed_oc.c.
References OverlayConnectContext::cgh_ch, OverlayConnectContext::client, Peer::details, OverlayConnectContext::emsg, forward_overlay_connect(), GNUNET_asprintf(), GNUNET_assert, GNUNET_break, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_i2s(), GNUNET_new, GNUNET_ntohll(), GNUNET_SCHEDULER_add_delayed(), GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_drop(), GNUNET_TESTING_peer_get_identity(), GNUNET_YES, GST_connection_pool_get_handle(), GST_CONNECTIONPOOL_SERVICE_CORE, GST_create_neighbour(), GST_get_neighbour(), GST_host_list, GST_neighbour_get_connection(), GST_peer_list, GST_timeout, Peer::id, Peer::local, LOG, LOG_DEBUG, msg, RemotePeer2Context::ncn, occ_cache_get_handle_core_cb(), OCC_TYPE_LOCAL, OCC_TYPE_REMOTE_LATERAL, OCC_TYPE_REMOTE_SLAVE, occq_head, occq_tail, OverlayConnectContext::op_id, OverlayConnectContext::other_peer_id, OverlayConnectContext::other_peer_identity, overlay_connect_notify(), p2_controller_connect_cb(), RemotePeer2Context::p2c, OverlayConnectContext::p2ctx, RemotePeer2Context::p2n, OverlayConnectContext::peer, peer, Peer::reference_cnt, Peer::remote, OverlayConnectContext::remote, timeout_overlay_connect(), OverlayConnectContext::timeout_task, OverlayConnectContext::type, VALID_HOST_ID, and VALID_PEER_ID.
void GST_queue_host_registration | ( | struct Slave * | slave, |
GNUNET_TESTBED_HostRegistrationCompletion | cb, | ||
void * | cb_cls, | ||
struct GNUNET_TESTBED_Host * | host | ||
) |
Adds a host registration's request to a slave's registration queue.
slave | the slave controller at which the given host has to be registered |
cb | the host registration completion callback |
cb_cls | the closure for the host registration completion callback |
host | the host which has to be registered |
Definition at line 247 of file gnunet-service-testbed.c.
References HostRegistration::cb, HostRegistration::cb_cls, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_DEBUG, GNUNET_new, GNUNET_NO, GNUNET_TESTBED_host_get_id_(), GNUNET_YES, GST_host_list, HostRegistration::host, Slave::host_id, Slave::hr_dll_head, Slave::hr_dll_tail, LOG, and register_next_host().
Referenced by lcf_proc_task(), and register_host().
void GST_forwarded_operation_reply_relay | ( | void * | cls, |
const struct GNUNET_MessageHeader * | msg | ||
) |
Callback to relay the reply msg of a forwarded operation back to the client.
cls | ForwardedOperationContext |
msg | the message to relay |
Definition at line 279 of file gnunet-service-testbed.c.
References ForwardedOperationContext::client, ForwardedOperationContext::cls, env, fopcq_head, fopcq_tail, GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_MQ_msg_copy(), GNUNET_MQ_send(), GNUNET_SCHEDULER_cancel(), GNUNET_SERVICE_client_get_mq(), LOG_DEBUG, msg, GNUNET_MessageHeader::size, ForwardedOperationContext::timeout_task, and GNUNET_MessageHeader::type.
Referenced by forward_overlay_connect(), forwarded_overlay_connect_listener(), handle_manage_peer_service(), handle_peer_get_config(), handle_peer_reconfigure(), handle_peer_start(), handle_peer_stop(), peer_create_success_cb(), and peer_destroy_success_cb().
void GST_forwarded_operation_timeout | ( | void * | cls | ) |
Task to free resources when forwarded operation has been timed out.
cls | the ForwardedOperationContext |
Definition at line 300 of file gnunet-service-testbed.c.
References ForwardedOperationContext::client, ForwardedOperationContext::cls, fopcq_head, fopcq_tail, GNUNET_CONTAINER_DLL_remove, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_TESTBED_forward_operation_msg_cancel_(), GST_send_operation_fail_msg(), LOG, ForwardedOperationContext::opc, ForwardedOperationContext::operation_id, and ForwardedOperationContext::timeout_task.
Referenced by client_disconnect_cb(), forward_overlay_connect(), forwarded_overlay_connect_timeout(), GST_notify_client_disconnect_oc(), GST_notify_client_disconnect_peers(), handle_manage_peer_service(), handle_peer_destroy(), handle_peer_get_config(), handle_peer_reconfigure(), handle_peer_start(), handle_peer_stop(), and peer_create_forward_timeout().
void GST_clear_fopcq | ( | void | ) |
Clears the forwarded operations queue.
Definition at line 677 of file gnunet-service-testbed.c.
References ForwardedOperationContext::cls, fopcq_head, fopcq_tail, GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_SCHEDULER_cancel(), GNUNET_TESTBED_forward_operation_msg_cancel_(), HandlerContext_ShutdownPeers::nslaves, OP_FORWARDED, OP_GET_SLAVE_CONFIG, OP_LINK_CONTROLLERS, OP_MANAGE_SERVICE, OP_OVERLAY_CONNECT, OP_PEER_CREATE, OP_PEER_DESTROY, OP_PEER_INFO, OP_PEER_RECONFIGURE, OP_PEER_START, OP_PEER_STOP, OP_SHUTDOWN_PEERS, ForwardedOperationContext::opc, ForwardedOperationContext::timeout_task, and ForwardedOperationContext::type.
Referenced by handle_shutdown_peers(), and shutdown_task().
void GST_send_operation_fail_msg | ( | struct GNUNET_SERVICE_Client * | client, |
uint64_t | operation_id, | ||
const char * | emsg | ||
) |
Send operation failure message to client.
client | the client to which the failure message has to be sent to |
operation_id | the id of the failed operation |
emsg | the error message; can be NULL |
Definition at line 125 of file gnunet-service-testbed.c.
References env, GNUNET_htonll(), GNUNET_memcpy, GNUNET_MESSAGE_TYPE_TESTBED_OPERATION_FAIL_EVENT, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_SERVICE_client_get_mq(), GNUNET_TESTBED_ET_OPERATION_FINISHED, msg, and GNUNET_TESTBED_OperationFailureEventMessage::operation_id.
Referenced by GST_forwarded_operation_timeout(), handle_manage_peer_service(), handle_peer_create(), handle_peer_destroy(), handle_peer_get_config(), handle_peer_reconfigure(), handle_peer_start(), handle_peer_stop(), handle_slave_get_config(), prc_stop_cb(), service_manage_result_cb(), shutdown_peers_reply_cb(), and timeout_overlay_connect().
void GST_notify_client_disconnect_oc | ( | struct GNUNET_SERVICE_Client * | client | ) |
Notify OC subsystem that client disconnected.
client | the client that disconnected |
Definition at line 624 of file gnunet-service-testbed_oc.c.
References cleanup_occ(), ForwardedOperationContext::client, OverlayConnectContext::client, fopcq_head, GNUNET_SCHEDULER_cancel(), GST_forwarded_operation_timeout(), ForwardedOperationContext::next, OverlayConnectContext::next, occq_head, and ForwardedOperationContext::timeout_task.
Referenced by client_disconnect_cb().
void GST_notify_client_disconnect_peers | ( | struct GNUNET_SERVICE_Client * | client | ) |
Notify peers subsystem that client disconnected.
client | the client that disconnected |
Definition at line 355 of file gnunet-service-testbed_peers.c.
References cleanup_mctx(), cleanup_prc(), ForwardedOperationContext::client, ManageServiceContext::client, PeerReconfigureContext::client, ForwardedOperationContext::cls, fopcq_head, GNUNET_free, GNUNET_SCHEDULER_cancel(), GST_forwarded_operation_timeout(), mctx_head, ForwardedOperationContext::next, ManageServiceContext::next, PeerReconfigureContext::next, OP_PEER_CREATE, prc_head, ForwardedOperationContext::timeout_task, and ForwardedOperationContext::type.
Referenced by client_disconnect_cb().
void GST_send_operation_success_msg | ( | struct GNUNET_SERVICE_Client * | client, |
uint64_t | operation_id | ||
) |
Function to send generic operation success message to given client.
client | the client to send the message to |
operation_id | the id of the operation which was successful |
Definition at line 154 of file gnunet-service-testbed.c.
References env, GNUNET_htonll(), GNUNET_MESSAGE_TYPE_TESTBED_GENERIC_OPERATION_SUCCESS, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_SERVICE_client_get_mq(), GNUNET_TESTBED_ET_OPERATION_FINISHED, msg, and GNUNET_TESTBED_GenericOperationSuccessEventMessage::operation_id.
Referenced by handle_peer_destroy(), handle_peer_reconfigure(), handle_shutdown_peers(), prc_stop_cb(), service_manage_result_cb(), and shutdown_peers_reply_cb().
int check_remote_overlay_connect | ( | void * | cls, |
const struct GNUNET_TESTBED_RemoteOverlayConnectMessage * | msg | ||
) |
Check GNUNET_MESSAGE_TYPE_TESTBED_REMOTE_OVERLAY_CONNECT messages.
cls | identification of the client |
msg | the actual message |
Definition at line 1870 of file gnunet-service-testbed_oc.c.
References GNUNET_break, GNUNET_break_op, GNUNET_MESSAGE_TYPE_HELLO, GNUNET_OK, GNUNET_SYSERR, GST_peer_list, GST_peer_list_size, msg, peer_id, GNUNET_MessageHeader::size, and GNUNET_MessageHeader::type.
void handle_remote_overlay_connect | ( | void * | cls, |
const struct GNUNET_TESTBED_RemoteOverlayConnectMessage * | msg | ||
) |
Handler for GNUNET_MESSAGE_TYPE_TESTBED_REMOTE_OVERLAY_CONNECT messages.
cls | identification of the client |
msg | the actual message |
Definition at line 1909 of file gnunet-service-testbed_oc.c.
References RemoteOverlayConnectCtx::a_id, cache_transport_peer_connect_notify(), ConnectivitySuggestContext::cgh_p2_th, GNUNET_TESTBED_Peer::controller, Peer::details, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_copy_message(), GNUNET_i2s(), GNUNET_malloc, GNUNET_memcpy, GNUNET_new, GNUNET_ntohll(), GNUNET_SCHEDULER_add_delayed(), GNUNET_SERVICE_client_continue(), GNUNET_strlcpy(), GNUNET_TESTBED_queue_message_(), GNUNET_TESTING_peer_get_identity(), GNUNET_YES, GST_connection_pool_get_handle(), GST_CONNECTIONPOOL_SERVICE_TRANSPORT, GST_peer_list, GST_timeout, RemoteOverlayConnectCtx::hello, Peer::local, LOG_DEBUG, msg, RemoteOverlayConnectCtx::op_id, RemoteOverlayConnectCtx::peer, peer, peer_id, pid, Peer::reference_cnt, rocc_cache_get_handle_transport_cb(), roccq_head, roccq_tail, GNUNET_MessageHeader::size, RemoteOverlayConnectCtx::tcc, timeout_rocc_task(), and RemoteOverlayConnectCtx::timeout_rocc_task_id.
int check_peer_create | ( | void * | cls, |
const struct GNUNET_TESTBED_PeerCreateMessage * | msg | ||
) |
Check #GNUNET_MESSAGE_TYPE_TESTBED_CREATEPEER messages.
cls | identification of the client |
msg | the actual message |
Definition at line 425 of file gnunet-service-testbed_peers.c.
References GNUNET_OK.
void handle_peer_create | ( | void * | cls, |
const struct GNUNET_TESTBED_PeerCreateMessage * | msg | ||
) |
Handler for #GNUNET_MESSAGE_TYPE_TESTBED_CREATEPEER messages.
cls | identification of the client |
msg | the actual message |
Definition at line 433 of file gnunet-service-testbed_peers.c.
References cfg, ForwardedOperationContext::client, ForwardedOperationContext::cls, Slave::controller, Route::dest, env, fopcq_head, fopcq_tail, GNUNET_asprintf(), GNUNET_break, GNUNET_CONFIGURATION_set_value_number(), GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_MESSAGE_TYPE_TESTBED_CREATE_PEER_SUCCESS, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_new, GNUNET_NO, GNUNET_ntohll(), GNUNET_SCHEDULER_add_delayed(), GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_drop(), GNUNET_SERVICE_client_get_mq(), GNUNET_TESTBED_extract_config_(), GNUNET_TESTBED_forward_operation_msg_(), GNUNET_TESTING_peer_configure(), GNUNET_YES, GST_context, GST_find_dest_route(), GST_send_operation_fail_msg(), GST_slave_list, GST_timeout, Context::host_id, LOG, LOG_DEBUG, msg, OP_PEER_CREATE, ForwardedOperationContext::opc, ForwardedOperationContext::operation_id, GNUNET_TESTBED_PeerCreateSuccessEventMessage::operation_id, peer, peer_create_forward_timeout(), peer_create_success_cb(), peer_id, GNUNET_TESTBED_PeerCreateSuccessEventMessage::peer_id, peer_list_add(), Context::system, ForwardedOperationContext::timeout_task, ForwardedOperationContext::type, and VALID_PEER_ID.
void handle_peer_destroy | ( | void * | cls, |
const struct GNUNET_TESTBED_PeerDestroyMessage * | msg | ||
) |
Message handler for #GNUNET_MESSAGE_TYPE_TESTBED_DESTROYPEER messages.
cls | identification of the client |
msg | the actual message |
Definition at line 565 of file gnunet-service-testbed_peers.c.
References ForwardedOperationContext::client, ForwardedOperationContext::cls, Slave::controller, fopcq_head, fopcq_tail, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_new, GNUNET_ntohll(), GNUNET_SCHEDULER_add_delayed(), GNUNET_SERVICE_client_continue(), GNUNET_TESTBED_forward_operation_msg_(), GNUNET_YES, GST_destroy_peer(), GST_forwarded_operation_timeout(), GST_peer_list, GST_send_operation_fail_msg(), GST_send_operation_success_msg(), GST_timeout, LOG, LOG_DEBUG, msg, OP_PEER_DESTROY, ForwardedOperationContext::opc, ForwardedOperationContext::operation_id, peer, peer_destroy_success_cb(), peer_id, Peer::slave, ForwardedOperationContext::timeout_task, ForwardedOperationContext::type, and VALID_PEER_ID.
void handle_peer_start | ( | void * | cls, |
const struct GNUNET_TESTBED_PeerStartMessage * | msg | ||
) |
Message handler for GNUNET_MESSAGE_TYPE_TESTBED_START_PEER messages.
cls | identification of the client |
msg | the actual message |
Definition at line 643 of file gnunet-service-testbed_peers.c.
References ForwardedOperationContext::client, Slave::controller, env, GNUNET_TESTBED_PeerEventMessage::event_type, fopcq_head, fopcq_tail, GNUNET_break, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_ERROR, GNUNET_MESSAGE_TYPE_TESTBED_PEER_EVENT, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_new, GNUNET_ntohll(), GNUNET_OK, GNUNET_SCHEDULER_add_delayed(), GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_get_mq(), GNUNET_TESTBED_ET_PEER_START, GNUNET_TESTBED_forward_operation_msg_(), GNUNET_YES, GST_context, GST_forwarded_operation_reply_relay(), GST_forwarded_operation_timeout(), GST_peer_list, GST_send_operation_fail_msg(), GST_timeout, Context::host_id, GNUNET_TESTBED_PeerEventMessage::host_id, LOG, msg, OP_PEER_START, ForwardedOperationContext::opc, ForwardedOperationContext::operation_id, GNUNET_TESTBED_PeerEventMessage::operation_id, peer, peer_id, GNUNET_TESTBED_PeerEventMessage::peer_id, Peer::slave, start_peer(), ForwardedOperationContext::timeout_task, ForwardedOperationContext::type, and VALID_PEER_ID.
void handle_peer_stop | ( | void * | cls, |
const struct GNUNET_TESTBED_PeerStopMessage * | msg | ||
) |
Message handler for #GNUNET_MESSAGE_TYPE_TESTBED_DESTROYPEER messages.
cls | identification of the client |
msg | the actual message |
Message handler for #GNUNET_MESSAGE_TYPE_TESTBED_DESTROYPEER messages.
cls | identification of the client |
msg | the actual message |
Definition at line 713 of file gnunet-service-testbed_peers.c.
References ForwardedOperationContext::client, Slave::controller, env, GNUNET_TESTBED_PeerEventMessage::event_type, fopcq_head, fopcq_tail, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_MESSAGE_TYPE_TESTBED_PEER_EVENT, GNUNET_MQ_msg, GNUNET_MQ_send(), GNUNET_new, GNUNET_ntohll(), GNUNET_OK, GNUNET_SCHEDULER_add_delayed(), GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_get_mq(), GNUNET_TESTBED_ET_PEER_STOP, GNUNET_TESTBED_forward_operation_msg_(), GNUNET_TESTING_peer_wait(), GNUNET_YES, GST_context, GST_forwarded_operation_reply_relay(), GST_forwarded_operation_timeout(), GST_peer_list, GST_send_operation_fail_msg(), GST_timeout, Context::host_id, GNUNET_TESTBED_PeerEventMessage::host_id, LOG, msg, OP_PEER_STOP, ForwardedOperationContext::opc, ForwardedOperationContext::operation_id, GNUNET_TESTBED_PeerEventMessage::operation_id, peer, peer_id, GNUNET_TESTBED_PeerEventMessage::peer_id, Peer::slave, stop_peer(), ForwardedOperationContext::timeout_task, ForwardedOperationContext::type, and VALID_PEER_ID.
void handle_peer_get_config | ( | void * | cls, |
const struct GNUNET_TESTBED_PeerGetConfigurationMessage * | msg | ||
) |
Handler for #GNUNET_MESSAGE_TYPE_TESTBED_GETPEERCONFIG messages.
cls | identification of the client |
msg | the actual message |
Handler for #GNUNET_MESSAGE_TYPE_TESTBED_GETPEERCONFIG messages.
cls | identification of the client |
msg | the actual message |
Definition at line 797 of file gnunet-service-testbed_peers.c.
References ForwardedOperationContext::client, config, GNUNET_TESTBED_PeerConfigurationInformationMessage::config_size, Slave::controller, Peer::details, env, fopcq_head, fopcq_tail, GNUNET_CONFIGURATION_serialize(), GNUNET_CONTAINER_DLL_insert_tail, GNUNET_free, GNUNET_memcpy, GNUNET_MESSAGE_TYPE_TESTBED_PEER_INFORMATION, GNUNET_MQ_msg_extra, GNUNET_MQ_send(), GNUNET_new, GNUNET_ntohll(), GNUNET_SCHEDULER_add_delayed(), GNUNET_SERVICE_client_continue(), GNUNET_SERVICE_client_get_mq(), GNUNET_TESTBED_compress_config_(), GNUNET_TESTBED_forward_operation_msg_(), GNUNET_TESTING_peer_get_identity(), GNUNET_YES, GST_forwarded_operation_reply_relay(), GST_forwarded_operation_timeout(), GST_peer_list, GST_send_operation_fail_msg(), GST_timeout, LOG_DEBUG, msg, OP_PEER_INFO, ForwardedOperationContext::opc, ForwardedOperationContext::operation_id, GNUNET_TESTBED_PeerConfigurationInformationMessage::operation_id, peer, peer_id, GNUNET_TESTBED_PeerConfigurationInformationMessage::peer_id, GNUNET_TESTBED_PeerConfigurationInformationMessage::peer_identity, Peer::slave, ForwardedOperationContext::timeout_task, ForwardedOperationContext::type, and VALID_PEER_ID.
void handle_shutdown_peers | ( | void * | cls, |
const struct GNUNET_TESTBED_ShutdownPeersMessage * | msg | ||
) |
Handler for GNUNET_MESSAGE_TYPE_TESTBED_SHUTDOWN_PEERS messages.
cls | identification of the client |
msg | the actual message |
Definition at line 1498 of file gnunet-service-testbed_peers.c.
References ForwardedOperationContext::client, ForwardedOperationContext::cls, Slave::controller, Slave::controller_proc, fopcq_head, fopcq_tail, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_free, GNUNET_new, GNUNET_ntohll(), GNUNET_SERVICE_client_continue(), GNUNET_TESTBED_forward_operation_msg_(), GST_clear_fopcq(), GST_destroy_peers(), GST_free_mctxq(), GST_free_occq(), GST_free_roccq(), GST_send_operation_success_msg(), GST_slave_list, GST_slave_list_size, LOG_DEBUG, msg, HandlerContext_ShutdownPeers::nslaves, OP_SHUTDOWN_PEERS, ForwardedOperationContext::opc, ForwardedOperationContext::operation_id, shutdown_peers_reply_cb(), and ForwardedOperationContext::type.
int check_manage_peer_service | ( | void * | cls, |
const struct GNUNET_TESTBED_ManagePeerServiceMessage * | msg | ||
) |
Check GNUNET_MESSAGE_TYPE_TESTBED_MANAGE_PEER_SERVICE message.
cls | identification of client |
msg | the actual message |
Definition at line 1269 of file gnunet-service-testbed_peers.c.
References GNUNET_break_op, GNUNET_OK, GNUNET_SYSERR, msg, service, and GNUNET_MessageHeader::size.
void handle_manage_peer_service | ( | void * | cls, |
const struct GNUNET_TESTBED_ManagePeerServiceMessage * | msg | ||
) |
Handler for GNUNET_MESSAGE_TYPE_TESTBED_MANAGE_PEER_SERVICE messages.
cls | identification of client |
msg | the actual message |
Definition at line 1294 of file gnunet-service-testbed_peers.c.
References ah, ManageServiceContext::ah, ForwardedOperationContext::client, ManageServiceContext::client, ForwardedOperationContext::cls, GNUNET_TESTBED_Peer::controller, fopcq_head, fopcq_tail, GNUNET_ARM_connect(), GNUNET_ARM_request_service_start(), GNUNET_ARM_request_service_stop(), GNUNET_asprintf(), GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_new, GNUNET_NO, GNUNET_ntohll(), GNUNET_OS_INHERIT_STD_ERR, GNUNET_SCHEDULER_add_delayed(), GNUNET_SERVICE_client_continue(), GNUNET_strdup, GNUNET_TESTBED_forward_operation_msg_(), GNUNET_YES, GST_forwarded_operation_reply_relay(), GST_forwarded_operation_timeout(), GST_peer_list, GST_peer_list_size, GST_send_operation_fail_msg(), GST_timeout, LOG, LOG_DEBUG, mctx_head, mctx_tail, msg, ManageServiceContext::op_id, OP_MANAGE_SERVICE, ForwardedOperationContext::opc, ForwardedOperationContext::operation_id, ManageServiceContext::peer, peer, peer_id, service, ManageServiceContext::service, service_manage_result_cb(), ManageServiceContext::start, ForwardedOperationContext::timeout_task, and ForwardedOperationContext::type.
int check_peer_reconfigure | ( | void * | cls, |
const struct GNUNET_TESTBED_PeerReconfigureMessage * | msg | ||
) |
Check #GNUNET_MESSAGE_TYPDE_TESTBED_RECONFIGURE_PEER type messages.
cls | identification of the client |
msg | the actual message |
Definition at line 969 of file gnunet-service-testbed_peers.c.
References GNUNET_OK.
void handle_peer_reconfigure | ( | void * | cls, |
const struct GNUNET_TESTBED_PeerReconfigureMessage * | msg | ||
) |
Handler for #GNUNET_MESSAGE_TYPDE_TESTBED_RECONFIGURE_PEER type messages.
Should stop the peer asynchronously, destroy it and create it again with the new configuration.
cls | identification of the client |
msg | the actual message |
Definition at line 985 of file gnunet-service-testbed_peers.c.
References cfg, PeerReconfigureContext::cfg, ForwardedOperationContext::client, PeerReconfigureContext::client, GNUNET_TESTBED_Peer::controller, fopcq_head, fopcq_tail, GNUNET_asprintf(), GNUNET_assert, GNUNET_break, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_new, GNUNET_NO, GNUNET_ntohll(), GNUNET_OK, GNUNET_SCHEDULER_add_delayed(), GNUNET_SERVICE_client_continue(), GNUNET_TESTBED_extract_config_(), GNUNET_TESTBED_forward_operation_msg_(), GNUNET_TESTING_peer_stop_async(), GNUNET_YES, GST_forwarded_operation_reply_relay(), GST_forwarded_operation_timeout(), GST_peer_list, GST_send_operation_fail_msg(), GST_send_operation_success_msg(), GST_timeout, LOG, LOG_DEBUG, msg, PeerReconfigureContext::op_id, OP_PEER_RECONFIGURE, ForwardedOperationContext::opc, ForwardedOperationContext::operation_id, peer, peer_id, PeerReconfigureContext::peer_id, prc_head, prc_stop_cb(), prc_tail, ForwardedOperationContext::timeout_task, ForwardedOperationContext::type, update_peer_config(), and VALID_PEER_ID.
void GST_free_mctxq | ( | void | ) |
Frees the ManageServiceContext queue.
Definition at line 1114 of file gnunet-service-testbed_peers.c.
References cleanup_mctx(), and mctx_head.
Referenced by handle_shutdown_peers(), and shutdown_task().
void GST_free_lcf | ( | void | ) |
Cleans up the queue used for forwarding link controllers requests.
Definition at line 1444 of file gnunet-service-testbed_links.c.
References GNUNET_assert, GNUNET_CONTAINER_DLL_remove, GNUNET_free, GNUNET_SCHEDULER_cancel(), GNUNET_TESTBED_operation_done(), lcf_head, lcf_proc_task_id, lcf_tail, LCFContext::op, and LCFContext::timeout_task.
Referenced by shutdown_task(), and slave_status_cb().
void GST_route_list_clear | ( | void | ) |
Cleans up the route list.
Definition at line 398 of file gnunet-service-testbed_links.c.
References GNUNET_free, id, route_list, and route_list_size.
Referenced by shutdown_task().
void GST_process_next_focc | ( | struct RegisteredHostContext * | rhc | ) |
Processes a forwarded overlay connect context in the queue of the given RegisteredHostContext.
rhc | the RegisteredHostContext |
Definition at line 425 of file gnunet-service-testbed_oc.c.
References ForwardedOperationContext::client, ForwardedOverlayConnectContext::client, ForwardedOperationContext::cls, Slave::controller, RegisteredHostContext::focc_dll_head, fopcq_head, fopcq_tail, forwarded_overlay_connect_listener(), forwarded_overlay_connect_timeout(), GNUNET_assert, GNUNET_CONTAINER_DLL_insert_tail, GNUNET_free, GNUNET_new, GNUNET_SCHEDULER_add_delayed(), GNUNET_TESTBED_forward_operation_msg_(), GNUNET_YES, GST_peer_list, GST_timeout, OP_OVERLAY_CONNECT, ForwardedOperationContext::opc, ForwardedOperationContext::operation_id, ForwardedOverlayConnectContext::operation_id, ForwardedOverlayConnectContext::orig_msg, peer, ForwardedOverlayConnectContext::peer1, RegisteredHostContext::state, ForwardedOperationContext::timeout_task, ForwardedOperationContext::type, and VALID_PEER_ID.
Referenced by forwarded_overlay_connect_listener(), forwarded_overlay_connect_timeout(), and host_registration_comp().
void GST_cleanup_focc | ( | struct ForwardedOverlayConnectContext * | focc | ) |
Cleans up ForwardedOverlayConnectContext.
focc | the ForwardedOverlayConnectContext to cleanup |
Definition at line 357 of file gnunet-service-testbed_oc.c.
References RegisteredHostContext::focc_dll_head, RegisteredHostContext::focc_dll_tail, GNUNET_CONTAINER_DLL_remove, GNUNET_free, ForwardedOverlayConnectContext::orig_msg, and ForwardedOverlayConnectContext::rhc.
Referenced by drop_client_entries(), forwarded_overlay_connect_listener(), forwarded_overlay_connect_timeout(), and reghost_free_iterator().
void GST_free_occq | ( | void | ) |
Clears all pending overlay connect contexts in queue.
Definition at line 1978 of file gnunet-service-testbed_oc.c.
References cleanup_occ(), and occq_head.
Referenced by handle_shutdown_peers(), and shutdown_task().
void GST_free_roccq | ( | void | ) |
Clears all pending remote overlay connect contexts in queue.
Definition at line 1991 of file gnunet-service-testbed_oc.c.
References cleanup_rocc(), and roccq_head.
Referenced by handle_shutdown_peers(), and shutdown_task().
void GST_free_prcq | ( | void | ) |
Cleans up the Peer reconfigure context list.
Definition at line 881 of file gnunet-service-testbed_peers.c.
References cleanup_prc(), and prc_head.
Referenced by shutdown_task().
void GST_cache_init | ( | unsigned int | size | ) |
Initializes the cache.
size | the size of the cache |
Definition at line 212 of file gnunet-service-testbed_cache.c.
References cache, cache_size, GNUNET_CONTAINER_multihashmap32_create(), and size.
Referenced by testbed_run().
void GST_cache_clear | ( | void | ) |
Clear cache.
Definition at line 190 of file gnunet-service-testbed_cache.c.
References cache, cache_clear_iterator(), cache_head, cache_size, cache_tail, GNUNET_assert, GNUNET_CONTAINER_multihashmap32_destroy(), GNUNET_CONTAINER_multihashmap32_iterate(), and GNUNET_CONTAINER_multihashmap32_size().
Referenced by shutdown_task().
const struct GNUNET_MessageHeader* GST_cache_lookup_hello | ( | const unsigned int | peer_id | ) |
Looks up in the hello cache and returns the HELLO of the given peer.
peer_id | the index of the peer whose HELLO has to be looked up |
Definition at line 228 of file gnunet-service-testbed_cache.c.
References cache, cache_lookup(), CacheEntry::hello, LOG_DEBUG, and peer_id.
Referenced by occ_cache_get_handle_core_cb().
void GST_cache_add_hello | ( | const unsigned int | peer_id, |
const struct GNUNET_MessageHeader * | hello | ||
) |
Caches the HELLO of the given peer.
Updates the HELLO if it was already cached before
peer_id | the peer identity of the peer whose HELLO has to be cached |
hello | the HELLO message |
Definition at line 255 of file gnunet-service-testbed_cache.c.
References add_entry(), cache, cache_lookup(), GNUNET_copy_message(), GNUNET_free, CacheEntry::hello, and peer_id.
Referenced by hello_update_cb().
void GST_stats_init | ( | const struct GNUNET_CONFIGURATION_Handle * | cfg | ) |
Initialize logging CPU and IO statisticfs.
Checks the configuration for "STATS_DIR" and logs to a file in that directory. The file is name is generated from the hostname and the process's PID.
Definition at line 590 of file gnunet-service-testbed_cpustatus.c.
References _, bw, cfg, GNUNET_asprintf(), GNUNET_BIO_write_open_file(), GNUNET_CONFIGURATION_get_value_filename(), GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, GNUNET_log_strerror, GNUNET_log_strerror_file, GNUNET_malloc, GNUNET_OK, GNUNET_OS_get_hostname_max_length, GNUNET_SCHEDULER_add_now(), hostname, len, sample_load_task(), sample_load_task_id, and updateUsage().
Referenced by testbed_run().
void GST_stats_destroy | ( | void | ) |
Shutdown the status calls module.
Definition at line 641 of file gnunet-service-testbed_cpustatus.c.
References bw, GNUNET_BIO_write_close(), GNUNET_break, GNUNET_free, GNUNET_OK, GNUNET_SCHEDULER_cancel(), and sample_load_task_id.
Referenced by shutdown_task().
|
extern |
Our configuration.
Definition at line 39 of file gnunet-service-testbed.c.
Referenced by handle_init(), shutdown_task(), and testbed_run().
|
extern |
The master context; generated with the first INIT message.
Definition at line 44 of file gnunet-service-testbed.c.
Referenced by client_disconnect_cb(), GST_find_dest_route(), handle_add_host(), handle_barrier_cancel(), handle_barrier_init(), handle_barrier_status(), handle_init(), handle_link_controllers(), handle_peer_create(), handle_peer_start(), handle_peer_stop(), shutdown_task(), and update_peer_config().
|
extern |
DLL head for forwarded operation contexts.
Definition at line 54 of file gnunet-service-testbed.c.
Referenced by client_disconnect_cb(), forward_overlay_connect(), GST_clear_fopcq(), GST_forwarded_operation_reply_relay(), GST_forwarded_operation_timeout(), GST_notify_client_disconnect_oc(), GST_notify_client_disconnect_peers(), GST_process_next_focc(), handle_manage_peer_service(), handle_peer_create(), handle_peer_destroy(), handle_peer_get_config(), handle_peer_reconfigure(), handle_peer_start(), handle_peer_stop(), handle_shutdown_peers(), and shutdown_peers_reply_cb().
|
extern |
DLL tail for forwarded operation contexts.
Definition at line 59 of file gnunet-service-testbed.c.
Referenced by forward_overlay_connect(), GST_clear_fopcq(), GST_forwarded_operation_reply_relay(), GST_forwarded_operation_timeout(), GST_process_next_focc(), handle_manage_peer_service(), handle_peer_create(), handle_peer_destroy(), handle_peer_get_config(), handle_peer_reconfigure(), handle_peer_start(), handle_peer_stop(), handle_shutdown_peers(), and shutdown_peers_reply_cb().
|
extern |
A list of peers we know about.
Definition at line 37 of file gnunet-service-testbed_peers.c.
Referenced by check_remote_overlay_connect(), cleanup_occ(), cleanup_prc(), forward_overlay_connect(), GST_destroy_peers(), GST_process_next_focc(), handle_manage_peer_service(), handle_overlay_connect(), handle_peer_destroy(), handle_peer_get_config(), handle_peer_reconfigure(), handle_peer_start(), handle_peer_stop(), handle_remote_overlay_connect(), occ_hello_sent_cb(), p2_transport_connect(), peer_list_add(), peer_list_remove(), and prc_stop_cb().
|
extern |
Array of hosts.
Definition at line 49 of file gnunet-service-testbed.c.
Referenced by forward_overlay_connect(), GST_queue_host_registration(), handle_link_controllers(), handle_overlay_connect(), handle_slave_get_config(), host_list_add(), hr_completion(), lcf_proc_task(), opstart_neighbour_conn(), register_host(), register_next_host(), shutdown_task(), slave_event_cb(), and slave_status_cb().
|
extern |
Operation queue for open file descriptors.
Definition at line 64 of file gnunet-service-testbed.c.
Referenced by GST_connection_pool_get_handle(), GST_neighbour_get_connection(), shutdown_task(), and testbed_run().
|
extern |
Timeout for operations which may take some time.
Definition at line 64 of file gnunet-service-testbed.c.
Referenced by forward_overlay_connect(), GST_process_next_focc(), handle_link_controllers(), handle_manage_peer_service(), handle_overlay_connect(), handle_peer_create(), handle_peer_destroy(), handle_peer_get_config(), handle_peer_reconfigure(), handle_peer_start(), handle_peer_stop(), handle_remote_overlay_connect(), lcf_proc_task(), and testbed_run().
|
extern |
The size of the peer list.
Definition at line 79 of file gnunet-service-testbed.c.
Referenced by check_remote_overlay_connect(), GST_destroy_peers(), handle_manage_peer_service(), peer_list_add(), and peer_list_remove().
|
extern |
The current number of peers running locally under this controller.
Definition at line 42 of file gnunet-service-testbed_peers.c.
Referenced by peer_list_add(), and peer_list_remove().
|
extern |
The size of the host list.
Definition at line 74 of file gnunet-service-testbed.c.
Referenced by handle_link_controllers(), host_list_add(), and shutdown_task().
|
extern |
The directory where to store load statistics data.