X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=tests%2Flibmemcached_world_socket.h;h=fbfb5a9cd14a2353135646fbc9bea47f8a649316;hb=cc47230b8dfe0bcd31d4f45ca84d2dd35ae360f0;hp=8016dba4ad6229dcafaf465d3f2b889ee39a42ba;hpb=9069819ac2940397e96210867e0666b801b97f60;p=m6w6%2Flibmemcached diff --git a/tests/libmemcached_world_socket.h b/tests/libmemcached_world_socket.h index 8016dba4..fbfb5a9c 100644 --- a/tests/libmemcached_world_socket.h +++ b/tests/libmemcached_world_socket.h @@ -41,23 +41,11 @@ #include -/* The structure we use for the test system */ -struct libmemcached_test_container_st -{ - libtest::server_startup_st& construct; - memcached_st *parent; - memcached_st *memc; - - libmemcached_test_container_st(libtest::server_startup_st &construct_arg) : - construct(construct_arg), - parent(NULL), - memc(NULL) - { } -}; +#include "tests/libmemcached_test_container.h" static void *world_create(libtest::server_startup_st& servers, test_return_t& error) { - if (HAVE_MEMCACHED_BINARY == 0) + if (libtest::has_memcached() == false) { error= TEST_SKIPPED; return NULL; @@ -80,99 +68,6 @@ static void *world_create(libtest::server_startup_st& servers, test_return_t& er return global_container; } -static test_return_t world_container_startup(libmemcached_test_container_st *container) -{ - char buffer[BUFSIZ]; - - test_compare_got(MEMCACHED_SUCCESS, - libmemcached_check_configuration(container->construct.option_string().c_str(), container->construct.option_string().size(), - buffer, sizeof(buffer)), - container->construct.option_string().c_str()); - - test_null(container->parent); - container->parent= memcached(container->construct.option_string().c_str(), container->construct.option_string().size()); - test_true(container->parent); - test_compare(MEMCACHED_SUCCESS, memcached_version(container->parent)); - - if (container->construct.sasl()) - { - if (memcached_failed(memcached_behavior_set(container->parent, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL, 1))) - { - memcached_free(container->parent); - return TEST_FAILURE; - } - - if (memcached_failed(memcached_set_sasl_auth_data(container->parent, container->construct.username().c_str(), container->construct.password().c_str()))) - { - memcached_free(container->parent); - return TEST_FAILURE; - } - } - - return TEST_SUCCESS; -} - -static test_return_t world_container_shutdown(libmemcached_test_container_st *container) -{ - memcached_free(container->parent); - container->parent= NULL; - - return TEST_SUCCESS; -} - -static test_return_t world_test_startup(libmemcached_test_container_st *container) -{ - test_true(container); - test_null(container->memc); - test_true(container->parent); - container->memc= memcached_clone(NULL, container->parent); - test_true(container->memc); - - 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); - memcached_free(container->memc); - container->memc= NULL; - - return TEST_SUCCESS; -} - static bool world_destroy(void *object) { libmemcached_test_container_st *container= (libmemcached_test_container_st *)object;