X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=tests%2Flibmemcached_world.h;h=2d05a5d596e78d6a40ddabd874666c3d79843c7e;hb=7253c10fe79f6a72b0aec419560823a16ad55a0a;hp=9f8b657ac844babf903fb4cbf579afe77bc92e21;hpb=5dbc64bfe7b86b105b1c552eaa2b3f54453db2bc;p=m6w6%2Flibmemcached diff --git a/tests/libmemcached_world.h b/tests/libmemcached_world.h index 9f8b657a..2d05a5d5 100644 --- a/tests/libmemcached_world.h +++ b/tests/libmemcached_world.h @@ -74,21 +74,20 @@ static void *world_create(libtest::server_startup_st& servers, test_return_t& er return NULL; } - for (uint32_t x= 0; x < servers.count(); x++) + for (uint32_t x= 0; x < servers.servers_to_run(); x++) { in_port_t port= libtest::get_free_port(); - const char *argv[1]= { "memcached" }; if (servers.sasl()) { - if (server_startup(servers, "memcached-sasl", port, 1, argv) == false) + if (server_startup(servers, "memcached-sasl", port, 0, NULL) == false) { fatal_message("Could not start memcached-sasl"); } } else { - if (server_startup(servers, "memcached", port, 1, argv) == false) + if (server_startup(servers, "memcached", port, 0, NULL) == false) { fatal_message("Could not start memcached"); } @@ -151,38 +150,6 @@ static test_return_t world_test_startup(libmemcached_test_container_st *containe return TEST_SUCCESS; } -test_return_t world_flush(libmemcached_test_container_st *container); -test_return_t world_flush(libmemcached_test_container_st *container) -{ - test_true(container->memc); - memcached_flush(container->memc, 0); - memcached_quit(container->memc); - - return TEST_SUCCESS; -} - -static test_return_t world_pre_run(libmemcached_test_container_st *container) -{ - test_true(container->memc); - for (uint32_t loop= 0; loop < memcached_server_list_count(container->memc->servers); loop++) - { - memcached_server_instance_st instance= memcached_server_instance_by_position(container->memc, loop); - - test_compare(-1, instance->fd); - test_compare(0U, instance->cursor_active); - } - - return TEST_SUCCESS; -} - - -static test_return_t world_post_run(libmemcached_test_container_st *container) -{ - test_true(container->memc); - - return TEST_SUCCESS; -} - static test_return_t world_on_error(test_return_t , libmemcached_test_container_st *container) { test_true(container->memc); @@ -209,64 +176,4 @@ static bool world_destroy(void *object) typedef test_return_t (*libmemcached_test_callback_fn)(memcached_st *); -static test_return_t _runner_default(libmemcached_test_callback_fn func, libmemcached_test_container_st *container) -{ - if (func) - { - test_true(container); - test_true(container->memc); - test_return_t ret; - try { - ret= func(container->memc); - } - catch (std::exception& e) - { - libtest::Error << e.what(); - return TEST_FAILURE; - } - - return ret; - } - - return TEST_SUCCESS; -} - -static test_return_t _pre_runner_default(libmemcached_test_callback_fn func, libmemcached_test_container_st *container) -{ - if (func) - { - return func(container->parent); - } - - return TEST_SUCCESS; -} - -static test_return_t _post_runner_default(libmemcached_test_callback_fn func, libmemcached_test_container_st *container) -{ - if (func) - { - return func(container->parent); - } - - return TEST_SUCCESS; -} - -class LibmemcachedRunner : public libtest::Runner { -public: - test_return_t run(test_callback_fn* func, void *object) - { - return _runner_default(libmemcached_test_callback_fn(func), (libmemcached_test_container_st*)object); - } - - test_return_t pre(test_callback_fn* func, void *object) - { - return _pre_runner_default(libmemcached_test_callback_fn(func), (libmemcached_test_container_st*)object); - } - - test_return_t post(test_callback_fn* func, void *object) - { - return _post_runner_default(libmemcached_test_callback_fn(func), (libmemcached_test_container_st*)object); - } -}; - -static LibmemcachedRunner defualt_libmemcached_runner; +#include "tests/runner.h"