1 /* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
3 * Libmemcached Client and Server
5 * Copyright (C) 2012 Data Differential, http://datadifferential.com/
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted provided that the following conditions are
12 * * Redistributions of source code must retain the above copyright
13 * notice, this list of conditions and the following disclaimer.
15 * * Redistributions in binary form must reproduce the above
16 * copyright notice, this list of conditions and the following disclaimer
17 * in the documentation and/or other materials provided with the
20 * * The names of its contributors may not be used to endorse or
21 * promote products derived from this software without specific prior
24 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
25 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
26 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
27 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
28 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
29 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
30 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
31 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
32 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
33 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
34 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
38 #include "mem_config.h"
39 #include "libtest/test.hpp"
41 #include "libmemcachedutil-1.0/util.h"
43 #include "tests/print.h"
44 #include "tests/libmemcached-1.0/setup_and_teardowns.h"
48 using namespace libtest
;
50 memcached_return_t
return_value_based_on_buffering(memcached_st
*memc
)
52 if (memcached_behavior_get(memc
, MEMCACHED_BEHAVIOR_BUFFER_REQUESTS
))
54 return MEMCACHED_BUFFERED
;
57 return MEMCACHED_SUCCESS
;
61 @note This should be testing to see if the server really supports the binary protocol.
63 test_return_t
pre_binary(memcached_st
*memc
)
65 test_true(memcached_server_count(memc
) > 0);
66 test_skip(true, libmemcached_util_version_check(memc
, 1, 4, 4));
67 test_skip(MEMCACHED_SUCCESS
, memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL
, true));
72 test_return_t
pre_buffer(memcached_st
*memc
)
74 test_skip(MEMCACHED_SUCCESS
, memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_BUFFER_REQUESTS
, true));
79 test_return_t
pre_unix_socket(memcached_st
*memc
)
83 memcached_servers_reset(memc
);
84 const char *socket_file
= libtest::default_socket();
85 test_skip(true, bool(socket_file
));
87 test_skip(0, stat(socket_file
, &buf
));
89 test_compare(MEMCACHED_SUCCESS
,
90 memcached_server_add_unix_socket_with_weight(memc
, socket_file
, 0));
95 test_return_t
pre_nodelay(memcached_st
*memc
)
97 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_NO_BLOCK
, 0);
98 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_TCP_NODELAY
, 0);
103 test_return_t
pre_settimer(memcached_st
*memc
)
105 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_SND_TIMEOUT
, 1000);
106 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_RCV_TIMEOUT
, 1000);
111 test_return_t
pre_murmur(memcached_st
*memc
)
113 test_skip(MEMCACHED_SUCCESS
, memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_HASH
, (uint64_t)MEMCACHED_HASH_MURMUR
));
117 test_return_t
pre_jenkins(memcached_st
*memc
)
119 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_HASH
, (uint64_t)MEMCACHED_HASH_JENKINS
);
125 test_return_t
pre_md5(memcached_st
*memc
)
127 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_HASH
, (uint64_t)MEMCACHED_HASH_MD5
);
132 test_return_t
pre_crc(memcached_st
*memc
)
134 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_HASH
, (uint64_t)MEMCACHED_HASH_CRC
);
139 test_return_t
pre_hsieh(memcached_st
*memc
)
141 test_skip(MEMCACHED_SUCCESS
, memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_HASH
, (uint64_t)MEMCACHED_HASH_HSIEH
));
145 test_return_t
pre_hash_fnv1_64(memcached_st
*memc
)
147 test_skip(MEMCACHED_SUCCESS
, memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_HASH
, (uint64_t)MEMCACHED_HASH_MURMUR
));
152 test_return_t
pre_hash_fnv1a_64(memcached_st
*memc
)
154 test_skip(MEMCACHED_SUCCESS
, memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_HASH
, (uint64_t)MEMCACHED_HASH_FNV1A_64
));
159 test_return_t
pre_hash_fnv1_32(memcached_st
*memc
)
161 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_HASH
, (uint64_t)MEMCACHED_HASH_FNV1_32
);
166 test_return_t
pre_hash_fnv1a_32(memcached_st
*memc
)
168 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_HASH
, (uint64_t)MEMCACHED_HASH_FNV1A_32
);
173 test_return_t
memcached_servers_reset_SETUP(memcached_st
*memc
)
175 memcached_servers_reset(memc
);
176 test_compare(0U, memcached_server_count(memc
));
180 test_return_t
memcached_servers_reset_CONTINUUM(memcached_st
*memc
)
182 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_DISTRIBUTION
, MEMCACHED_DISTRIBUTION_CONSISTENT
);
183 memcached_servers_reset(memc
);
184 test_zero(memc
->ketama
.continuum_count
);
185 // If memc->ketama.continuum_count is non-zero at this point, any call to
186 // memcached_server_add will cause a segfault.
190 test_return_t
memcached_servers_reset_MEMCACHED_DISTRIBUTION_CONSISTENT_SETUP(memcached_st
*memc
)
192 test_compare(TEST_SUCCESS
, memcached_servers_reset_SETUP(memc
));
194 test_compare(MEMCACHED_SUCCESS
, memcached_behavior_set_distribution(memc
, MEMCACHED_DISTRIBUTION_CONSISTENT
));
195 test_compare(memcached_behavior_get_distribution(memc
), MEMCACHED_DISTRIBUTION_CONSISTENT
);
200 test_return_t
memcached_servers_reset_MEMCACHED_DISTRIBUTION_CONSISTENT_WEIGHTED_SETUP(memcached_st
*memc
)
202 test_compare(TEST_SUCCESS
, memcached_servers_reset_SETUP(memc
));
203 ASSERT_EQ(0U, memcached_server_count(0));
205 test_compare(MEMCACHED_SUCCESS
, memcached_behavior_set_distribution(memc
, MEMCACHED_DISTRIBUTION_CONSISTENT_WEIGHTED
));
206 test_compare(memcached_behavior_get_distribution(memc
), MEMCACHED_DISTRIBUTION_CONSISTENT_WEIGHTED
);
211 test_return_t
pre_behavior_ketama(memcached_st
*memc
)
213 test_compare(MEMCACHED_SUCCESS
, memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_KETAMA
, 1));
215 test_compare(memcached_behavior_get(memc
, MEMCACHED_BEHAVIOR_KETAMA
), uint64_t(1));
220 test_return_t
pre_behavior_ketama_weighted(memcached_st
*memc
)
222 test_compare(memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_KETAMA_WEIGHTED
, true), MEMCACHED_SUCCESS
);
224 test_compare(memcached_behavior_get(memc
, MEMCACHED_BEHAVIOR_KETAMA_WEIGHTED
), uint64_t(1));
226 test_compare(memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_KETAMA_HASH
, MEMCACHED_HASH_MD5
), MEMCACHED_SUCCESS
);
228 test_compare(memcached_hash_t(memcached_behavior_get(memc
, MEMCACHED_BEHAVIOR_KETAMA_HASH
)), MEMCACHED_HASH_MD5
);
233 test_return_t
pre_replication(memcached_st
*memc
)
235 test_skip(TEST_SUCCESS
, pre_binary(memc
));
238 * Make sure that we store the item on all servers
239 * (master + replicas == number of servers)
241 test_compare(MEMCACHED_SUCCESS
, memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_NUMBER_OF_REPLICAS
, memcached_server_count(memc
) - 1));
242 test_compare(memcached_behavior_get(memc
, MEMCACHED_BEHAVIOR_NUMBER_OF_REPLICAS
), uint64_t(memcached_server_count(memc
) - 1));
248 test_return_t
pre_replication_noblock(memcached_st
*memc
)
250 test_skip(TEST_SUCCESS
, pre_replication(memc
));
252 return pre_nonblock(memc
);
255 test_return_t
pre_nonblock(memcached_st
*memc
)
257 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_NO_BLOCK
, 0);
262 test_return_t
pre_nonblock_binary(memcached_st
*memc
)
264 memcached_st
*memc_clone
= memcached_clone(NULL
, memc
);
265 test_true(memc_clone
);
267 // The memcached_version needs to be done on a clone, because the server
268 // will not toggle protocol on an connection.
269 memcached_version(memc_clone
);
271 memcached_return_t rc
= MEMCACHED_FAILURE
;
272 if (libmemcached_util_version_check(memc_clone
, 1, 4, 4))
274 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_NO_BLOCK
, 0);
275 test_compare(MEMCACHED_SUCCESS
,
276 memcached_behavior_set(memc
, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL
, 1));
277 test_compare(uint64_t(1), memcached_behavior_get(memc
, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL
));
281 memcached_free(memc_clone
);
285 memcached_free(memc_clone
);
287 return rc
== MEMCACHED_SUCCESS
? TEST_SUCCESS
: TEST_SKIPPED
;