From: Michael Wallner Date: Tue, 13 Oct 2020 13:40:19 +0000 (+0200) Subject: testing: memslap X-Git-Tag: 1.1.0-beta1~236^2~2 X-Git-Url: https://git.m6w6.name/?a=commitdiff_plain;h=52d10244d2cb8059106b483da7170a4c9acc3b0a;p=awesomized%2Flibmemcached testing: memslap --- diff --git a/src/bin/memslap.cc b/src/bin/memslap.cc index 89649764..59fef02a 100644 --- a/src/bin/memslap.cc +++ b/src/bin/memslap.cc @@ -1,5 +1,5 @@ /* vim:expandtab:shiftwidth=2:tabstop=2:smarttab: - * + * * Libmemcached library * * Copyright (C) 2011-2012 Data Differential, http://datadifferential.com/ @@ -214,10 +214,10 @@ int main(int argc, char *argv[]) { opt_servers= strdup(temp); } - + if (opt_servers == NULL) { - std::cerr << "No Servers provided" << std::endl; + std::cerr << "No servers provided" << std::endl; exit(EXIT_FAILURE); } } diff --git a/test/tests/bin/memslap.cpp b/test/tests/bin/memslap.cpp new file mode 100644 index 00000000..dee7ebc3 --- /dev/null +++ b/test/tests/bin/memslap.cpp @@ -0,0 +1,43 @@ +#include "test/lib/common.hpp" +#include "test/lib/Shell.hpp" +#include "test/lib/MemcachedCluster.hpp" + +using Catch::Matchers::Contains; + +TEST_CASE("bin/memslap") { + Shell sh{string{TESTING_ROOT "/../src/bin"}}; + + SECTION("no servers provided") { + string output; + REQUIRE_FALSE(sh.run("memslap", output)); + REQUIRE(output == "No servers provided\n"); + } + + SECTION("--help") { + string output; + + REQUIRE(sh.run("memslap --help", output)); + REQUIRE_THAT(output, Contains("memslap")); + REQUIRE_THAT(output, Contains("v1")); + REQUIRE_THAT(output, Contains("help")); + REQUIRE_THAT(output, Contains("version")); + REQUIRE_THAT(output, Contains("option")); + REQUIRE_THAT(output, Contains("--")); + REQUIRE_THAT(output, Contains("=")); + } + + SECTION("with servers") { + auto test = MemcachedCluster::udp(); + auto flags = {"--binary", "--udp", "--flush", "--test=mget", "--test=get", "--tcp-nodelay", + "--non-blocking", "--initial-load=1000"}; + string servers{"--servers="}; + + for (const auto &server : test.cluster.getServers()) { + servers += "localhost:" + to_string(get(server.getSocketOrPort())) + ", "; + } + + for (const auto flag : flags) { + REQUIRE(sh.run("memslap --quiet --concurrency=2 " + servers + flag)); + } + } +} diff --git a/tests/memslap.cc b/tests/memslap.cc deleted file mode 100644 index a8fd1747..00000000 --- a/tests/memslap.cc +++ /dev/null @@ -1,192 +0,0 @@ -/* vim:expandtab:shiftwidth=2:tabstop=2:smarttab: - * - * Test memslap - * - * Copyright (C) 2011 Data Differential, http://datadifferential.com/ - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions are - * met: - * - * * Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * - * * Redistributions in binary form must reproduce the above - * copyright notice, this list of conditions and the following disclaimer - * in the documentation and/or other materials provided with the - * distribution. - * - * * The names of its contributors may not be used to endorse or - * promote products derived from this software without specific prior - * written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS - * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT - * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR - * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT - * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, - * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT - * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE - * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - * - */ - - -/* - Test that we are cycling the servers we are creating during testing. -*/ - -#include "mem_config.h" - -#include "libtest/test.hpp" -#include "libmemcached-1.0/memcached.h" - -using namespace libtest; - -#ifndef __INTEL_COMPILER -#pragma GCC diagnostic ignored "-Wstrict-aliasing" -#endif - -static std::string executable; - -static test_return_t quiet_test(void *) -{ - const char *args[]= { "--quiet", 0 }; - - test_compare(EXIT_FAILURE, exec_cmdline(executable, args, true)); - - return TEST_SUCCESS; -} - -static test_return_t help_test(void *) -{ - const char *args[]= { "--help", 0 }; - - test_compare(EXIT_SUCCESS, exec_cmdline(executable, args, true)); - - return TEST_SUCCESS; -} - -static test_return_t server_test(void *) -{ - char buffer[1024]; - snprintf(buffer, sizeof(buffer), "--servers=localhost:%d", int(default_port())); - const char *args[]= { buffer, 0 }; - - test_compare(EXIT_SUCCESS, exec_cmdline(executable, args, true)); - - return TEST_SUCCESS; -} - -static test_return_t server_concurrency_test(void *) -{ - char buffer[1024]; - snprintf(buffer, sizeof(buffer), "--servers=localhost:%d", int(default_port())); - const char *args[]= { buffer, "--concurrency=10", 0 }; - - test_compare(EXIT_SUCCESS, exec_cmdline(executable, args, true)); - - return TEST_SUCCESS; -} - -static test_return_t server_concurrency_initial_load_test(void *) -{ - char buffer[1024]; - snprintf(buffer, sizeof(buffer), "--servers=localhost:%d", int(default_port())); - const char *args[]= { buffer, "--concurrency=10", "--initial-load=1000", 0 }; - - test_compare(EXIT_SUCCESS, exec_cmdline(executable, args, true)); - - return TEST_SUCCESS; -} - -static test_return_t server_concurrency_initial_load_execute_number_test(void *) -{ - char buffer[1024]; - snprintf(buffer, sizeof(buffer), "--servers=localhost:%d", int(default_port())); - const char *args[]= { buffer, "--concurrency=10", "--initial-load=1000", "--execute-number=10", 0 }; - - test_compare(EXIT_SUCCESS, exec_cmdline(executable, args, true)); - - return TEST_SUCCESS; -} - -static test_return_t server_concurrency_initial_load_execute_number_test_get_test(void *) -{ - char buffer[1024]; - snprintf(buffer, sizeof(buffer), "--servers=localhost:%d", int(default_port())); - const char *args[]= { buffer, "--concurrency=10", "--initial-load=1000", "--execute-number=10", "--test=get", 0 }; - - test_compare(EXIT_SUCCESS, exec_cmdline(executable, args, true)); - - return TEST_SUCCESS; -} - -static test_return_t server_concurrency_initial_load_execute_number_test_set_test(void *) -{ - char buffer[1024]; - snprintf(buffer, sizeof(buffer), "--servers=localhost:%d", int(default_port())); - const char *args[]= { buffer, "--concurrency=10", "--initial-load=1000", "--execute-number=10", "--test=set", 0 }; - - test_compare(EXIT_SUCCESS, exec_cmdline(executable, args, true)); - - return TEST_SUCCESS; -} - -static test_return_t server_concurrency_initial_load_execute_number_test_set_non_blocking_test(void *) -{ - char buffer[1024]; - snprintf(buffer, sizeof(buffer), "--servers=localhost:%d", int(default_port())); - const char *args[]= { buffer, "--concurrency=10", "--initial-load=1000", "--execute-number=10", "--test=set", "--non-blocking", 0 }; - - test_compare(EXIT_SUCCESS, exec_cmdline(executable, args, true)); - - return TEST_SUCCESS; -} - -test_st memslap_tests[] ={ - {"--quiet", true, quiet_test }, - {"--help", true, help_test }, - {"--server_test", true, server_test }, - {"--concurrency=10", true, server_concurrency_test }, - {"--initial-load=1000", true, server_concurrency_initial_load_test }, - {"--execute-number=10", true, server_concurrency_initial_load_execute_number_test }, - {"--test=get", true, server_concurrency_initial_load_execute_number_test_get_test }, - {"--test=set", true, server_concurrency_initial_load_execute_number_test_set_test }, - {"--test=set --non-blockin", true, server_concurrency_initial_load_execute_number_test_set_non_blocking_test }, - {0, 0, 0} -}; - -collection_st collection[] ={ - {"memslap", 0, 0, memslap_tests }, - {0, 0, 0, 0} -}; - -static void *world_create(server_startup_st& servers, test_return_t& error) -{ - if (libtest::has_memcached() == false) - { - error= TEST_SKIPPED; - return NULL; - } - - const char *argv[]= { "memslap", 0 }; - if (server_startup(servers, "memcached", libtest::default_port(), argv) == false) - { - error= TEST_FAILURE; - } - - return &servers; -} - - -void get_world(libtest::Framework* world) -{ - executable= "./src/bin/memslap"; - world->collections(collection); - world->create(world_create); -} -