/* We don't test the behavior itself, we test the switches */
test_return behavior_test(memcached_st *memc)
{
- unsigned long long value;
- unsigned int set= 1;
+ uint64_t value;
+ uint32_t set= 1;
memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, set);
value= memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_NO_BLOCK);
assert(length==strlen(value));
assert(rc == MEMCACHED_SUCCESS);
assert(memcmp(value, value2, length)==0);
+ free(value2);
return 0;
}
test_return generate_data_with_stats(memcached_st *memc)
{
- memcached_stat_st *stat_p= NULL;
+ memcached_stat_st *stat_p;
memcached_return rc;
- int host_index= 0;
+ uint32_t host_index= 0;
execute_set(memc, global_pairs, global_count);
//TODO: hosts used size stats
- stat_p = memcached_stat(memc, NULL, &rc);
- for (host_index = 0; host_index < SERVERS_TO_CREATE; ++host_index)
+ stat_p= memcached_stat(memc, NULL, &rc);
+ assert(stat_p);
+
+ for (host_index= 0; host_index < SERVERS_TO_CREATE; host_index++)
{
- printf("\nserver %d|%s|%d bytes: %lld\n", host_index, (memc->hosts)[host_index].hostname, (memc->hosts)[host_index].port, (stat_p + host_index)->bytes);
+ printf("\nserver %u|%s|%u bytes: %llu\n", host_index, (memc->hosts)[host_index].hostname, (memc->hosts)[host_index].port, (unsigned long long)(stat_p + host_index)->bytes);
}
+ memcached_stat_free(NULL, stat_p);
+
return 0;
}
memcached_return pre_binary(memcached_st *memc)
{
- memcached_return rc;
-
- rc = memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL, 1);
- assert(rc == MEMCACHED_SUCCESS);
+ memcached_return rc= MEMCACHED_FAILURE;
+ memcached_st *clone;
- assert(memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL) == 1);
+ clone= memcached_clone(NULL, memc);
+ assert(clone);
+ // The memcached_version needs to be done on a clone, because the server
+ // will not toggle protocol on an connection.
+ memcached_version(clone);
- return MEMCACHED_SUCCESS;
+ if (clone->hosts[0].major_version >= 1 && clone->hosts[0].minor_version > 2)
+ {
+ rc = memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL, 1);
+ assert(rc == MEMCACHED_SUCCESS);
+ assert(memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_BINARY_PROTOCOL) == 1);
+ }
+ memcached_free(clone);
+ return rc;
}
+
void my_free(memcached_st *ptr, void *mem)
{
free(mem);
memcached_version(memc);
- if (memc->hosts[0].major_version >= 1 &&
- (memc->hosts[0].minor_version == 2 &&
- memc->hosts[0].micro_version >= 4) || memc->hosts[0].minor_version > 2)
+ if ((memc->hosts[0].major_version >= 1 && (memc->hosts[0].minor_version == 2 && memc->hosts[0].micro_version >= 4))
+ || memc->hosts[0].minor_version > 2)
{
memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_SUPPORT_CAS, set);
{
memcached_version(memc);
- if (memc->hosts[0].major_version >= 1 &&
- (memc->hosts[0].minor_version == 2 && memc->hosts[0].micro_version >= 4)
+ if ((memc->hosts[0].major_version >= 1 && (memc->hosts[0].minor_version == 2 && memc->hosts[0].micro_version >= 4))
|| memc->hosts[0].minor_version > 2)
return MEMCACHED_SUCCESS;
return MEMCACHED_SUCCESS;
}
+memcached_return pre_settimer(memcached_st *memc)
+{
+ memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_SND_TIMEOUT, 1000);
+ memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_RCV_TIMEOUT, 1000);
+
+ return MEMCACHED_SUCCESS;
+}
+
memcached_return poll_timeout(memcached_st *memc)
{
int32_t timeout;
{"binary", pre_binary, 0, tests},
{"nonblock", pre_nonblock, 0, tests},
{"nodelay", pre_nodelay, 0, tests},
+ {"settimer", pre_settimer, 0, tests},
{"md5", pre_md5, 0, tests},
{"crc", pre_crc, 0, tests},
{"hsieh", pre_hsieh, 0, tests},