projects
/
m6w6
/
libmemcached
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
Style cleanup
[m6w6/libmemcached]
/
libmemcached
/
memcached.c
diff --git
a/libmemcached/memcached.c
b/libmemcached/memcached.c
index 5991aabb46ced3c685ed7a26fcf0f9a4ce40786e..a363c2498351435a0f639911e35478144f5a211f 100644
(file)
--- a/
libmemcached/memcached.c
+++ b/
libmemcached/memcached.c
@@
-11,16
+11,20
@@
memcached_st *memcached_create(memcached_st *ptr)
{
ptr= (memcached_st *)calloc(1, sizeof(memcached_st));
{
ptr= (memcached_st *)calloc(1, sizeof(memcached_st));
- if (!ptr)
+ if (! ptr)
+ {
return NULL; /* MEMCACHED_MEMORY_ALLOCATION_FAILURE */
return NULL; /* MEMCACHED_MEMORY_ALLOCATION_FAILURE */
+ }
- ptr->is_allocated= true;
+ ptr->
options.
is_allocated= true;
}
else
{
memset(ptr, 0, sizeof(memcached_st));
}
}
else
{
memset(ptr, 0, sizeof(memcached_st));
}
+ ptr->options.is_initialized= true;
+
memcached_set_memory_allocators(ptr, NULL, NULL, NULL, NULL);
result_ptr= memcached_result_create(ptr, &ptr->result);
memcached_set_memory_allocators(ptr, NULL, NULL, NULL, NULL);
result_ptr= memcached_result_create(ptr, &ptr->result);
@@
-34,6
+38,9
@@
memcached_st *memcached_create(memcached_st *ptr)
ptr->io_msg_watermark= 500;
ptr->io_bytes_watermark= 65 * 1024;
ptr->io_msg_watermark= 500;
ptr->io_bytes_watermark= 65 * 1024;
+ WATCHPOINT_ASSERT_INITIALIZED(&ptr->result);
+ WATCHPOINT_ASSERT_INITIALIZED(&ptr->hashkit);
+
return ptr;
}
return ptr;
}
@@
-50,10
+57,14
@@
void memcached_free(memcached_st *ptr)
if (ptr->continuum)
ptr->call_free(ptr, ptr->continuum);
if (ptr->continuum)
ptr->call_free(ptr, ptr->continuum);
- if (ptr->is_allocated)
+ if (memcached_is_allocated(ptr))
+ {
ptr->call_free(ptr, ptr);
ptr->call_free(ptr, ptr);
+ }
else
else
- memset(ptr, 0, sizeof(memcached_st));
+ {
+ ptr->options.is_initialized= false;
+ }
}
/*
}
/*
@@
-63,13
+74,13
@@
void memcached_free(memcached_st *ptr)
*/
memcached_st *memcached_clone(memcached_st *clone, memcached_st *source)
{
*/
memcached_st *memcached_clone(memcached_st *clone, memcached_st *source)
{
- memcached_return rc= MEMCACHED_SUCCESS;
+ memcached_return
_t
rc= MEMCACHED_SUCCESS;
memcached_st *new_clone;
if (source == NULL)
return memcached_create(clone);
memcached_st *new_clone;
if (source == NULL)
return memcached_create(clone);
- if (clone &&
clone->is_allocated
)
+ if (clone &&
memcached_is_allocated(clone)
)
{
return NULL;
}
{
return NULL;
}
@@
-105,6
+116,7
@@
memcached_st *memcached_clone(memcached_st *clone, memcached_st *source)
new_clone->io_msg_watermark= source->io_msg_watermark;
new_clone->io_bytes_watermark= source->io_bytes_watermark;
new_clone->io_key_prefetch= source->io_key_prefetch;
new_clone->io_msg_watermark= source->io_msg_watermark;
new_clone->io_bytes_watermark= source->io_bytes_watermark;
new_clone->io_key_prefetch= source->io_key_prefetch;
+ new_clone->number_of_replicas= source->number_of_replicas;
if (source->hosts)
rc= memcached_server_push(new_clone, source->hosts);
if (source->hosts)
rc= memcached_server_push(new_clone, source->hosts);