struct GNUNET_TESTING_Daemon
* d, const char *emsg);
-
/**
* Handle to an entire testbed of GNUnet peers.
*/
void *update_cb_cls;
/**
- * Identity of this peer (once started).
+ * PID of the process we used to run gnunet-arm or SSH to start the peer.
*/
- struct GNUNET_PeerIdentity id;
+ struct GNUNET_OS_Process *proc_arm_start;
/**
- * Flag to indicate that we've already been asked
- * to terminate (but could not because some action
- * was still pending).
+ * PID of the process we used to run gnunet-arm or SSH to stop the peer.
*/
- int dead;
+ struct GNUNET_OS_Process *proc_arm_stop;
/**
- * GNUNET_YES if the hostkey has been created
- * for this peer, GNUNET_NO otherwise.
+ * PID of the process we used to run gnunet-arm or SSH to manage services at the peer.
*/
- int have_hostkey;
+ struct GNUNET_OS_Process *proc_arm_srv_start;
/**
- * PID of the process that we started last.
+ * PID of the process we used to run gnunet-arm or SSH to manage services at the peer.
*/
- struct GNUNET_OS_Process *proc;
+ struct GNUNET_OS_Process *proc_arm_srv_stop;
/**
- * In which phase are we during the start of
- * this process?
+ * PID of the process we used to run copy files
*/
- enum GNUNET_TESTING_StartPhase phase;
+ struct GNUNET_OS_Process *proc_arm_copying;
/**
- * ID of the current task.
+ * PID of the process we used to run gnunet-peerinfo.
*/
- GNUNET_SCHEDULER_TaskIdentifier task;
+ struct GNUNET_OS_Process *proc_arm_peerinfo;
/**
* Handle to the server.
*/
struct GNUNET_TRANSPORT_Handle *th;
+ /**
+ * Handle for getting HELLOs from transport
+ */
+ struct GNUNET_TRANSPORT_GetHelloHandle *ghh;
+
/**
* HELLO message for this peer
*/
struct GNUNET_DISK_PipeHandle *pipe_stdout;
/**
- * Output from gnunet-peerinfo is read into this buffer.
+ * Currently, a single char * pointing to a service
+ * that has been churned off.
+ *
+ * FIXME: make this a linked list of services that have been churned off!!!
*/
- char hostkeybuf[105];
+ char *churned_services;
+
+ /**
+ * ID of the current task.
+ */
+ GNUNET_SCHEDULER_TaskIdentifier task;
+
+ /**
+ * Identity of this peer (once started).
+ */
+ struct GNUNET_PeerIdentity id;
+
+ /**
+ * Flag to indicate that we've already been asked
+ * to terminate (but could not because some action
+ * was still pending).
+ */
+ int dead;
+
+ /**
+ * GNUNET_YES if the hostkey has been created
+ * for this peer, GNUNET_NO otherwise.
+ */
+ int have_hostkey;
+
+ /**
+ * In which phase are we during the start of
+ * this process?
+ */
+ enum GNUNET_TESTING_StartPhase phase;
/**
* Current position in 'hostkeybuf' (for reading from gnunet-peerinfo)
int churn;
/**
- * Currently, a single char * pointing to a service
- * that has been churned off.
- *
- * FIXME: make this a linked list of services that have been churned off!!!
+ * Output from gnunet-peerinfo is read into this buffer.
*/
- char *churned_services;
+ char hostkeybuf[105];
+
};
second_daemon,
const char *emsg);
+
/**
* Prototype of a callback function indicating that two peers
* are currently connected.
const struct GNUNET_PeerIdentity
* second, const char *emsg);
+
/**
* Starts a GNUnet daemon. GNUnet must be installed on the target
* system and available in the PATH. The machine must furthermore be
* @param cb_cls closure for cb
* @return handle to the daemon (actual start will be completed asynchronously)
*/
-struct GNUNET_TESTING_Daemon *GNUNET_TESTING_daemon_start (const struct
- GNUNET_CONFIGURATION_Handle
- *cfg,
- struct
- GNUNET_TIME_Relative
- timeout, int pretend,
- const char *hostname,
- const char
- *ssh_username,
- uint16_t sshport,
- const char *hostkey,
- GNUNET_TESTING_NotifyHostkeyCreated
- hostkey_callback,
- void *hostkey_cls,
- GNUNET_TESTING_NotifyDaemonRunning
- cb, void *cb_cls);
+struct GNUNET_TESTING_Daemon *
+GNUNET_TESTING_daemon_start (const struct GNUNET_CONFIGURATION_Handle *cfg,
+ struct GNUNET_TIME_Relative timeout, int pretend,
+ const char *hostname, const char *ssh_username,
+ uint16_t sshport, const char *hostkey,
+ GNUNET_TESTING_NotifyHostkeyCreated
+ hostkey_callback, void *hostkey_cls,
+ GNUNET_TESTING_NotifyDaemonRunning cb,
+ void *cb_cls);
/**
* Continues GNUnet daemon startup when user wanted to be notified
void
GNUNET_TESTING_daemon_continue_startup (struct GNUNET_TESTING_Daemon *daemon);
+
/**
* Check whether the given daemon is running.
*
* @param daemon the daemon to check
- *
* @return GNUNET_YES if the daemon is up, GNUNET_NO if the
* daemon is down, GNUNET_SYSERR on error.
*/
-int GNUNET_TESTING_daemon_running (struct GNUNET_TESTING_Daemon *daemon);
+int
+GNUNET_TESTING_test_daemon_running (struct GNUNET_TESTING_Daemon *daemon);
+
+
+/**
+ * Obtain the peer identity of the peer with the given configuration
+ * handle. This function reads the private key of the peer, obtains
+ * the public key and hashes it.
+ *
+ * @param cfg configuration of the peer
+ * @param pid where to store the peer identity
+ * @return GNUNET_OK on success, GNUNET_SYSERR on failure
+ */
+int
+GNUNET_TESTING_get_peer_identity (const struct GNUNET_CONFIGURATION_Handle *cfg,
+ struct GNUNET_PeerIdentity *pid);
+
/**
* Restart (stop and start) a GNUnet daemon.
GNUNET_TESTING_NotifyDaemonRunning cb,
void *cb_cls);
+
/**
* Start a peer that has previously been stopped using the daemon_stop
* call (and files weren't deleted and the allow restart flag)
GNUNET_TESTING_NotifyDaemonRunning cb,
void *cb_cls);
+
/**
* Starts a GNUnet daemon's service.
*
*/
void
GNUNET_TESTING_daemon_start_service (struct GNUNET_TESTING_Daemon *d,
- char *service,
+ const char *service,
struct GNUNET_TIME_Relative timeout,
GNUNET_TESTING_NotifyDaemonRunning cb,
void *cb_cls);
+
/**
* Starts a GNUnet daemon's service which has been previously turned off.
*
GNUNET_TESTING_NotifyDaemonRunning
cb, void *cb_cls);
+
/**
* Get a certain testing daemon handle.
*
* @param pg handle to the set of running peers
* @param position the number of the peer to return
*/
-struct GNUNET_TESTING_Daemon *GNUNET_TESTING_daemon_get (struct
- GNUNET_TESTING_PeerGroup
- *pg,
- unsigned int position);
+struct GNUNET_TESTING_Daemon *
+GNUNET_TESTING_daemon_get (struct GNUNET_TESTING_PeerGroup *pg,
+ unsigned int position);
-/*
+
+/**
* Get a daemon by peer identity, so callers can
* retrieve the daemon without knowing it's offset.
*
*
* @return the daemon on success, or NULL if no such peer identity is found
*/
-struct GNUNET_TESTING_Daemon *GNUNET_TESTING_daemon_get_by_id (struct
- GNUNET_TESTING_PeerGroup
- *pg,
- struct
- GNUNET_PeerIdentity
- *peer_id);
+struct GNUNET_TESTING_Daemon *
+GNUNET_TESTING_daemon_get_by_id (struct GNUNET_TESTING_PeerGroup *pg,
+ const struct GNUNET_PeerIdentity *peer_id);
+
/**
* Stops a GNUnet daemon.
int delete_files, int allow_restart);
+
+/**
+ * Create a new configuration using the given configuration
+ * as a template; however, each PORT in the existing cfg
+ * must be renumbered by incrementing "*port". If we run
+ * out of "*port" numbers, return NULL.
+ *
+ * @param cfg template configuration
+ * @param off the current peer offset
+ * @param port port numbers to use, update to reflect
+ * port numbers that were used
+ * @param upnum number to make unix domain socket names unique
+ * @param hostname hostname of the controlling host, to allow control connections from
+ * @param fdnum number used to offset the unix domain socket for grouped processes
+ * (such as statistics or peerinfo, which can be shared among others)
+ *
+ * @return new configuration, NULL on error
+ */
+struct GNUNET_CONFIGURATION_Handle *
+GNUNET_TESTING_create_cfg (const struct GNUNET_CONFIGURATION_Handle *cfg, uint32_t off,
+ uint16_t * port, uint32_t * upnum, const char *hostname,
+ uint32_t * fdnum);
+
/**
* Changes the configuration of a GNUnet daemon.
*
* @param cb function called once the configuration was changed
* @param cb_cls closure for cb
*/
-void GNUNET_TESTING_daemon_reconfigure (struct GNUNET_TESTING_Daemon *d,
- struct GNUNET_CONFIGURATION_Handle *cfg,
- GNUNET_TESTING_NotifyCompletion cb,
- void *cb_cls);
+void
+GNUNET_TESTING_daemon_reconfigure (struct GNUNET_TESTING_Daemon *d,
+ struct GNUNET_CONFIGURATION_Handle *cfg,
+ GNUNET_TESTING_NotifyCompletion cb,
+ void *cb_cls);
+
/**
* Stops a single service of a GNUnet daemon. Used like daemon_stop,
*/
void
GNUNET_TESTING_daemon_stop_service (struct GNUNET_TESTING_Daemon *d,
- char *service,
+ const char *service,
struct GNUNET_TIME_Relative timeout,
GNUNET_TESTING_NotifyCompletion cb,
void *cb_cls);
+
/**
* Read a testing hosts file based on a configuration.
* Returns a DLL of hosts (caller must free!) on success
*
* @return DLL of hosts on success, NULL on failure
*/
-struct GNUNET_TESTING_Host *GNUNET_TESTING_hosts_load (const struct
- GNUNET_CONFIGURATION_Handle
- *cfg);
+struct GNUNET_TESTING_Host *
+GNUNET_TESTING_hosts_load (const struct GNUNET_CONFIGURATION_Handle *cfg);
/**
*
* @return NULL on error, otherwise handle to control peer group
*/
-struct GNUNET_TESTING_PeerGroup *GNUNET_TESTING_daemons_start (const struct
- GNUNET_CONFIGURATION_Handle
- *cfg,
- unsigned int
- total,
- unsigned int
- max_concurrent_connections,
- unsigned int
- max_concurrent_ssh,
- struct
- GNUNET_TIME_Relative
- timeout,
- GNUNET_TESTING_NotifyHostkeyCreated
- hostkey_callback,
- void
- *hostkey_cls,
- GNUNET_TESTING_NotifyDaemonRunning
- cb, void *cb_cls,
- GNUNET_TESTING_NotifyConnection
- connect_callback,
- void
- *connect_callback_cls,
- const struct
- GNUNET_TESTING_Host
- *hostnames);
+struct GNUNET_TESTING_PeerGroup *
+GNUNET_TESTING_daemons_start (const struct GNUNET_CONFIGURATION_Handle *cfg,
+ unsigned int total,
+ unsigned int max_concurrent_connections,
+ unsigned int max_concurrent_ssh,
+ struct GNUNET_TIME_Relative timeout,
+ GNUNET_TESTING_NotifyHostkeyCreated
+ hostkey_callback, void *hostkey_cls,
+ GNUNET_TESTING_NotifyDaemonRunning cb,
+ void *cb_cls,
+ GNUNET_TESTING_NotifyConnection connect_callback,
+ void *connect_callback_cls,
+ const struct GNUNET_TESTING_Host *hostnames);
+
/**
* Function which continues a peer group starting up
/**
- * Establish a connection between two GNUnet daemons.
+ * Handle for an active request to connect two peers.
+ */
+struct GNUNET_TESTING_ConnectContext;
+
+
+/**
+ * Establish a connection between two GNUnet daemons. The daemons
+ * must both be running and not be stopped until either the
+ * 'cb' callback is called OR the connection request has been
+ * explicitly cancelled.
*
* @param d1 handle for the first daemon
* @param d2 handle for the second daemon
* the HELLO has already been exchanged
* @param cb function to call at the end
* @param cb_cls closure for cb
+ * @return handle to cancel the request, NULL on error
*/
-void
+struct GNUNET_TESTING_ConnectContext *
GNUNET_TESTING_daemons_connect (struct GNUNET_TESTING_Daemon *d1,
struct GNUNET_TESTING_Daemon *d2,
struct GNUNET_TIME_Relative timeout,
void *cb_cls);
+
+/**
+ * Cancel an attempt to connect two daemons.
+ *
+ * @param cc connect context
+ */
+void
+GNUNET_TESTING_daemons_connect_cancel (struct GNUNET_TESTING_ConnectContext
+ *cc);
+
+
+
/**
* Restart all peers in the given group.
*
unsigned int
GNUNET_TESTING_daemons_running (struct GNUNET_TESTING_PeerGroup *pg);
+
/**
* Simulate churn by stopping some peers (and possibly
* re-starting others if churn is called multiple times). This
*/
void
GNUNET_TESTING_daemons_churn (struct GNUNET_TESTING_PeerGroup *pg,
- char *service,
- unsigned int voff,
+ char *service, unsigned int voff,
unsigned int von,
struct GNUNET_TIME_Relative timeout,
GNUNET_TESTING_NotifyCompletion cb, void *cb_cls);
-/*
+
+
+/**
* Start a given service for each of the peers in the peer group.
*
* @param pg handle for the peer group
GNUNET_TESTING_NotifyCompletion cb,
void *cb_cls);
+
/**
* Callback function to process statistic values.
*
uint64_t value,
int is_persistent);
+
/**
* Iterate over all (running) peers in the peer group, retrieve
* all statistics from each.
GNUNET_TESTING_STATISTICS_Iterator proc,
void *cls);
+
/**
* Topologies supported for testbeds.
*/
GNUNET_TESTING_topology_get (enum GNUNET_TESTING_Topology *topology,
const char *topology_string);
+
/**
* Get connect topology option from string input.
*
enum GNUNET_TESTING_Topology restrict_topology,
const char *restrict_transports);
+
/**
* Iterate over all (running) peers in the peer group, retrieve
* all connections that each currently has.
GNUNET_TESTING_get_topology (struct GNUNET_TESTING_PeerGroup *pg,
GNUNET_TESTING_NotifyTopology cb, void *cls);
+
/**
* Stop the connection process temporarily.
*
* @param pg the peer group to stop connecting
*/
-void GNUNET_TESTING_stop_connections (struct GNUNET_TESTING_PeerGroup *pg);
+void
+GNUNET_TESTING_stop_connections (struct GNUNET_TESTING_PeerGroup *pg);
+
/**
* Resume the connection process.
*
* @param pg the peer group to resume connecting
*/
-void GNUNET_TESTING_resume_connections (struct GNUNET_TESTING_PeerGroup *pg);
+void
+GNUNET_TESTING_resume_connections (struct GNUNET_TESTING_PeerGroup *pg);
+
/**
* There are many ways to connect peers that are supported by this function.
GNUNET_TESTING_NotifyCompletion
notify_callback, void *notify_cls);
+
/**
* Start or stop an individual peer from the given group.
*
*/
void
GNUNET_TESTING_daemons_vary (struct GNUNET_TESTING_PeerGroup *pg,
- unsigned int offset,
- int desired_status,
+ unsigned int offset, int desired_status,
struct GNUNET_TIME_Relative timeout,
GNUNET_TESTING_NotifyCompletion cb, void *cb_cls);
+
/**
* Start a peer group with a given number of peers. Notify
* on completion of peer startup and connection based on given
*
* @return NULL on error, otherwise handle to control peer group
*/
-struct GNUNET_TESTING_PeerGroup *GNUNET_TESTING_peergroup_start (const struct
- GNUNET_CONFIGURATION_Handle
- *cfg,
- unsigned int
- total,
- struct
- GNUNET_TIME_Relative
- timeout,
- GNUNET_TESTING_NotifyConnection
- connect_cb,
- GNUNET_TESTING_NotifyCompletion
- peergroup_cb,
- void
- *peergroup_cls,
- const struct
- GNUNET_TESTING_Host
- *hostnames);
+struct GNUNET_TESTING_PeerGroup *
+GNUNET_TESTING_peergroup_start (const struct GNUNET_CONFIGURATION_Handle *cfg,
+ unsigned int total,
+ struct GNUNET_TIME_Relative timeout,
+ GNUNET_TESTING_NotifyConnection connect_cb,
+ GNUNET_TESTING_NotifyCompletion peergroup_cb,
+ void *peergroup_cls,
+ const struct GNUNET_TESTING_Host *hostnames);
+
/**
* Print current topology to a graphviz readable file.
projects / oweals / gnunet.git / blobdiff