3 static memcached_return
memcached_flush_binary(memcached_st
*ptr
,
5 static memcached_return
memcached_flush_textual(memcached_st
*ptr
,
8 memcached_return
memcached_flush(memcached_st
*ptr
, time_t expiration
)
12 LIBMEMCACHED_MEMCACHED_FLUSH_START();
13 if (ptr
->flags
& MEM_BINARY_PROTOCOL
)
14 rc
= memcached_flush_binary(ptr
, expiration
);
16 rc
= memcached_flush_textual(ptr
, expiration
);
17 LIBMEMCACHED_MEMCACHED_FLUSH_END();
21 static memcached_return
memcached_flush_textual(memcached_st
*ptr
,
27 char buffer
[MEMCACHED_DEFAULT_COMMAND_SIZE
];
29 unlikely (ptr
->number_of_hosts
== 0)
30 return MEMCACHED_NO_SERVERS
;
32 for (x
= 0; x
< ptr
->number_of_hosts
; x
++)
35 send_length
= snprintf(buffer
, MEMCACHED_DEFAULT_COMMAND_SIZE
,
36 "flush_all %llu\r\n", (unsigned long long)expiration
);
38 send_length
= snprintf(buffer
, MEMCACHED_DEFAULT_COMMAND_SIZE
,
41 rc
= memcached_do(&ptr
->hosts
[x
], buffer
, send_length
, 1);
43 if (rc
== MEMCACHED_SUCCESS
)
44 (void)memcached_response(&ptr
->hosts
[x
], buffer
, MEMCACHED_DEFAULT_COMMAND_SIZE
, NULL
);
47 return MEMCACHED_SUCCESS
;
50 static memcached_return
memcached_flush_binary(memcached_st
*ptr
,
54 protocol_binary_request_flush request
= {.bytes
= {0}};
56 unlikely (ptr
->number_of_hosts
== 0)
57 return MEMCACHED_NO_SERVERS
;
59 request
.message
.header
.request
.magic
= (uint8_t)PROTOCOL_BINARY_REQ
;
60 request
.message
.header
.request
.opcode
= PROTOCOL_BINARY_CMD_FLUSH
;
61 request
.message
.header
.request
.extlen
= 4;
62 request
.message
.header
.request
.datatype
= PROTOCOL_BINARY_RAW_BYTES
;
63 request
.message
.header
.request
.bodylen
= htonl(request
.message
.header
.request
.extlen
);
64 request
.message
.body
.expiration
= htonl(expiration
);
66 for (x
= 0; x
< ptr
->number_of_hosts
; x
++)
68 if (memcached_do(&ptr
->hosts
[x
], request
.bytes
,
69 sizeof(request
.bytes
), 1) != MEMCACHED_SUCCESS
)
71 memcached_io_reset(&ptr
->hosts
[x
]);
72 return MEMCACHED_WRITE_FAILURE
;
76 for (x
= 0; x
< ptr
->number_of_hosts
; x
++)
78 if (memcached_server_response_count(&ptr
->hosts
[x
]) > 0)
79 (void)memcached_response(&ptr
->hosts
[x
], NULL
, 0, NULL
);
82 return MEMCACHED_SUCCESS
;