#include "platform.h"
#include "gnunet_util_lib.h"
#include "gnunet_testing_lib.h"
#include "gnunet_testing_ng_lib.h"
#include "gnunet_testing_plugin.h"
#include "gnunet_testing_netjail_lib.h"
#include "testing.h"
#include "testing_cmds.h"
#include "gnunet_testing_barrier.h"
#include <zlib.h>
Go to the source code of this file.
Data Structures | |
struct | NodeIdentifier |
Struct with information about a specific node and the whole network namespace setup. More... | |
struct | WriteContext |
Context for a single write on a chunk of memory. More... | |
Macros | |
#define | LOG(kind, ...) GNUNET_log (kind, __VA_ARGS__) |
Generic logging shortcut. More... | |
#define | LOG_DEBUG(...) LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__) |
Debug logging shorthand. More... | |
#define | NODE_BASE_IP "192.168.15." |
#define | KNOWN_BASE_IP "92.68.151." |
#define | ROUTER_BASE_IP "92.68.150." |
Functions | |
static void | do_shutdown (void *cls) |
Task to shut down cleanly. More... | |
static void | write_task (void *cls) |
Task to write to the standard out. More... | |
static void | write_message (struct GNUNET_MessageHeader *message, size_t msg_length) |
Callback to write a message to the master loop. More... | |
static void | delay_shutdown_cb () |
struct GNUNET_MessageHeader * | GNUNET_TESTING_send_local_test_finished_msg () |
static void | finished_cb (enum GNUNET_GenericReturnValue rv) |
static enum GNUNET_GenericReturnValue | tokenizer_cb (void *cls, const struct GNUNET_MessageHeader *message) |
Functions with this signature are called whenever a complete message is received by the tokenizer. More... | |
static void | read_task (void *cls) |
Task to read from stdin. More... | |
static void | run (void *cls, char *const *args, const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *cfg) |
Main function that will be run. More... | |
static void | sighandler_child_death () |
Signal handler called for SIGCHLD. More... | |
int | main (int argc, char **argv) |
Main function. More... | |
Variables | |
struct GNUNET_SCHEDULER_Task * | finished_task |
struct GNUNET_TESTING_Interpreter * | is |
struct TestcasePlugin * | plugin |
The process handle to the testbed service. More... | |
struct GNUNET_MessageStreamTokenizer * | tokenizer |
Our message stream tokenizer. More... | |
static struct GNUNET_DISK_FileHandle * | stdin_fd |
Disk handle from stdin. More... | |
static struct GNUNET_DISK_FileHandle * | stdout_fd |
Disk handle for stdout. More... | |
static struct GNUNET_DISK_PipeHandle * | sigpipe |
Pipe used to communicate shutdown via signal. More... | |
static struct GNUNET_SCHEDULER_Task * | read_task_id |
Task identifier for the read task. More... | |
static struct GNUNET_SCHEDULER_Task * | write_task_id |
Task identifier for the write task. More... | |
static int | done_reading |
Are we done reading messages from stdin? More... | |
static int | status |
Result to return in case we fail. More... | |
#define LOG | ( | kind, | |
... | |||
) | GNUNET_log (kind, __VA_ARGS__) |
Generic logging shortcut.
Definition at line 55 of file gnunet-cmds-helper.c.
#define LOG_DEBUG | ( | ... | ) | LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__) |
Debug logging shorthand.
Definition at line 60 of file gnunet-cmds-helper.c.
#define NODE_BASE_IP "192.168.15." |
Definition at line 62 of file gnunet-cmds-helper.c.
#define KNOWN_BASE_IP "92.68.151." |
Definition at line 64 of file gnunet-cmds-helper.c.
#define ROUTER_BASE_IP "92.68.150." |
Definition at line 66 of file gnunet-cmds-helper.c.
|
static |
Task to shut down cleanly.
cls | NULL |
Definition at line 203 of file gnunet-cmds-helper.c.
References WriteContext::data, GNUNET_DISK_file_close(), GNUNET_free, GNUNET_MST_destroy(), GNUNET_PLUGIN_unload(), GNUNET_SCHEDULER_cancel(), TestcasePlugin::library_name, LOG_DEBUG, plugin, read_task_id, stdin_fd, stdout_fd, tokenizer, and write_task_id.
Referenced by run().
|
static |
Task to write to the standard out.
cls | the WriteContext |
Definition at line 240 of file gnunet-cmds-helper.c.
References WriteContext::data, GNUNET_assert, GNUNET_DISK_file_write(), GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, GNUNET_SCHEDULER_add_write_file(), GNUNET_SYSERR, GNUNET_TIME_UNIT_FOREVER_REL, WriteContext::length, LOG, WriteContext::pos, stdout_fd, write_task(), and write_task_id.
Referenced by write_message(), and write_task().
|
static |
Callback to write a message to the master loop.
Definition at line 279 of file gnunet-cmds-helper.c.
References WriteContext::data, GNUNET_ERROR_TYPE_ERROR, GNUNET_log, GNUNET_new, GNUNET_SCHEDULER_add_write_file(), GNUNET_TIME_UNIT_FOREVER_REL, WriteContext::length, stdout_fd, write_task(), and write_task_id.
Referenced by finished_cb(), and tokenizer_cb().
|
static |
Definition at line 298 of file gnunet-cmds-helper.c.
References GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, and GNUNET_SCHEDULER_shutdown().
Referenced by finished_cb().
struct GNUNET_MessageHeader * GNUNET_TESTING_send_local_test_finished_msg | ( | ) |
Definition at line 307 of file gnunet-cmds-helper.c.
References GNUNET_MESSAGE_TYPE_CMDS_HELPER_LOCAL_FINISHED, GNUNET_new, GNUNET_TESTING_CommandLocalFinished::header, GNUNET_MessageHeader::size, and GNUNET_MessageHeader::type.
|
static |
Definition at line 322 of file gnunet-cmds-helper.c.
References delay_shutdown_cb(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_log, GNUNET_MESSAGE_TYPE_CMDS_HELPER_LOCAL_FINISHED, GNUNET_new, GNUNET_SCHEDULER_add_delayed(), GNUNET_TIME_UNIT_SECONDS, GNUNET_TESTING_CommandLocalFinished::header, GNUNET_TESTING_CommandLocalFinished::rv, GNUNET_MessageHeader::size, GNUNET_MessageHeader::type, and write_message().
Referenced by GDS_u_send(), GNUNET_NAMESTORE_record_set_edit_cancel(), gnunet_send(), ip_send(), and tokenizer_cb().
|
static |
Functions with this signature are called whenever a complete message is received by the tokenizer.
Do not call #GNUNET_mst_destroy() in this callback
cls | identification of the client |
message | the actual message |
Definition at line 360 of file gnunet-cmds-helper.c.
References GNUNET_TESTING_PluginFunctions::all_local_tests_prepared, GNUNET_TESTING_PluginFunctions::all_peers_started, TestcasePlugin::api, dummy, finished_cb(), NodeIdentifier::global_n, TestcasePlugin::global_n, GNUNET_asprintf(), GNUNET_break, GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_malloc, GNUNET_MESSAGE_TYPE_CMDS_HELPER_ALL_LOCAL_TESTS_PREPARED, GNUNET_MESSAGE_TYPE_CMDS_HELPER_ALL_PEERS_STARTED, GNUNET_MESSAGE_TYPE_CMDS_HELPER_BARRIER_CROSSABLE, GNUNET_MESSAGE_TYPE_CMDS_HELPER_INIT, GNUNET_MESSAGE_TYPE_CMDS_HELPER_REPLY, GNUNET_new, GNUNET_OK, GNUNET_OS_get_libexec_binary_path(), GNUNET_PLUGIN_load(), GNUNET_SCHEDULER_shutdown(), GNUNET_strdup, GNUNET_strlcpy(), GNUNET_SYSERR, GNUNET_TESTING_finish_barrier_(), GNUNET_TESTING_CommandHelperReply::header, is, KNOWN_BASE_IP, TestcasePlugin::library_name, NodeIdentifier::local_m, TestcasePlugin::local_m, LOG, NodeIdentifier::m, TestcasePlugin::m, msg, NodeIdentifier::n, TestcasePlugin::n, NODE_BASE_IP, plugin, plugin_name, GNUNET_TESTING_CommandHelperInit::plugin_name_size, NodeIdentifier::read_file, ROUTER_BASE_IP, GNUNET_MessageHeader::size, GNUNET_TESTING_PluginFunctions::start_testcase, status, NodeIdentifier::topology_data, type, GNUNET_MessageHeader::type, and write_message().
Referenced by run().
|
static |
Task to read from stdin.
cls | NULL |
Definition at line 520 of file gnunet-cmds-helper.c.
References done_reading, GNUNET_break, GNUNET_break_op, GNUNET_DISK_file_read(), GNUNET_ERROR_TYPE_ERROR, GNUNET_MAX_MESSAGE_SIZE, GNUNET_MST_from_buffer(), GNUNET_NO, GNUNET_OK, GNUNET_SCHEDULER_add_read_file(), GNUNET_SCHEDULER_shutdown(), GNUNET_SYSERR, GNUNET_TIME_UNIT_FOREVER_REL, GNUNET_YES, LOG, LOG_DEBUG, read_task(), read_task_id, stdin_fd, and tokenizer.
Referenced by read_task(), and run().
|
static |
Main function that will be run.
cls | closure |
args | remaining command-line arguments |
cfgfile | name of the configuration file used (for saving, can be NULL!) |
cfg | configuration |
Definition at line 571 of file gnunet-cmds-helper.c.
References do_shutdown(), GNUNET_DISK_get_handle_from_native(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_MST_create(), GNUNET_SCHEDULER_add_read_file(), GNUNET_SCHEDULER_add_shutdown(), GNUNET_TIME_UNIT_FOREVER_REL, LOG, read_task(), read_task_id, stdin_fd, stdout_fd, tokenizer, and tokenizer_cb().
Referenced by main().
|
static |
Signal handler called for SIGCHLD.
Definition at line 600 of file gnunet-cmds-helper.c.
References GNUNET_break, GNUNET_DISK_file_write(), GNUNET_DISK_PIPE_END_WRITE, GNUNET_DISK_pipe_handle(), and sigpipe.
Referenced by main().
int main | ( | int | argc, |
char ** | argv | ||
) |
Main function.
argc | the number of command line arguments |
argv | command line arg array |
Definition at line 624 of file gnunet-cmds-helper.c.
References NodeIdentifier::global_n, GNUNET_assert, GNUNET_break, GNUNET_DISK_PF_NONE, GNUNET_DISK_pipe(), GNUNET_DISK_pipe_close(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_ERROR, GNUNET_free, GNUNET_GETOPT_OPTION_END, GNUNET_log, GNUNET_log_setup(), GNUNET_log_strerror, GNUNET_malloc, GNUNET_new, GNUNET_OK, GNUNET_PROGRAM_run(), GNUNET_SIGCHLD, GNUNET_SIGNAL_handler_install(), GNUNET_SIGNAL_handler_uninstall(), NodeIdentifier::local_m, LOG, NodeIdentifier::m, NodeIdentifier::n, options, read_file(), NodeIdentifier::read_file, ret, run(), shc_chld, sighandler_child_death(), sigpipe, status, and NodeIdentifier::topology_data.
struct GNUNET_SCHEDULER_Task* finished_task |
Definition at line 80 of file gnunet-cmds-helper.c.
struct GNUNET_TESTING_Interpreter* is |
Definition at line 82 of file gnunet-cmds-helper.c.
Referenced by backchannel_check_run(), barrier_reached_run(), barrier_run(), batch_run(), block_until_all_peers_started_run(), check_backchannel_encapsulation(), check_communicator_backchannel(), connect_peers_run(), delete_networks(), do_timeout(), exec_bash_script_run(), finish_test(), free_barrier_node_cb(), free_barrier_nodes(), free_barriers_cb(), get_addresses(), get_command(), GNUNET_NT_scanner_done(), GNUNET_NT_scanner_get_type(), GNUNET_NT_scanner_init(), GNUNET_TESTING_add_barrier_(), GNUNET_TESTING_add_netjail_helper_(), GNUNET_TESTING_finish_barrier_(), GNUNET_TESTING_get_barrier_(), GNUNET_TESTING_interpreter_fail(), GNUNET_TESTING_interpreter_get_current_command(), GNUNET_TESTING_interpreter_lookup_command(), GNUNET_TESTING_interpreter_lookup_command_all(), GNUNET_TESTING_interpreter_lookup_future_command(), GNUNET_TESTING_run(), handle_communicator_backchannel(), interface_proc(), interpreter_next(), interpreter_run(), join_room_run(), netjail_exec_run(), netjail_start_run(), netjail_stop_run(), notify_connect(), run_finish(), send_barrier_crossable(), send_simple_run(), start_peer_run(), start_service_run(), stop_peer_run(), stop_service_run(), stop_testing_system_run(), system_destroy_run(), and tokenizer_cb().
struct TestcasePlugin* plugin |
The process handle to the testbed service.
static struct GNUNET_OS_Process *cmd_binary_process; Plugin to dynamically load a test case.
Definition at line 154 of file gnunet-cmds-helper.c.
Referenced by __attribute__(), add_addr(), add_plugin(), core_connect_cb(), core_disconnect_cb(), core_init_cb(), create_source(), create_target(), database_connect(), database_prepare(), database_setup(), database_shutdown(), delete_by_rowid(), delete_old_block(), delete_value(), DHTU_gnunet_done(), DHTU_gnunet_init(), DHTU_ip_done(), DHTU_ip_init(), do_shutdown(), execute_get(), expire_blocks(), find_plugin(), find_source(), find_target(), free_value(), get_any(), get_records_and_call_iterator(), get_typed(), GNUNET_BLOCK_check_block(), GNUNET_BLOCK_check_query(), GNUNET_BLOCK_check_reply(), GNUNET_BLOCK_context_destroy(), GNUNET_BLOCK_get_key(), GNUNET_BLOCK_group_create(), gnunet_drop(), GNUNET_GNSRECORD_is_critical(), GNUNET_GNSRECORD_number_to_typename(), GNUNET_GNSRECORD_string_to_value(), GNUNET_GNSRECORD_typename_to_number(), GNUNET_GNSRECORD_value_to_string(), gnunet_hold(), GNUNET_RECLAIM_attribute_number_to_typename(), GNUNET_RECLAIM_attribute_string_to_value(), GNUNET_RECLAIM_attribute_typename_to_number(), GNUNET_RECLAIM_attribute_value_to_string(), GNUNET_RECLAIM_credential_get_attributes(), GNUNET_RECLAIM_credential_get_expiration(), GNUNET_RECLAIM_credential_get_issuer(), GNUNET_RECLAIM_credential_get_presentation(), GNUNET_RECLAIM_credential_number_to_typename(), GNUNET_RECLAIM_credential_string_to_value(), GNUNET_RECLAIM_credential_typename_to_number(), GNUNET_RECLAIM_credential_value_to_string(), GNUNET_RECLAIM_presentation_get_attributes(), GNUNET_RECLAIM_presentation_get_expiration(), GNUNET_RECLAIM_presentation_get_issuer(), GNUNET_RECLAIM_presentation_number_to_typename(), GNUNET_RECLAIM_presentation_string_to_value(), GNUNET_RECLAIM_presentation_typename_to_number(), GNUNET_RECLAIM_presentation_value_to_string(), gnunet_try_connect(), handle_core_message(), heap_get_keys(), heap_plugin_del(), heap_plugin_estimate_size(), heap_plugin_get(), heap_plugin_get_closest(), heap_plugin_get_expiration(), heap_plugin_get_key(), heap_plugin_get_replication(), heap_plugin_get_zero_anonymity(), heap_plugin_put(), heap_plugin_remove_key(), init_connection(), ip_send(), ip_try_connect(), libgnunet_plugin_datacache_heap_done(), libgnunet_plugin_datacache_heap_init(), libgnunet_plugin_datacache_postgres_done(), libgnunet_plugin_datacache_postgres_init(), libgnunet_plugin_datacache_sqlite_done(), libgnunet_plugin_datacache_sqlite_init(), libgnunet_plugin_datacache_template_done(), libgnunet_plugin_datacache_template_init(), libgnunet_plugin_datastore_heap_done(), libgnunet_plugin_datastore_heap_init(), libgnunet_plugin_datastore_postgres_done(), libgnunet_plugin_datastore_postgres_init(), libgnunet_plugin_datastore_sqlite_done(), libgnunet_plugin_datastore_sqlite_init(), libgnunet_plugin_datastore_template_done(), libgnunet_plugin_datastore_template_init(), libgnunet_plugin_namecache_flat_done(), libgnunet_plugin_namecache_flat_init(), libgnunet_plugin_namecache_postgres_done(), libgnunet_plugin_namecache_postgres_init(), libgnunet_plugin_namecache_sqlite_done(), libgnunet_plugin_namecache_sqlite_init(), libgnunet_plugin_namestore_flat_done(), libgnunet_plugin_namestore_flat_init(), libgnunet_plugin_namestore_postgres_done(), libgnunet_plugin_namestore_postgres_init(), libgnunet_plugin_namestore_sqlite_done(), libgnunet_plugin_namestore_sqlite_init(), libgnunet_plugin_peerstore_sqlite_done(), libgnunet_plugin_peerstore_sqlite_init(), libgnunet_plugin_rest_pabc_init(), libgnunet_plugin_rest_reclaim_done(), lookup_records(), namecache_cache_block(), namecache_expire_blocks(), namecache_lookup_block(), namecache_postgres_cache_block(), namecache_postgres_expire_blocks(), namecache_postgres_lookup_block(), namecache_sqlite_cache_block(), namecache_sqlite_expire_blocks(), namecache_sqlite_lookup_block(), namestore_flat_iterate_records(), namestore_flat_lookup_records(), namestore_flat_store_records(), namestore_flat_zone_to_name(), namestore_postgres_clear_editor_hint(), namestore_postgres_create_tables(), namestore_postgres_drop_tables(), namestore_postgres_edit_records(), namestore_postgres_iterate_records(), namestore_postgres_lookup_records(), namestore_postgres_store_records(), namestore_postgres_zone_to_name(), namestore_sqlite_create_tables(), namestore_sqlite_drop_tables(), namestore_sqlite_editor_hint_clear(), namestore_sqlite_iterate_records(), namestore_sqlite_store_records(), namestore_sqlite_zone_to_name(), nse_cb(), peerinfo_cb(), peerstore_sqlite_delete_records(), peerstore_sqlite_expire_records(), peerstore_sqlite_iterate_records(), peerstore_sqlite_store_record(), postgres_plugin_del(), postgres_plugin_drop(), postgres_plugin_estimate_size(), postgres_plugin_get(), postgres_plugin_get_closest(), postgres_plugin_get_expiration(), postgres_plugin_get_key(), postgres_plugin_get_keys(), postgres_plugin_get_replication(), postgres_plugin_get_zero_anonymity(), postgres_plugin_put(), postgres_plugin_remove_key(), process_ifcs(), process_result(), read_cb(), repl_proc(), REST_config_done(), REST_config_init(), REST_config_process_request(), REST_copying_done(), REST_copying_init(), REST_gns_done(), REST_gns_init(), REST_identity_done(), REST_identity_init(), REST_namestore_done(), REST_namestore_init(), REST_openid_done(), REST_openid_init(), REST_reclaim_done(), REST_reclaim_init(), run(), scan(), sqlite_plugin_del(), sqlite_plugin_drop(), sqlite_plugin_estimate_size(), sqlite_plugin_get_closest(), sqlite_plugin_get_expiration(), sqlite_plugin_get_key(), sqlite_plugin_get_keys(), sqlite_plugin_get_replication(), sqlite_plugin_get_zero_anonymity(), sqlite_plugin_put(), sqlite_plugin_remove_key(), start_helper(), and tokenizer_cb().
struct GNUNET_MessageStreamTokenizer* tokenizer |
Our message stream tokenizer.
Definition at line 159 of file gnunet-cmds-helper.c.
Referenced by do_shutdown(), read_task(), and run().
|
static |
Disk handle from stdin.
Definition at line 164 of file gnunet-cmds-helper.c.
Referenced by do_shutdown(), read_task(), and run().
|
static |
Disk handle for stdout.
Definition at line 169 of file gnunet-cmds-helper.c.
Referenced by do_shutdown(), run(), write_message(), and write_task().
|
static |
Pipe used to communicate shutdown via signal.
Definition at line 174 of file gnunet-cmds-helper.c.
Referenced by main(), and sighandler_child_death().
|
static |
Task identifier for the read task.
Definition at line 179 of file gnunet-cmds-helper.c.
Referenced by do_shutdown(), read_task(), and run().
|
static |
Task identifier for the write task.
Definition at line 184 of file gnunet-cmds-helper.c.
Referenced by do_shutdown(), write_message(), and write_task().
|
static |
Are we done reading messages from stdin?
Definition at line 189 of file gnunet-cmds-helper.c.
Referenced by read_task().
|
static |
Result to return in case we fail.
Definition at line 194 of file gnunet-cmds-helper.c.
Referenced by main(), and tokenizer_cb().