memcached_return_t memcached_flush(memcached_st *ptr, time_t expiration)
{
memcached_return_t rc;
- if (memcached_failed(rc= initialize_query(ptr)))
+ if (memcached_failed(rc= initialize_query(ptr, true)))
{
return rc;
}
time_t expiration)
{
// Invert the logic to make it simpler to read the code
- bool reply= (ptr->flags.no_reply) ? false : true;
+ bool reply= memcached_is_replying(ptr);
char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE];
int send_length= 0;
{
memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, x);
- if (ptr->flags.no_reply)
+ if (memcached_is_replying(ptr))
{
- request.message.header.request.opcode= PROTOCOL_BINARY_CMD_FLUSHQ;
+ request.message.header.request.opcode= PROTOCOL_BINARY_CMD_FLUSH;
}
else
{
- request.message.header.request.opcode= PROTOCOL_BINARY_CMD_FLUSH;
+ request.message.header.request.opcode= PROTOCOL_BINARY_CMD_FLUSHQ;
}
+ struct libmemcached_io_vector_st vector[]=
+ {
+ { request.bytes, sizeof(request.bytes) }
+ };
+
memcached_return_t rrc;
- if ((rrc= memcached_do(instance, request.bytes, sizeof(request.bytes), true)))
+ if ((rrc= memcached_vdo(instance, vector, 1, true)))
{
memcached_set_error(*instance, rrc, MEMCACHED_AT);
memcached_io_reset(instance);