X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=tests%2Fparser.cc;h=220d9ef5d8322bdfa37096d2fb7f1cc713416bde;hb=refs%2Ftags%2F1.0.13;hp=8119c82bcb8a1262b987a31b21fc802e4107d232;hpb=f0d3a824ed9acb9f6e3080683abe2bcc8b0cd6bd;p=awesomized%2Flibmemcached diff --git a/tests/parser.cc b/tests/parser.cc index 8119c82b..220d9ef5 100644 --- a/tests/parser.cc +++ b/tests/parser.cc @@ -1,9 +1,8 @@ /* vim:expandtab:shiftwidth=2:tabstop=2:smarttab: * - * Gearmand client and server library. + * Libmemcached library * - * Copyright (C) 2011 Data Differential, http://datadifferential.com/ - * All rights reserved. + * Copyright (C) 2012 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 @@ -37,313 +36,96 @@ #include -#include +/* + C++ interface test +*/ +#include +#include -#include "tests/parser.h" -#include "tests/print.h" +using namespace libtest; -enum scanner_type_t +static test_return_t memcached_NULL_string_TEST(void*) { - NIL, - UNSIGNED, - SIGNED, - ARRAY -}; - - -struct scanner_string_st { - const char *c_str; - size_t size; -}; - -static inline scanner_string_st scanner_string(const char *arg, size_t arg_size) -{ - scanner_string_st local= { arg, arg_size }; - return local; -} - -#define make_scanner_string(X) scanner_string((X), static_cast(sizeof(X) - 1)) - -static struct scanner_string_st scanner_string_null= { 0, 0}; - -struct scanner_variable_t { - enum scanner_type_t type; - struct scanner_string_st option; - struct scanner_string_st result; - test_return_t (*check_func)(memcached_st *memc, const scanner_string_st &hostname); -}; - -// Check and make sure the first host is what we expect it to be -static test_return_t __check_host(memcached_st *memc, const scanner_string_st &hostname) -{ - memcached_server_instance_st instance= - memcached_server_instance_by_position(memc, 0); - - test_true(instance); - - const char *first_hostname = memcached_server_name(instance); - test_true(first_hostname); - test_strcmp(first_hostname, hostname.c_str); - + test_null(memcached(NULL, 75)); return TEST_SUCCESS; } -// Check and make sure the prefix_key is what we expect it to be -static test_return_t __check_prefix_key(memcached_st *memc, const scanner_string_st &hostname) +static test_return_t memcached_zero_string_length_TEST(void*) { - memcached_server_instance_st instance= - memcached_server_instance_by_position(memc, 0); - - test_true(instance); - - const char *first_hostname = memcached_server_name(instance); - test_true(first_hostname); - test_strcmp(first_hostname, hostname.c_str); - + test_null(memcached("value", 0)); return TEST_SUCCESS; } -static test_return_t __check_IO_MSG_WATERMARK(memcached_st *memc, const scanner_string_st &value) +static test_return_t putenv_localhost_quoted_TEST(void*) { - uint64_t value_number; + char set_env[1024]; - value_number= atoll(value.c_str); + snprintf(set_env, sizeof(set_env), "LIBMEMCACHED=\"--server=localhost\""); + test_zero(putenv(set_env)); + test_null(memcached(NULL, 0)); - test_true(memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_IO_MSG_WATERMARK) == value_number); return TEST_SUCCESS; } -static test_return_t __check_AUTO_EJECT_HOSTS(memcached_st *memc, const scanner_string_st &value) +static test_return_t putenv_NULL_TEST(void*) { - (void)value; - test_true(memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_AUTO_EJECT_HOSTS)); - return TEST_SUCCESS; -} - -static test_return_t __check_CACHE_LOOKUPS(memcached_st *memc, const scanner_string_st &value) -{ - (void)value; - test_true(memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_CACHE_LOOKUPS)); - return TEST_SUCCESS; -} + char set_env[1024]; -static test_return_t __check_NOREPLY(memcached_st *memc, const scanner_string_st &value) -{ - (void)value; - test_true(memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_NOREPLY)); - return TEST_SUCCESS; -} + snprintf(set_env, sizeof(set_env), "LIBMEMCACHED"); + test_zero(putenv(set_env)); + memcached_st *memc= memcached(NULL, 0); + test_true(memc); -static test_return_t __check_VERIFY_KEY(memcached_st *memc, const scanner_string_st &value) -{ - (void)value; - test_true(memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_VERIFY_KEY)); - return TEST_SUCCESS; -} + memcached_free(memc); -static test_return_t __check_distribution_RANDOM(memcached_st *memc, const scanner_string_st &value) -{ - (void)value; - test_true(memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_DISTRIBUTION) == MEMCACHED_DISTRIBUTION_RANDOM); return TEST_SUCCESS; } -scanner_variable_t test_server_strings[]= { - { ARRAY, make_scanner_string("--server=localhost"), make_scanner_string("localhost"), __check_host }, - { ARRAY, make_scanner_string("--server=10.0.2.1"), make_scanner_string("10.0.2.1"), __check_host }, - { ARRAY, make_scanner_string("--server=example.com"), make_scanner_string("example.com"), __check_host }, - { ARRAY, make_scanner_string("--server=localhost:30"), make_scanner_string("localhost"), __check_host }, - { ARRAY, make_scanner_string("--server=10.0.2.1:20"), make_scanner_string("10.0.2.1"), __check_host }, - { ARRAY, make_scanner_string("--server=example.com:1024"), make_scanner_string("example.com"), __check_host }, - { NIL, scanner_string_null, scanner_string_null, NULL } -}; - -scanner_variable_t test_servers_strings[]= { - { ARRAY, make_scanner_string("--servers=localhost:11221,localhost:11222,localhost:11223,localhost:11224,localhost:11225"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--servers=a.example.com:81,localhost:82,b.example.com"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--servers=localhost,localhost:80"), scanner_string_null, NULL }, - { NIL, scanner_string_null, scanner_string_null, NULL} -}; - - -scanner_variable_t bad_test_strings[]= { - { ARRAY, make_scanner_string("-servers=localhost:11221,localhost:11222,localhost:11223,localhost:11224,localhost:11225"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("-- servers=a.example.com:81,localhost:82,b.example.com"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--servers=localhost+80"), scanner_string_null, NULL}, - { NIL, scanner_string_null, scanner_string_null, NULL} -}; - -scanner_variable_t test_number_options[]= { - { ARRAY, make_scanner_string("--CONNECT_TIMEOUT=456"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--IO_MSG_WATERMARK=456"), make_scanner_string("456"), __check_IO_MSG_WATERMARK }, - { ARRAY, make_scanner_string("--IO_BYTES_WATERMARK=456"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--IO_KEY_PREFETCH=456"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--NUMBER_OF_REPLICAS=456"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--POLL_TIMEOUT=456"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--RCV_TIMEOUT=456"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--RETRY_TIMEOUT=456"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--SERVER_FAILURE_LIMIT=456"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--SND_TIMEOUT=456"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--SOCKET_RECV_SIZE=456"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--SOCKET_SEND_SIZE=456"), scanner_string_null, NULL }, - { NIL, scanner_string_null, scanner_string_null, NULL} -}; - -scanner_variable_t test_boolean_options[]= { - { ARRAY, make_scanner_string("--AUTO_EJECT_HOSTS"), scanner_string_null, __check_AUTO_EJECT_HOSTS }, - { ARRAY, make_scanner_string("--BINARY_PROTOCOL"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--BUFFER_REQUESTS"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--CACHE_LOOKUPS"), scanner_string_null, __check_CACHE_LOOKUPS }, - { ARRAY, make_scanner_string("--CORK"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--HASH_WITH_PREFIX_KEY"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--KETAMA"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--KETAMA_WEIGHTED"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--NOREPLY"), scanner_string_null, __check_NOREPLY }, - { ARRAY, make_scanner_string("--RANDOMIZE_REPLICA_READ"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--SORT_HOSTS"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--SUPPORT_CAS"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--TCP_NODELAY"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--TCP_KEEPALIVE"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--TCP_KEEPIDLE"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--USE_UDP"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--VERIFY_KEY"), scanner_string_null, __check_VERIFY_KEY }, - { NIL, scanner_string_null, scanner_string_null, NULL} -}; - -scanner_variable_t prefix_key_strings[]= { - { ARRAY, make_scanner_string("--PREFIX_KEY=foo"), make_scanner_string("foo"), __check_prefix_key }, - { ARRAY, make_scanner_string("--PREFIX-KEY=\"foo\""), make_scanner_string("foo"), __check_prefix_key }, - { ARRAY, make_scanner_string("--PREFIX-KEY=\"This is a very long key\""), make_scanner_string("This is a very long key"), __check_prefix_key }, - { NIL, scanner_string_null, scanner_string_null, NULL} -}; - -scanner_variable_t distribution_strings[]= { - { ARRAY, make_scanner_string("--DISTRIBUTION=consistent"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--DISTRIBUTION=random"), scanner_string_null, __check_distribution_RANDOM }, - { ARRAY, make_scanner_string("--DISTRIBUTION=modula"), scanner_string_null, NULL }, - { NIL, scanner_string_null, scanner_string_null, NULL} -}; - -scanner_variable_t hash_strings[]= { - { ARRAY, make_scanner_string("--HASH=MD5"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--HASH=CRC"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--HASH=FNV1_64"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--HASH=FNV1A_64"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--HASH=FNV1_32"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--HASH=FNV1A_32"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--HASH=MURMUR"), scanner_string_null, NULL }, - { ARRAY, make_scanner_string("--HASH=JENKINS"), scanner_string_null, NULL }, - { NIL, scanner_string_null, scanner_string_null, NULL} -}; - - -static test_return_t _test_option(scanner_variable_t *scanner, bool test_true= true) +static test_return_t putenv_NULL_TEST2(void*) { - (void)test_true; - memcached_st *memc; - memc= memcached_create(NULL); + char set_env[1024]; - for (scanner_variable_t *ptr= scanner; ptr->type != NIL; ptr++) - { - memcached_return_t rc; - rc= memcached_parse_options(memc, ptr->option.c_str, ptr->option.size); - if (test_true) - { - test_true_got(rc == MEMCACHED_SUCCESS, memcached_last_error_message(memc)); + snprintf(set_env, sizeof(set_env), "LIBMEMCACHED="); + test_zero(putenv(set_env)); + memcached_st *memc= memcached(NULL, 0); + test_true(memc); - if (ptr->check_func) - { - (*ptr->check_func)(memc, ptr->result); - } - } - else - { - test_false_with(rc == MEMCACHED_SUCCESS, ptr->option.c_str); - } - memcached_reset(memc); - } memcached_free(memc); return TEST_SUCCESS; } -test_return_t server_test(memcached_st *junk) -{ - (void)junk; - return _test_option(test_server_strings); -} - -test_return_t servers_test(memcached_st *junk) +static test_return_t putenv_localhost_TEST(void*) { - (void)junk; + char set_env[1024]; - test_return_t rc; - if ((rc= _test_option(test_server_strings)) != TEST_SUCCESS) - { - return rc; - } - -#if 0 - memcached_server_fn callbacks[1]; - callbacks[0]= server_print_callback; - memcached_server_cursor(memc, callbacks, NULL, 1); -#endif - - if ((rc= _test_option(bad_test_strings, false)) != TEST_SUCCESS) - { - return rc; - } - - return TEST_SUCCESS; -} + snprintf(set_env, sizeof(set_env), "LIBMEMCACHED=--server=localhost"); + test_zero(putenv(set_env)); + memcached_st *memc= memcached(NULL, 0); + test_true(memc); -test_return_t parser_number_options_test(memcached_st *junk) -{ - (void)junk; - return _test_option(test_number_options); -} - -test_return_t parser_boolean_options_test(memcached_st *junk) -{ - (void)junk; - return _test_option(test_boolean_options); -} + memcached_free(memc); -test_return_t behavior_parser_test(memcached_st *junk) -{ - (void)junk; return TEST_SUCCESS; } -test_return_t parser_hash_test(memcached_st *junk) -{ - (void)junk; - return _test_option(hash_strings); -} +test_st memcached_TESTS[] ={ + {"memcached(NULL, 75)", false, (test_callback_fn*)memcached_NULL_string_TEST }, + {"memcached(\"value\", 0)", false, (test_callback_fn*)memcached_zero_string_length_TEST }, + {"putenv(LIBMEMCACHED=--server=localhost)", false, (test_callback_fn*)putenv_localhost_TEST }, + {"putenv(LIBMEMCACHED)", false, (test_callback_fn*)putenv_NULL_TEST }, + {"putenv(LIBMEMCACHED=)", false, (test_callback_fn*)putenv_NULL_TEST2 }, + {"putenv(LIBMEMCACHED=--server=\"localhost\")", false, (test_callback_fn*)putenv_localhost_quoted_TEST }, + {0, 0, 0} +}; -test_return_t parser_distribution_test(memcached_st *junk) -{ - (void)junk; - return _test_option(distribution_strings); -} +collection_st collection[] ={ + {"memcached()", 0, 0, memcached_TESTS}, + {0, 0, 0, 0} +}; -test_return_t parser_key_prefix_test(memcached_st *junk) +void get_world(libtest::Framework* world) { - (void)junk; - return _test_option(distribution_strings); + world->collections(collection); } -test_return_t memcached_parse_file_options_test(memcached_st *junk) -{ - (void)junk; - memcached_st memc; - memcached_st *memc_ptr= memcached_create(&memc); - - test_true(memc_ptr); - - memcached_return_t rc= memcached_parse_file_options(memc_ptr, "support/example.cnf"); - test_true_got(rc == MEMCACHED_SUCCESS, rc == MEMCACHED_INVALID_ARGUMENTS ? memcached_last_error_message(&memc) : memcached_strerror(NULL, rc)); - memcached_free(memc_ptr); - - return TEST_SUCCESS; -}