diff options
author | Trond Norbye <trond.norbye@gmail.com> | 2011-05-06 10:04:35 +0200 |
---|---|---|
committer | Trond Norbye <trond.norbye@gmail.com> | 2011-07-13 08:15:48 +0200 |
commit | 05a6a8573c429ad93749d68af2f186a6af86ccb7 (patch) | |
tree | 5c44e6c28718972868150aa07d13ead116e72dec | |
parent | 7e2c95cbed29a475b1d2cd741bc81d93369e52b2 (diff) | |
download | memcached-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.c | 11 | ||||
-rw-r--r-- | daemon/memcached.h | 1 | ||||
-rw-r--r-- | include/memcached/server_api.h | 10 | ||||
-rw-r--r-- | programs/mock_server.c | 6 |
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 |