projects
/
awesomized
/
libmemcached
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
Updating the get function in the C++ interface.
[awesomized/libmemcached]
/
libmemcached
/
memcached_flush.c
diff --git
a/libmemcached/memcached_flush.c
b/libmemcached/memcached_flush.c
index 4e048d00260e279858493167f98e05831797b967..55a6ca716de10df28486015751548e3716c1dc01 100644
(file)
--- a/
libmemcached/memcached_flush.c
+++ b/
libmemcached/memcached_flush.c
@@
-31,16
+31,18
@@
static memcached_return memcached_flush_textual(memcached_st *ptr,
for (x= 0; x < ptr->number_of_hosts; x++)
{
for (x= 0; x < ptr->number_of_hosts; x++)
{
+ bool no_reply= (ptr->flags & MEM_NOREPLY);
if (expiration)
send_length= snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE,
if (expiration)
send_length= snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE,
- "flush_all %llu\r\n", (unsigned long long)expiration);
+ "flush_all %llu%s\r\n",
+ (unsigned long long)expiration, no_reply ? " noreply" : "");
else
send_length= snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE,
else
send_length= snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE,
- "flush_all
\r\n
");
+ "flush_all
%s\r\n", no_reply ? " noreply" : "
");
rc= memcached_do(&ptr->hosts[x], buffer, send_length, 1);
rc= memcached_do(&ptr->hosts[x], buffer, send_length, 1);
- if (rc == MEMCACHED_SUCCESS)
+ if (rc == MEMCACHED_SUCCESS
&& !no_reply
)
(void)memcached_response(&ptr->hosts[x], buffer, MEMCACHED_DEFAULT_COMMAND_SIZE, NULL);
}
(void)memcached_response(&ptr->hosts[x], buffer, MEMCACHED_DEFAULT_COMMAND_SIZE, NULL);
}
@@
-65,6
+67,10
@@
static memcached_return memcached_flush_binary(memcached_st *ptr,
for (x= 0; x < ptr->number_of_hosts; x++)
{
for (x= 0; x < ptr->number_of_hosts; x++)
{
+ if (ptr->flags & MEM_NOREPLY)
+ request.message.header.request.opcode= PROTOCOL_BINARY_CMD_FLUSHQ;
+ else
+ request.message.header.request.opcode= PROTOCOL_BINARY_CMD_FLUSH;
if (memcached_do(&ptr->hosts[x], request.bytes,
sizeof(request.bytes), 1) != MEMCACHED_SUCCESS)
{
if (memcached_do(&ptr->hosts[x], request.bytes,
sizeof(request.bytes), 1) != MEMCACHED_SUCCESS)
{