diff options
Diffstat (limited to 'src/lockmanager/test_lockmanager_api_servercrash.c')
| -rw-r--r-- | src/lockmanager/test_lockmanager_api_servercrash.c | 190 |
1 files changed, 55 insertions, 135 deletions
diff --git a/src/lockmanager/test_lockmanager_api_servercrash.c b/src/lockmanager/test_lockmanager_api_servercrash.c index 3fa6418..a37d614 100644 --- a/src/lockmanager/test_lockmanager_api_servercrash.c +++ b/src/lockmanager/test_lockmanager_api_servercrash.c @@ -27,14 +27,17 @@ #include "platform.h" #include "gnunet_util_lib.h" #include "gnunet_lockmanager_service.h" +#include "gnunet_testing_lib.h" -#define VERBOSE GNUNET_YES - -#define VERBOSE_ARM 1 - +/** + * Generic logging shorthand + */ #define LOG(kind,...) \ GNUNET_log (kind, __VA_ARGS__) +/** + * Relative seconds shorthand + */ #define TIME_REL_SECONDS(min) \ GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, min) @@ -42,34 +45,34 @@ * Various steps of the test */ enum Test - { +{ /** * Signal test failure */ - TEST_FAIL, + TEST_FAIL, /** * Testing just began */ - TEST_INIT, + TEST_INIT, /** * Client 1 has got the lock successfully; Client 2 should try to acquire * the lock now; after some time client 1 has to release the lock */ - TEST_CLIENT1_LOCK_SUCCESS, + TEST_CLIENT1_LOCK_SUCCESS, /** * Client 2 has got the lock; Server should crash now; */ - TEST_CLIENT2_LOCK_SUCCESS, + TEST_CLIENT2_LOCK_SUCCESS, /** * Client 2 should get lock release due to server crash; Should call * shutdown now */ - TEST_CLIENT2_SERVER_CRASH_SUCCESS - }; + TEST_CLIENT2_SERVER_CRASH_SUCCESS +}; /** * The testing result @@ -77,14 +80,9 @@ enum Test static enum Test result; /** - * The process id of the GNUNET ARM process - */ -static struct GNUNET_OS_Process *arm_pid = NULL; - -/** * Configuration Handle */ -static struct GNUNET_CONFIGURATION_Handle *config; +static const struct GNUNET_CONFIGURATION_Handle *config; /** * The handle to the lockmanager service @@ -111,6 +109,11 @@ static struct GNUNET_LOCKMANAGER_LockingRequest *request2; */ static GNUNET_SCHEDULER_TaskIdentifier abort_task_id; +/** + * Our peer + */ +static struct GNUNET_TESTING_Peer *self; + /** * Shutdown nicely @@ -119,7 +122,7 @@ static GNUNET_SCHEDULER_TaskIdentifier abort_task_id; * @param tc the task context */ static void -do_shutdown (void *cls, const const struct GNUNET_SCHEDULER_TaskContext *tc) +do_shutdown (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) { if (GNUNET_SCHEDULER_NO_TASK != abort_task_id) { @@ -130,18 +133,6 @@ do_shutdown (void *cls, const const struct GNUNET_SCHEDULER_TaskContext *tc) GNUNET_LOCKMANAGER_disconnect (handle); if (NULL != handle2) GNUNET_LOCKMANAGER_disconnect (handle2); - if (NULL != arm_pid) - { - if (0 != GNUNET_OS_process_kill (arm_pid, SIGTERM)) - { - LOG (GNUNET_ERROR_TYPE_DEBUG, - "Kill gnunet-service-arm manually\n"); - } - GNUNET_OS_process_wait (arm_pid); - GNUNET_OS_process_destroy (arm_pid); - } - if (NULL != config) - GNUNET_CONFIGURATION_destroy (config); } @@ -152,7 +143,7 @@ do_shutdown (void *cls, const const struct GNUNET_SCHEDULER_TaskContext *tc) * @param tc the task context */ static void -do_abort (void *cls, const const struct GNUNET_SCHEDULER_TaskContext *tc) +do_abort (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) { LOG (GNUNET_ERROR_TYPE_DEBUG, "Aborting test...\n"); abort_task_id = GNUNET_SCHEDULER_NO_TASK; @@ -166,33 +157,29 @@ do_abort (void *cls, const const struct GNUNET_SCHEDULER_TaskContext *tc) * * @param cls the handle * - * @param domain_name the locking domain of the lock + * @param domain_name the locking domain of the lock * * @param lock the lock for which this status is relevant * * @param status GNUNET_LOCKMANAGER_SUCCESS if the lock has been successfully * acquired; GNUNET_LOCKMANAGER_RELEASE when the acquired lock is lost */ -static void -status_cb (void *cls, - const char *domain_name, - uint32_t lock, +static void +status_cb (void *cls, const char *domain_name, uint32_t lock, enum GNUNET_LOCKMANAGER_Status status) { LOG (GNUNET_ERROR_TYPE_DEBUG, - "Status change callback called on lock: %d of domain: %s\n", - lock, domain_name); + "Status change callback called on lock: %d of domain: %s\n", lock, + domain_name); switch (result) { case TEST_INIT: GNUNET_assert (handle == cls); GNUNET_assert (GNUNET_LOCKMANAGER_SUCCESS == status); result = TEST_CLIENT1_LOCK_SUCCESS; - request2 = GNUNET_LOCKMANAGER_acquire_lock (handle2, - "GNUNET_LOCKMANAGER_TESTING", - 99, - &status_cb, - handle2); + request2 = + GNUNET_LOCKMANAGER_acquire_lock (handle2, "GNUNET_LOCKMANAGER_TESTING", + 99, &status_cb, handle2); GNUNET_assert (NULL != request2); GNUNET_LOCKMANAGER_cancel_request (request); request = NULL; @@ -201,15 +188,8 @@ status_cb (void *cls, GNUNET_assert (handle2 == cls); GNUNET_assert (GNUNET_LOCKMANAGER_SUCCESS == status); result = TEST_CLIENT2_LOCK_SUCCESS; - /* We should kill the lockmanager process */ - if (0 != GNUNET_OS_process_kill (arm_pid, SIGTERM)) - { - LOG (GNUNET_ERROR_TYPE_DEBUG, - "Kill gnunet-service-arm manually\n"); - } - GNUNET_OS_process_wait (arm_pid); - GNUNET_OS_process_destroy (arm_pid); - arm_pid =NULL; + /* We should stop our peer to simulate crash in lockmanager service */ + GNUNET_TESTING_peer_stop (self); break; case TEST_CLIENT2_LOCK_SUCCESS: GNUNET_assert (handle2 == cls); @@ -217,110 +197,50 @@ status_cb (void *cls, GNUNET_assert (99 == lock); GNUNET_assert (0 == strcmp (domain_name, "GNUNET_LOCKMANAGER_TESTING")); result = TEST_CLIENT2_SERVER_CRASH_SUCCESS; - GNUNET_SCHEDULER_add_delayed (TIME_REL_SECONDS (1), - &do_shutdown, - NULL); + GNUNET_LOCKMANAGER_cancel_request (request2); + request2 = NULL; + GNUNET_SCHEDULER_add_delayed (TIME_REL_SECONDS (1), &do_shutdown, NULL); break; default: GNUNET_assert (0); /* We should never reach here */ } - } /** - * Testing function - * - * @param cls NULL - * @param tc the task context + * Main point of test execution */ static void -test (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) -{ +run (void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg, + struct GNUNET_TESTING_Peer *peer) +{ + config = cfg; + self = peer; result = TEST_INIT; handle = GNUNET_LOCKMANAGER_connect (config); GNUNET_assert (NULL != handle); handle2 = GNUNET_LOCKMANAGER_connect (config); - - request = GNUNET_LOCKMANAGER_acquire_lock (handle, - "GNUNET_LOCKMANAGER_TESTING", - 99, - &status_cb, - handle); - GNUNET_assert (NULL != request); - abort_task_id = GNUNET_SCHEDULER_add_delayed (TIME_REL_SECONDS (10), - &do_abort, - NULL); -} - -/** - * Main point of test execution - */ -static void -run (void *cls, char *const *args, const char *cfgfile, - const struct GNUNET_CONFIGURATION_Handle *cfg) -{ - LOG (GNUNET_ERROR_TYPE_DEBUG, "Starting test...\n"); - config = GNUNET_CONFIGURATION_dup (cfg); - arm_pid = - GNUNET_OS_start_process (GNUNET_YES, NULL, NULL, "gnunet-service-arm", - "gnunet-service-arm", -#if VERBOSE_ARM - "-L", "DEBUG", -#endif - "-c", "test_lockmanager_api.conf", NULL); - - GNUNET_assert (NULL != arm_pid); - GNUNET_SCHEDULER_add_delayed (TIME_REL_SECONDS (3), - &test, - NULL); + request = + GNUNET_LOCKMANAGER_acquire_lock (handle, "GNUNET_LOCKMANAGER_TESTING", 99, + &status_cb, handle); + GNUNET_assert (NULL != request); + abort_task_id = + GNUNET_SCHEDULER_add_delayed (TIME_REL_SECONDS (10), &do_abort, NULL); } /** * Main function */ -int main (int argc, char **argv) +int +main (int argc, char **argv) { - int ret; - - char *const argv2[] = { "test-lockmanager-api-servercrash", - "-c", "test_lockmanager_api.conf", -#if VERBOSE - "-L", "DEBUG", -#endif - NULL - }; - - struct GNUNET_GETOPT_CommandLineOption options[] = { - GNUNET_GETOPT_OPTION_END - }; - - GNUNET_log_setup ("test-lockmanager-api-servercrash", -#if VERBOSE - "DEBUG", -#else - "WARNING", -#endif - NULL); - - ret = - GNUNET_PROGRAM_run ((sizeof (argv2) / sizeof (char *)) - 1, argv2, - "test-lockmanager-api-servercrash", - "nohelp", options, &run, NULL); - - if (GNUNET_OK != ret) - { - LOG (GNUNET_ERROR_TYPE_WARNING, "run failed with error code %d\n", - ret); + if (0 != + GNUNET_TESTING_peer_run ("test_lockmanager_api_servercrash", + "test_lockmanager_api.conf", &run, NULL)) return 1; - } - if (TEST_CLIENT2_SERVER_CRASH_SUCCESS != result) - { - LOG (GNUNET_ERROR_TYPE_WARNING, "test failed\n"); - return 1; - } - LOG (GNUNET_ERROR_TYPE_INFO, "test OK\n"); - return 0; + return (TEST_CLIENT2_SERVER_CRASH_SUCCESS != result) ? 1 : 0; } + +/* end of test_lockmanager_api_servercrash.c */ |