-static void auto_response(memcached_server_write_instance_st instance, const bool reply, memcached_return_t& rc, uint64_t* value)
+static void auto_response(memcached_instance_st* instance, const bool reply, memcached_return_t& rc, uint64_t* value)
{ memcached_literal_param("incr ") },
{ memcached_array_string(instance->root->_namespace), memcached_array_size(instance->root->_namespace) },
{ key, key_length },
{ memcached_literal_param("incr ") },
{ memcached_array_string(instance->root->_namespace), memcached_array_size(instance->root->_namespace) },
{ key, key_length },
{ " noreply", reply ? 0 : memcached_literal_param_size(" noreply") },
{ memcached_literal_param("\r\n") }
};
{ " noreply", reply ? 0 : memcached_literal_param_size(" noreply") },
{ memcached_literal_param("\r\n") }
};
return memcached_vdo(instance, vector, 7, true);
}
return memcached_vdo(instance, vector, 7, true);
}
protocol_binary_command cmd,
const char *key, const size_t key_length,
const uint64_t offset,
protocol_binary_command cmd,
const char *key, const size_t key_length,
const uint64_t offset,
request.message.header.request.opcode= cmd;
request.message.header.request.keylen= htons((uint16_t)(key_length + memcached_array_size(instance->root->_namespace)));
request.message.header.request.extlen= 20;
request.message.header.request.opcode= cmd;
request.message.header.request.keylen= htons((uint16_t)(key_length + memcached_array_size(instance->root->_namespace)));
request.message.header.request.extlen= 20;
const char *group_key, size_t group_key_length,
const char *key, size_t key_length,
uint64_t offset,
const char *group_key, size_t group_key_length,
const char *key, size_t key_length,
uint64_t offset,
}
uint32_t server_key= memcached_generate_hash_with_redistribution(memc, group_key, group_key_length);
}
uint32_t server_key= memcached_generate_hash_with_redistribution(memc, group_key, group_key_length);
}
uint32_t server_key= memcached_generate_hash_with_redistribution(memc, group_key, group_key_length);
}
uint32_t server_key= memcached_generate_hash_with_redistribution(memc, group_key, group_key_length);
const char *group_key, size_t group_key_length,
const char *key, size_t key_length,
uint64_t offset,
uint64_t *value)
{
const char *group_key, size_t group_key_length,
const char *key, size_t key_length,
uint64_t offset,
uint64_t *value)
{
LIBMEMCACHED_MEMCACHED_INCREMENT_START();
memcached_return_t rc= increment_decrement_by_key(PROTOCOL_BINARY_CMD_INCREMENT,
memc,
LIBMEMCACHED_MEMCACHED_INCREMENT_START();
memcached_return_t rc= increment_decrement_by_key(PROTOCOL_BINARY_CMD_INCREMENT,
memc,
const char *group_key, size_t group_key_length,
const char *key, size_t key_length,
uint64_t offset,
uint64_t *value)
{
const char *group_key, size_t group_key_length,
const char *key, size_t key_length,
uint64_t offset,
uint64_t *value)
{
LIBMEMCACHED_MEMCACHED_DECREMENT_START();
memcached_return_t rc= increment_decrement_by_key(PROTOCOL_BINARY_CMD_DECREMENT,
memc,
LIBMEMCACHED_MEMCACHED_DECREMENT_START();
memcached_return_t rc= increment_decrement_by_key(PROTOCOL_BINARY_CMD_DECREMENT,
memc,
offset, initial, expiration, value);
}
offset, initial, expiration, value);
}
memcached_return_t rc= increment_decrement_with_initial_by_key(PROTOCOL_BINARY_CMD_INCREMENT,
memc,
group_key, group_key_length,
memcached_return_t rc= increment_decrement_with_initial_by_key(PROTOCOL_BINARY_CMD_INCREMENT,
memc,
group_key, group_key_length,
offset, initial, expiration, value);
}
offset, initial, expiration, value);
}
memcached_return_t rc= increment_decrement_with_initial_by_key(PROTOCOL_BINARY_CMD_DECREMENT,
memc,
group_key, group_key_length,
memcached_return_t rc= increment_decrement_with_initial_by_key(PROTOCOL_BINARY_CMD_DECREMENT,
memc,
group_key, group_key_length,