summaryrefslogtreecommitdiff
path: root/daemon
diff options
context:
space:
mode:
Diffstat (limited to 'daemon')
-rw-r--r--daemon/memcached.c11
-rw-r--r--daemon/memcached.h1
2 files changed, 1 insertions, 11 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;
};