X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;ds=sidebyside;f=tests%2Flibmemcached_world.h;h=181379868be7b48abe6d34b93df7499219040002;hb=93dec285cdb4aab2bff0bae0d50e033b69560181;hp=2e7aa25da818cbeede99ead981ecab409dfa739a;hpb=a101fe771182e664d67a1609a6d9dee3d161dc81;p=awesomized%2Flibmemcached diff --git a/tests/libmemcached_world.h b/tests/libmemcached_world.h index 2e7aa25d..18137986 100644 --- a/tests/libmemcached_world.h +++ b/tests/libmemcached_world.h @@ -39,8 +39,6 @@ #pragma once -#include - /* The structure we use for the test system */ struct libmemcached_test_container_st { @@ -78,48 +76,25 @@ static void *world_create(libtest::server_startup_st& servers, test_return_t& er for (uint32_t x= 0; x < servers.count(); x++) { - in_port_t port; - - char variable_buffer[1024]; - snprintf(variable_buffer, sizeof(variable_buffer), "LIBMEMCACHED_PORT_%u", x); + in_port_t port= libtest::get_free_port(); - char *var; - if ((var= getenv(variable_buffer))) - { - port= in_port_t(atoi(var)); - } - else - { - port= in_port_t(TEST_PORT_BASE +x); - } - - const char *argv[1]= { "memcached" }; if (servers.sasl()) { - if (not server_startup(servers, "memcached-sasl", port, 1, argv)) + if (server_startup(servers, "memcached-sasl", port, 0, NULL) == false) { - error= TEST_FATAL; - return NULL; + fatal_message("Could not start memcached-sasl"); } } else { - if (not server_startup(servers, "memcached", port, 1, argv)) + if (server_startup(servers, "memcached", port, 0, NULL) == false) { - error= TEST_FATAL; - return NULL; + fatal_message("Could not start memcached"); } } } libmemcached_test_container_st *global_container= new libmemcached_test_container_st(servers); - if (global_container == NULL) - { - error= TEST_MEMORY_ALLOCATION_FAILURE; - return NULL; - } - - error= TEST_SUCCESS; return global_container; } @@ -153,17 +128,6 @@ static test_return_t world_container_startup(libmemcached_test_container_st *con } } - for (uint32_t host= 0; host < memcached_server_count(container->parent); ++host) - { - memcached_server_instance_st instance= - memcached_server_instance_by_position(container->parent, host); - - if (instance->type == MEMCACHED_CONNECTION_TCP) - { - test_true_got(memcached_server_port(instance) >= TEST_PORT_BASE, memcached_server_port(instance)); - } - } - return TEST_SUCCESS; } @@ -201,8 +165,7 @@ 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); + memcached_server_instance_st instance= memcached_server_instance_by_position(container->memc, loop); test_compare(-1, instance->fd); test_compare(0U, instance->cursor_active);