memcached_return_t memcached_delete_by_key(memcached_st *ptr,
const char *master_key, size_t master_key_length,
const char *key, size_t key_length,
time_t expiration)
{
memcached_return_t memcached_delete_by_key(memcached_st *ptr,
const char *master_key, size_t master_key_length,
const char *key, size_t key_length,
time_t expiration)
{
server_key= memcached_generate_hash(ptr, master_key, master_key_length);
instance= memcached_server_instance_fetch(ptr, server_key);
server_key= memcached_generate_hash(ptr, master_key, master_key_length);
instance= memcached_server_instance_fetch(ptr, server_key);
{
/* We might get out of sync with the server if we
* send this command to a server newer than 1.2.x..
* disable no_reply and buffered mode.
*/
{
/* We might get out of sync with the server if we
* send this command to a server newer than 1.2.x..
* disable no_reply and buffered mode.
*/
if (no_reply)
memcached_server_response_increment(instance);
no_reply= false;
}
}
send_length= (size_t) snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE,
if (no_reply)
memcached_server_response_increment(instance);
no_reply= false;
}
}
send_length= (size_t) snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE,
{
if (send_length > MAX_UDP_DATAGRAM_LENGTH - UDP_DATAGRAM_HEADER_LENGTH)
return MEMCACHED_WRITE_FAILURE;
if (send_length + instance->write_buffer_offset > MAX_UDP_DATAGRAM_LENGTH)
{
if (send_length > MAX_UDP_DATAGRAM_LENGTH - UDP_DATAGRAM_HEADER_LENGTH)
return MEMCACHED_WRITE_FAILURE;
if (send_length + instance->write_buffer_offset > MAX_UDP_DATAGRAM_LENGTH)
- memcached_io_write(instance, NULL, 0, 1);
+ memcached_io_write(instance, NULL, 0, true);
}
rc= memcached_do(instance, buffer, send_length, to_write);
}
rc= memcached_do(instance, buffer, send_length, to_write);
request.message.header.request.datatype= PROTOCOL_BINARY_RAW_BYTES;
request.message.header.request.bodylen= htonl((uint32_t) key_length);
request.message.header.request.datatype= PROTOCOL_BINARY_RAW_BYTES;
request.message.header.request.bodylen= htonl((uint32_t) key_length);
{
size_t cmd_size= sizeof(request.bytes) + key_length;
if (cmd_size > MAX_UDP_DATAGRAM_LENGTH - UDP_DATAGRAM_HEADER_LENGTH)
return MEMCACHED_WRITE_FAILURE;
if (cmd_size + instance->write_buffer_offset > MAX_UDP_DATAGRAM_LENGTH)
{
size_t cmd_size= sizeof(request.bytes) + key_length;
if (cmd_size > MAX_UDP_DATAGRAM_LENGTH - UDP_DATAGRAM_HEADER_LENGTH)
return MEMCACHED_WRITE_FAILURE;
if (cmd_size + instance->write_buffer_offset > MAX_UDP_DATAGRAM_LENGTH)
- memcached_io_write(instance, NULL, 0, 1);
+ memcached_io_write(instance, NULL, 0, true);
}
memcached_return_t rc= MEMCACHED_SUCCESS;
if ((memcached_do(instance, request.bytes,
}
memcached_return_t rc= MEMCACHED_SUCCESS;
if ((memcached_do(instance, request.bytes,
replica= memcached_server_instance_fetch(ptr, server_key);
if ((memcached_do(replica, (const char*)request.bytes,
replica= memcached_server_instance_fetch(ptr, server_key);
if ((memcached_do(replica, (const char*)request.bytes,
- sizeof(request.bytes), 0) != MEMCACHED_SUCCESS) ||
- (memcached_io_write(replica, key, key_length, (char) flush) == -1))
+ sizeof(request.bytes), false) != MEMCACHED_SUCCESS) ||
+ (memcached_io_write(replica, key, key_length, flush) == -1))