projects
/
m6w6
/
libmemcached
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
Adding test, showing off how to add a custom function to libmemcached.
[m6w6/libmemcached]
/
libmemcached
/
quit.c
diff --git
a/libmemcached/quit.c
b/libmemcached/quit.c
index a8f70402062d7c1e87a486a2ac54959827091981..ebeffa5c0bd2f134a039ed881fa78f87152f5e67 100644
(file)
--- a/
libmemcached/quit.c
+++ b/
libmemcached/quit.c
@@
-24,11
+24,11
@@
void memcached_quit_server(memcached_server_st *ptr, uint8_t io_death)
request.message.header.request.magic = PROTOCOL_BINARY_REQ;
request.message.header.request.opcode = PROTOCOL_BINARY_CMD_QUIT;
request.message.header.request.datatype = PROTOCOL_BINARY_RAW_BYTES;
request.message.header.request.magic = PROTOCOL_BINARY_REQ;
request.message.header.request.opcode = PROTOCOL_BINARY_CMD_QUIT;
request.message.header.request.datatype = PROTOCOL_BINARY_RAW_BYTES;
- rc= memcached_do(ptr, request.bytes, sizeof(request.bytes),
1
);
+ rc= memcached_do(ptr, request.bytes, sizeof(request.bytes),
true
);
}
else
{
}
else
{
- rc= memcached_do(ptr, "quit\r\n",
6, 1
);
+ rc= memcached_do(ptr, "quit\r\n",
sizeof("quit\r\n"), true
);
}
WATCHPOINT_ASSERT(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_FETCH_NOTFINISHED);
}
WATCHPOINT_ASSERT(rc == MEMCACHED_SUCCESS || rc == MEMCACHED_FETCH_NOTFINISHED);
@@
-69,15
+69,19
@@
void memcached_quit_server(memcached_server_st *ptr, uint8_t io_death)
void memcached_quit(memcached_st *ptr)
{
void memcached_quit(memcached_st *ptr)
{
- u
nsigned in
t x;
+ u
int32_
t x;
- if (ptr->hosts == NULL ||
- memcached_server_count(ptr) == 0)
+ if (memcached_server_count(ptr) == 0)
return;
return;
- if (
ptr->hosts &&
memcached_server_count(ptr))
+ if (memcached_server_count(ptr))
{
for (x= 0; x < memcached_server_count(ptr); x++)
{
for (x= 0; x < memcached_server_count(ptr); x++)
- memcached_quit_server(&ptr->hosts[x], 0);
+ {
+ memcached_server_instance_st *instance=
+ memcached_server_instance_fetch(ptr, x);
+
+ memcached_quit_server(instance, 0);
+ }
}
}
}
}