char read_buffer[MEMCACHED_MAX_BUFFER];
size_t read_buffer_length;
char *read_ptr;
+ memcached_allocated sockaddr_inited;
struct sockaddr_in servAddr;
memcached_connection type;
uint8_t major_version;
time_t expiration);
memcached_return memcached_increment(memcached_st *ptr,
char *key, size_t key_length,
- unsigned int offset,
+ uint32_t offset,
uint64_t *value);
memcached_return memcached_decrement(memcached_st *ptr,
char *key, size_t key_length,
- unsigned int offset,
+ uint32_t offset,
uint64_t *value);
void memcached_stat_free(memcached_st *, memcached_stat_st *);
memcached_stat_st *memcached_stat(memcached_st *ptr, char *args, memcached_return *error);
memcached_return memcached_increment(memcached_st *ptr,
char *key, size_t key_length,
- unsigned int offset,
+ uint32_t offset,
uint64_t *value)
{
memcached_return rc;
memcached_return memcached_decrement(memcached_st *ptr,
char *key, size_t key_length,
- unsigned int offset,
+ uint32_t offset,
uint64_t *value)
{
memcached_return rc;
/* Old connection junk still is in the structure */
WATCHPOINT_ASSERT(ptr->hosts[server_key].stack_responses == 0);
- if (ptr->hosts[server_key].servAddr.sin_family == 0)
+ if (ptr->hosts[server_key].sockaddr_inited == MEMCACHED_NOT_ALLOCATED)
{
memcached_return rc;
rc= set_hostinfo(&ptr->hosts[server_key]);
if (rc != MEMCACHED_SUCCESS)
return rc;
+
+ ptr->hosts[server_key].sockaddr_inited= MEMCACHED_ALLOCATED;
}
/* Create the socket */
assert((value_length == (sizeof(unsigned int) * x)));
assert(rc == MEMCACHED_SUCCESS);
- store_ptr= store_list;
+ store_ptr= (unsigned int *)value;
x= 0;
while (*store_ptr)
{