X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;ds=sidebyside;f=tests%2Flibmemcached_world.h;h=5fab96fe2a9e71f00db4d24061fb6f5f008433d6;hb=e43f018db5ff3167a060cd383f017147cebe68c2;hp=9f8b657ac844babf903fb4cbf579afe77bc92e21;hpb=5dbc64bfe7b86b105b1c552eaa2b3f54453db2bc;p=m6w6%2Flibmemcached diff --git a/tests/libmemcached_world.h b/tests/libmemcached_world.h index 9f8b657a..5fab96fe 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"); } @@ -209,63 +208,66 @@ 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) +class LibmemcachedRunner : public libtest::Runner { +public: + test_return_t run(test_callback_fn* func, void *object) { - 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 _runner_default(libmemcached_test_callback_fn(func), (libmemcached_test_container_st*)object); } - return TEST_SUCCESS; -} - -static test_return_t _pre_runner_default(libmemcached_test_callback_fn func, libmemcached_test_container_st *container) -{ - if (func) + test_return_t pre(test_callback_fn* func, void *object) { - return func(container->parent); + return _pre_runner_default(libmemcached_test_callback_fn(func), (libmemcached_test_container_st*)object); } - return TEST_SUCCESS; -} - -static test_return_t _post_runner_default(libmemcached_test_callback_fn func, libmemcached_test_container_st *container) -{ - if (func) + test_return_t post(test_callback_fn* func, void *object) { - return func(container->parent); + return _post_runner_default(libmemcached_test_callback_fn(func), (libmemcached_test_container_st*)object); } - return TEST_SUCCESS; -} - -class LibmemcachedRunner : public libtest::Runner { -public: - test_return_t run(test_callback_fn* func, void *object) +private: + test_return_t _runner_default(libmemcached_test_callback_fn func, libmemcached_test_container_st *container) { - return _runner_default(libmemcached_test_callback_fn(func), (libmemcached_test_container_st*)object); + test_compare(true, check()); + + 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; } - test_return_t pre(test_callback_fn* func, void *object) + test_return_t _pre_runner_default(libmemcached_test_callback_fn func, libmemcached_test_container_st *container) { - return _pre_runner_default(libmemcached_test_callback_fn(func), (libmemcached_test_container_st*)object); + if (func) + { + return func(container->parent); + } + + return TEST_SUCCESS; } - test_return_t post(test_callback_fn* func, void *object) + test_return_t _post_runner_default(libmemcached_test_callback_fn func, libmemcached_test_container_st *container) { - return _post_runner_default(libmemcached_test_callback_fn(func), (libmemcached_test_container_st*)object); + if (func) + { + return func(container->parent); + } + + return TEST_SUCCESS; } };