+#include "libmemcached/common.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/time.h>
#include <getopt.h>
#include <pthread.h>
+#include <assert.h>
#include <libmemcached/memcached.h>
if (opt_udp_io)
{
memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_USE_UDP, opt_udp_io);
- unsigned int i= 0;
- for(i= 0; i < servers[0].count; i++ )
- servers[i].type= MEMCACHED_CONNECTION_UDP;
+ unsigned int x= 0;
+ for(x= 0; x < servers[0].count; x++ )
+ servers[x].type= MEMCACHED_CONNECTION_UDP;
}
memcached_server_push(memc, servers);
for (x= 0; x < opt_concurrency; x++)
{
thread_context_st *context;
- context= (thread_context_st *)malloc(sizeof(thread_context_st));
- memset(context, 0, sizeof(thread_context_st));
+ context= (thread_context_st *)calloc(1, sizeof(thread_context_st));
context->memc= memcached_clone(NULL, memc);
context->test= opt_test;
switch (context->test)
{
case SET_TEST:
+ assert(context->execute_pairs);
execute_set(memc, context->execute_pairs, context->execute_number);
break;
case GET_TEST: