summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTrond Norbye <trond.norbye@gmail.com>2011-05-06 10:04:35 +0200
committerTrond Norbye <trond.norbye@gmail.com>2011-07-13 08:15:48 +0200
commit05a6a8573c429ad93749d68af2f186a6af86ccb7 (patch)
tree5c44e6c28718972868150aa07d13ead116e72dec
parent7e2c95cbed29a475b1d2cd741bc81d93369e52b2 (diff)
downloadmemcached-05a6a8573c429ad93749d68af2f186a6af86ccb7.tar.gz
Remove the set_tap_nack_mode from the server api
The tap commands should always return error messages just like the other memcached commands
-rw-r--r--daemon/memcached.c11
-rw-r--r--daemon/memcached.h1
-rw-r--r--include/memcached/server_api.h10
-rw-r--r--programs/mock_server.c6
4 files changed, 1 insertions, 27 deletions
diff --git a/daemon/memcached.c b/daemon/memcached.c
index f4a328d..3212d5e 100644
--- a/daemon/memcached.c
+++ b/daemon/memcached.c
@@ -692,7 +692,6 @@ static void conn_cleanup(conn *c) {
assert(c->next == NULL);
c->ascii_cmd = NULL;
c->sfd = INVALID_SOCKET;
- c->tap_nack_mode = false;
}
void conn_close(conn *c) {
@@ -2759,9 +2758,7 @@ static void process_bin_tap_packet(tap_event_t event, conn *c) {
c->ewouldblock = true;
break;
default:
- if ((tap_flags & TAP_FLAG_ACK) ||
- (ret != ENGINE_SUCCESS && c->tap_nack_mode))
- {
+ if ((tap_flags & TAP_FLAG_ACK) || (ret != ENGINE_SUCCESS)) {
write_bin_packet(c, engine_error_2_protocol_error(ret), 0);
} else {
conn_set_state(c, conn_new_cmd);
@@ -6329,11 +6326,6 @@ static int get_socket_fd(const void *cookie) {
return c->sfd;
}
-static void set_tap_nack_mode(const void *cookie, bool enable) {
- conn *c = (conn *)cookie;
- c->tap_nack_mode = enable;
-}
-
static ENGINE_ERROR_CODE reserve_cookie(const void *cookie) {
conn *c = (conn *)cookie;
++c->refcount;
@@ -6781,7 +6773,6 @@ static SERVER_HANDLE_V1 *get_server_api(void)
.store_engine_specific = store_engine_specific,
.get_engine_specific = get_engine_specific,
.get_socket_fd = get_socket_fd,
- .set_tap_nack_mode = set_tap_nack_mode,
.notify_io_complete = notify_io_complete,
.reserve = reserve_cookie,
.release = release_cookie
diff --git a/daemon/memcached.h b/daemon/memcached.h
index 32697e0..232d73e 100644
--- a/daemon/memcached.h
+++ b/daemon/memcached.h
@@ -375,7 +375,6 @@ struct conn {
ENGINE_ERROR_CODE aiostat;
bool ewouldblock;
- bool tap_nack_mode;
TAP_ITERATOR tap_iterator;
};
diff --git a/include/memcached/server_api.h b/include/memcached/server_api.h
index 847640f..3c8e7ee 100644
--- a/include/memcached/server_api.h
+++ b/include/memcached/server_api.h
@@ -131,16 +131,6 @@ extern "C" {
void (*notify_io_complete)(const void *cookie,
ENGINE_ERROR_CODE status);
-
- /**
- * Enable or disable automatic generation of a negative ACK
- * message for a TAP message (even if the request didn't have
- * tap ack flag set)
- * @param cookie cookie representing the connection
- * @param enabel true to enable, false to disable
- */
- void (*set_tap_nack_mode)(const void *cookie, bool enable);
-
/**
* Notify the core that we're holding on to this cookie for
* future use. (The core guarantees it will not invalidate the
diff --git a/programs/mock_server.c b/programs/mock_server.c
index 0213307..f07b118 100644
--- a/programs/mock_server.c
+++ b/programs/mock_server.c
@@ -58,11 +58,6 @@ static int mock_get_socket_fd(const void *cookie) {
return c->sfd;
}
-static void mock_set_tap_nack_mode(const void *cookie, bool enable) {
- (void)cookie;
- (void)enable;
-}
-
static ENGINE_ERROR_CODE mock_cookie_reserve(const void *cookie) {
(void)cookie;
return ENGINE_SUCCESS;
@@ -275,7 +270,6 @@ SERVER_HANDLE_V1 *get_mock_server_api(void)
.store_engine_specific = mock_store_engine_specific,
.get_engine_specific = mock_get_engine_specific,
.get_socket_fd = mock_get_socket_fd,
- .set_tap_nack_mode = mock_set_tap_nack_mode,
.notify_io_complete = mock_notify_io_complete,
.reserve = mock_cookie_reserve,
.release = mock_cookie_release