projects
/
m6w6
/
libmemcached
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
Missing hosts file.
[m6w6/libmemcached]
/
lib
/
memcached_storage.c
diff --git
a/lib/memcached_storage.c
b/lib/memcached_storage.c
index 499fb7c8e947e18f76e5fda784a5c2a90d361534..c1ce2b830ad4c485776e5fb7e337eac7e09302c4 100644
(file)
--- a/
lib/memcached_storage.c
+++ b/
lib/memcached_storage.c
@@
-7,7
+7,7
@@
*/
*/
-#include
<memcached.h>
+#include
"common.h"
static memcached_return memcached_send(memcached_st *ptr,
char *key, size_t key_length,
static memcached_return memcached_send(memcached_st *ptr,
char *key, size_t key_length,
@@
-25,6
+25,8
@@
static memcached_return memcached_send(memcached_st *ptr,
assert(value);
assert(value_length);
assert(value);
assert(value_length);
+ memset(buffer, 0, MEMCACHED_DEFAULT_COMMAND_SIZE);
+
rc= memcached_connect(ptr);
if (rc != MEMCACHED_SUCCESS)
return rc;
rc= memcached_connect(ptr);
if (rc != MEMCACHED_SUCCESS)
return rc;
@@
-64,8
+66,12
@@
memcached_return memcached_set(memcached_st *ptr, char *key, size_t key_length,
time_t expiration,
uint16_t flags)
{
time_t expiration,
uint16_t flags)
{
- return memcached_send(ptr, key, key_length, value, value_length,
+ memcached_return rc;
+ LIBMEMCACHED_MEMCACHED_SET_START();
+ rc= memcached_send(ptr, key, key_length, value, value_length,
expiration, flags, "set");
expiration, flags, "set");
+ LIBMEMCACHED_MEMCACHED_SET_END();
+ return rc;
}
memcached_return memcached_add(memcached_st *ptr, char *key, size_t key_length,
}
memcached_return memcached_add(memcached_st *ptr, char *key, size_t key_length,
@@
-73,8
+79,12
@@
memcached_return memcached_add(memcached_st *ptr, char *key, size_t key_length,
time_t expiration,
uint16_t flags)
{
time_t expiration,
uint16_t flags)
{
- return memcached_send(ptr, key, key_length, value, value_length,
+ memcached_return rc;
+ LIBMEMCACHED_MEMCACHED_ADD_START();
+ rc= memcached_send(ptr, key, key_length, value, value_length,
expiration, flags, "add");
expiration, flags, "add");
+ LIBMEMCACHED_MEMCACHED_ADD_END();
+ return rc;
}
memcached_return memcached_replace(memcached_st *ptr, char *key, size_t key_length,
}
memcached_return memcached_replace(memcached_st *ptr, char *key, size_t key_length,
@@
-82,6
+92,10
@@
memcached_return memcached_replace(memcached_st *ptr, char *key, size_t key_leng
time_t expiration,
uint16_t flags)
{
time_t expiration,
uint16_t flags)
{
- return memcached_send(ptr, key, key_length, value, value_length,
+ memcached_return rc;
+ LIBMEMCACHED_MEMCACHED_REPLACE_START();
+ rc= memcached_send(ptr, key, key_length, value, value_length,
expiration, flags, "replace");
expiration, flags, "replace");
+ LIBMEMCACHED_MEMCACHED_REPLACE_END();
+ return rc;
}
}