diff options
author | Michael Grunder <michael.grunder@gmail.com> | 2023-08-18 21:07:25 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-08-18 21:07:25 -0700 |
commit | 869f3d0ef1513dd0258ad7190c9914df16dcc4a4 (patch) | |
tree | da35d90b552e3903035c6e2b417ca1127fe68136 | |
parent | 039385bd8b9192a3994d75e75e377933f17d1f47 (diff) |
Make redisEnableKeepAlive a no-op on AF_UNIX connections. (#1215)
Fixes #1185
-rw-r--r-- | .gitignore | 1 | ||||
-rw-r--r-- | net.c | 4 | ||||
-rw-r--r-- | test.c | 19 |
3 files changed, 24 insertions, 0 deletions
@@ -7,3 +7,4 @@ /*.pc *.dSYM tags +compile_commands.json @@ -173,6 +173,10 @@ int redisKeepAlive(redisContext *c, int interval) { int val = 1; redisFD fd = c->fd; + /* TCP_KEEPALIVE makes no sense with AF_UNIX connections */ + if (c->connection_type == REDIS_CONN_UNIX) + return REDIS_ERR; + #ifndef _WIN32 if (setsockopt(fd, SOL_SOCKET, SO_KEEPALIVE, &val, sizeof(val)) == -1){ __redisSetError(c,REDIS_ERR_OTHER,strerror(errno)); @@ -431,6 +431,24 @@ static void test_tcp_options(struct config cfg) { redisFree(c); } +static void test_unix_keepalive(struct config cfg) { + redisContext *c; + redisReply *r; + + c = do_connect(cfg); + + test("Setting TCP_KEEPALIVE on a unix socket returns an error: "); + test_cond(redisEnableKeepAlive(c) == REDIS_ERR && c->err == 0); + + test("Setting TCP_KEEPALIVE on a unix socket doesn't break the connection: "); + r = redisCommand(c, "PING"); + test_cond(r != NULL && r->type == REDIS_REPLY_STATUS && r->len == 4 && + !memcmp(r->str, "PONG", 4)); + freeReplyObject(r); + + redisFree(c); +} + static void test_reply_reader(void) { redisReader *reader; void *reply, *root; @@ -2363,6 +2381,7 @@ int main(int argc, char **argv) { test_blocking_connection_timeouts(cfg); test_blocking_io_errors(cfg); test_invalid_timeout_errors(cfg); + test_unix_keepalive(cfg); if (throughput) test_throughput(cfg); } else { test_skipped(); |