return TEST_SUCCESS;
}
+/*
+ Set the value, then quit to make sure it is flushed.
+ Come back in and test that add fails.
+*/
+test_return_t memcached_add_SUCCESS_TEST(memcached_st *memc)
+{
+ memcached_return_t rc;
+ test_null(memcached_get(memc, test_literal_param(__func__), NULL, NULL, &rc));
+ test_compare(MEMCACHED_NOTFOUND, rc);
+
+ test_compare(MEMCACHED_SUCCESS,
+ memcached_add(memc,
+ test_literal_param(__func__),
+ test_literal_param("try something else"),
+ time_t(0), uint32_t(0)));
+
+ return TEST_SUCCESS;
+}
+
/*
Set the value, then quit to make sure it is flushed.
Come back in and test that add fails.
*/
test_return_t add_test(memcached_st *memc)
{
- test_compare_hint(return_value_based_on_buffering(memc),
- memcached_set(memc,
- test_literal_param(__func__),
- test_literal_param("when we sanitize"),
- time_t(0), uint32_t(0)),
- memcached_last_error_message(memc));
+ test_compare(return_value_based_on_buffering(memc),
+ memcached_set(memc,
+ test_literal_param(__func__),
+ test_literal_param("when we sanitize"),
+ time_t(0), uint32_t(0)));
memcached_quit(memc);
- test_compare_hint(memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL) ? MEMCACHED_DATA_EXISTS : MEMCACHED_NOTSTORED,
- memcached_add(memc,
- test_literal_param(__func__),
- test_literal_param("try something else"),
- time_t(0), uint32_t(0)),
- memcached_last_error_message(memc));
+ size_t value_length;
+ uint32_t flags;
+ memcached_return_t rc;
+ char *check_value= memcached_get(memc,
+ test_literal_param(__func__),
+ &value_length, &flags, &rc);
+ test_memcmp(check_value, "when we sanitize", strlen("when we sanitize"));
+ test_compare(test_literal_param_size("when we sanitize"), value_length);
+ test_compare(MEMCACHED_SUCCESS, rc);
+ free(check_value);
+
+ test_compare(memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL) ? MEMCACHED_DATA_EXISTS : MEMCACHED_NOTSTORED,
+ memcached_add(memc,
+ test_literal_param(__func__),
+ test_literal_param("try something else"),
+ time_t(0), uint32_t(0)));
return TEST_SUCCESS;
}
#endif
for (uint32_t x= 0; x < max; x++)
+ {
add_test(memc);
+ }
return TEST_SUCCESS;
}
test_return_t replace_test(memcached_st *memc)
{
- test_compare_hint(return_value_based_on_buffering(memc),
- memcached_set(memc,
- test_literal_param(__func__),
- test_literal_param("when we sanitize"),
- time_t(0), uint32_t(0)),
- memcached_last_error_message(memc));
+ test_compare(return_value_based_on_buffering(memc),
+ memcached_set(memc,
+ test_literal_param(__func__),
+ test_literal_param("when we sanitize"),
+ time_t(0), uint32_t(0)));
- test_compare_hint(MEMCACHED_SUCCESS,
- memcached_replace(memc,
- test_literal_param(__func__),
- test_literal_param("first we insert some data"),
- time_t(0), uint32_t(0)),
- memcached_last_error_message(memc));
+ test_compare(MEMCACHED_SUCCESS,
+ memcached_replace(memc,
+ test_literal_param(__func__),
+ test_literal_param("first we insert some data"),
+ time_t(0), uint32_t(0)));
return TEST_SUCCESS;
}
test_return_t delete_test(memcached_st *memc)
{
- test_compare_hint(return_value_based_on_buffering(memc),
- memcached_set(memc,
- test_literal_param(__func__),
- test_literal_param("when we sanitize"),
- time_t(0), uint32_t(0)),
- memcached_last_error_message(memc));
+ test_compare(return_value_based_on_buffering(memc),
+ memcached_set(memc,
+ test_literal_param(__func__),
+ test_literal_param("when we sanitize"),
+ time_t(0), uint32_t(0)));
- test_compare_hint(return_value_based_on_buffering(memc),
- memcached_delete(memc,
- test_literal_param(__func__),
- time_t(0)),
- memcached_last_error_message(memc));
+ test_compare(return_value_based_on_buffering(memc),
+ memcached_delete(memc,
+ test_literal_param(__func__),
+ time_t(0)));
return TEST_SUCCESS;
}
{
for (uint32_t x= 0; x < 10; x++)
{
- test_compare_hint(return_value_based_on_buffering(memc),
- memcached_set(memc,
- test_literal_param("foo"),
- test_literal_param("train in the brain"),
- time_t(0), uint32_t(0)),
- memcached_last_error_message(memc));
+ test_compare(return_value_based_on_buffering(memc),
+ memcached_set(memc,
+ test_literal_param("foo"),
+ test_literal_param("train in the brain"),
+ time_t(0), uint32_t(0)));
}
return TEST_SUCCESS;
snprintf(key, sizeof(key), "foo%u", x);
uint64_t query_id= memcached_query_id(memc);
- test_compare_hint(return_value_based_on_buffering(memc),
- memcached_set(memc, key, strlen(key),
- &value[0], value.size(),
- time_t(0), uint32_t(0)),
- memcached_last_error_message(memc));
+ test_compare(return_value_based_on_buffering(memc),
+ memcached_set(memc, key, strlen(key),
+ &value[0], value.size(),
+ time_t(0), uint32_t(0)));
test_compare(query_id +1, memcached_query_id(memc));
}
test_literal_param(__func__),
test_literal_param("3"),
time_t(0), uint32_t(0)));
+
// Make sure we flush the value we just set
test_compare(MEMCACHED_SUCCESS, memcached_flush_buffers(memc));
{
const char *value= "sanford and sun";
- test_compare_hint(return_value_based_on_buffering(memc),
- memcached_set(memc,
- test_literal_param(__func__),
- value, strlen(value),
- (time_t)10, (uint32_t)3),
- memcached_last_error_message(memc));
+ test_compare(return_value_based_on_buffering(memc),
+ memcached_set(memc,
+ test_literal_param(__func__),
+ value, strlen(value),
+ time_t(10), uint32_t(3)));
memcached_quit(memc);
- test_compare_hint(return_value_based_on_buffering(memc),
- memcached_set(memc,
- test_literal_param(__func__),
- value, strlen(value),
- (time_t)50, (uint32_t)9),
- memcached_last_error_message(memc));
+ test_compare(return_value_based_on_buffering(memc),
+ memcached_set(memc,
+ test_literal_param(__func__),
+ value, strlen(value),
+ time_t(50), uint32_t(9)));
return TEST_SUCCESS;
}
size_t key_length[]= {5, 3, 4};
memcached_result_st results_obj;
- memcached_result_st *results;
-
- results= memcached_result_create(memc, &results_obj);
+ memcached_result_st *results= memcached_result_create(memc, &results_obj);
test_true(results);
test_true(&results_obj == results);
const char *keys= "036790384900";
size_t key_length= strlen(keys);
- test_compare_hint(MEMCACHED_SUCCESS, memcached_set(memc, keys, key_length,
- insert_data, VALUE_SIZE_BUG5,
- time_t(0), 245U),
- memcached_last_error_message(memc));
+ test_compare(MEMCACHED_SUCCESS, memcached_set(memc, keys, key_length,
+ insert_data, VALUE_SIZE_BUG5,
+ time_t(0), 245U));
memcached_return_t rc;
size_t value_length;
char *value2= memcached_get(memc, key, strlen(key),
&length, &flags, &rc);
- test_true(length==strlen(value));
+ test_compare(length, strlen(value));
test_compare(MEMCACHED_SUCCESS, rc);
test_memcmp(value, value2, length);
free(value2);
return TEST_SUCCESS;
}
-test_return_t ping_test(memcached_st *memc)
+static memcached_return_t ping_each_server(const memcached_st*,
+ const memcached_server_st *instance,
+ void*)
{
+ // Test both the version that returns a code, and the one that does not.
memcached_return_t rc;
- memcached_server_instance_st instance=
- memcached_server_instance_by_position(memc, 0);
+ if (libmemcached_util_ping(memcached_server_name(instance),
+ memcached_server_port(instance), &rc) == false)
+ {
+ throw libtest::fatal(LIBYATL_DEFAULT_PARAM, "%s:%d %s", memcached_server_name(instance),
+ memcached_server_port(instance), memcached_strerror(NULL, rc));
+ }
- // Test both the version that returns a code, and the one that does not.
- test_true(libmemcached_util_ping(memcached_server_name(instance),
- memcached_server_port(instance), NULL));
+ if (libmemcached_util_ping(memcached_server_name(instance),
+ memcached_server_port(instance), NULL) == false)
+ {
+ throw libtest::fatal(LIBYATL_DEFAULT_PARAM, "%s:%d", memcached_server_name(instance), memcached_server_port(instance));
+ }
- test_true(libmemcached_util_ping(memcached_server_name(instance),
- memcached_server_port(instance), &rc));
+ return MEMCACHED_SUCCESS;
+}
- test_compare(MEMCACHED_SUCCESS, rc);
+test_return_t libmemcached_util_ping_TEST(memcached_st *memc)
+{
+ memcached_server_fn callbacks[1]= { ping_each_server };
+ memcached_server_cursor(memc, callbacks, NULL, 1);
return TEST_SUCCESS;
}
projects / m6w6 / libmemcached / blobdiff