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 f722cc904e6ea9835d4d8bbb1d40f004a1f1024b..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);
}
@@
-51,7
+53,7
@@
static memcached_return memcached_flush_binary(memcached_st *ptr,
time_t expiration)
{
unsigned int x;
time_t expiration)
{
unsigned int x;
- protocol_binary_request_flush request= {
0
};
+ protocol_binary_request_flush request= {
.bytes= {0}
};
unlikely (ptr->number_of_hosts == 0)
return MEMCACHED_NO_SERVERS;
unlikely (ptr->number_of_hosts == 0)
return MEMCACHED_NO_SERVERS;
@@
-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)
{