summaryrefslogtreecommitdiff
path: root/example/interface_v0.cc
diff options
context:
space:
mode:
authorBrian Aker <brian@tangent.org>2012-03-04 16:44:37 -0800
committerBrian Aker <brian@tangent.org>2012-03-04 16:44:37 -0800
commit93dec285cdb4aab2bff0bae0d50e033b69560181 (patch)
tree06a3927452671d05bc2d1c45a5d3793f675b0e6f /example/interface_v0.cc
parent8cc058d16abc8b75b675173c6c416c5ac7a30849 (diff)
downloadlibmemcached-93dec285cdb4aab2bff0bae0d50e033b69560181.tar.gz
Add in better testing for gdb.
Diffstat (limited to 'example/interface_v0.cc')
-rw-r--r--example/interface_v0.cc16
1 files changed, 14 insertions, 2 deletions
diff --git a/example/interface_v0.cc b/example/interface_v0.cc
index cc2f17d2..e4f5c901 100644
--- a/example/interface_v0.cc
+++ b/example/interface_v0.cc
@@ -20,6 +20,12 @@
#include <example/byteorder.h>
#include "example/memcached_light.h"
#include "example/storage.h"
+#include "util/log.hpp"
+
+
+using namespace datadifferential;
+
+static util::log_info_st *log_file= NULL;
static protocol_binary_response_status noop_command_handler(const void *cookie,
protocol_binary_request_header *header,
@@ -121,18 +127,22 @@ static protocol_binary_response_status delete_command_handler(const void *cookie
response.message.header.response.opcode= header->request.opcode;
response.message.header.response.opaque= header->request.opaque;
- if (!delete_item(key, keylen))
+ if (delete_item(key, keylen) == false)
{
+ log_file->write(util::VERBOSE_NOTICE, "%s not found: %.*s", __func__, keylen, key);
response.message.header.response.status= htons(PROTOCOL_BINARY_RESPONSE_KEY_ENOENT);
return response_handler(cookie, header, (protocol_binary_response_header*)&response);
}
else if (header->request.opcode == PROTOCOL_BINARY_CMD_DELETE)
{
+ log_file->write(util::VERBOSE_NOTICE, "%s not found: %.*s", __func__, keylen, key);
/* DELETEQ doesn't want success response */
response.message.header.response.status= htons(PROTOCOL_BINARY_RESPONSE_SUCCESS);
return response_handler(cookie, header, (protocol_binary_response_header*)&response);
}
+ log_file->write(util::VERBOSE_NOTICE, "%s deleted: %.*s", __func__, keylen, key);
+
return PROTOCOL_BINARY_RESPONSE_SUCCESS;
}
@@ -516,8 +526,10 @@ static protocol_binary_response_status stat_command_handler(const void *cookie,
memcached_binary_protocol_callback_st interface_v0_impl;
-void initialize_interface_v0_handler(void)
+void initialize_interface_v0_handler(util::log_info_st& arg)
{
+ log_file= &arg;
+
interface_v0_impl.interface_version= MEMCACHED_PROTOCOL_HANDLER_V0;
interface_v0_impl.interface.v0.comcode[PROTOCOL_BINARY_CMD_GET]= get_command_handler;
interface_v0_impl.interface.v0.comcode[PROTOCOL_BINARY_CMD_SET]= set_command_handler;