From 68e779f34bd7a06397ebea520f5ce43372fad000 Mon Sep 17 00:00:00 2001 From: Itamar Haber Date: Tue, 2 Feb 2016 09:58:19 -0800 Subject: [PATCH 1/2] Adds keyspace notifications for lrem --- src/t_list.c | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/t_list.c b/src/t_list.c index 0008404d..7d5be11a 100644 --- a/src/t_list.c +++ b/src/t_list.c @@ -509,12 +509,17 @@ void lremCommand(client *c) { } listTypeReleaseIterator(li); + if (removed) { + signalModifiedKey(c->db,c->argv[1]); + notifyKeyspaceEvent(NOTIFY_GENERIC,"lrem",c->argv[1],c->db->id); + } + if (listTypeLength(subject) == 0) { dbDelete(c->db,c->argv[1]); + notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],c->db->id); } addReplyLongLong(c,removed); - if (removed) signalModifiedKey(c->db,c->argv[1]); } /* This is the semantic of this command: From 31a70a8bcf01ceb35ccbd2ae1f567ddf45321b2f Mon Sep 17 00:00:00 2001 From: Itamar Haber Date: Wed, 3 Feb 2016 11:04:09 -0800 Subject: [PATCH 2/2] Fixes a typo --- src/server.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/server.c b/src/server.c index 5ca784c5..8ed105d9 100644 --- a/src/server.c +++ b/src/server.c @@ -3866,7 +3866,7 @@ int redisSupervisedUpstart(void) { return 0; } - serverLog(LL_NOTICE, "supervised by upstart, will stop to signal readyness"); + serverLog(LL_NOTICE, "supervised by upstart, will stop to signal readiness"); raise(SIGSTOP); unsetenv("UPSTART_JOB"); return 1; @@ -3890,7 +3890,7 @@ int redisSupervisedSystemd(void) { return 0; } - serverLog(LL_NOTICE, "supervised by systemd, will signal readyness"); + serverLog(LL_NOTICE, "supervised by systemd, will signal readiness"); if ((fd = socket(AF_UNIX, SOCK_DGRAM, 0)) == -1) { serverLog(LL_WARNING, "Can't connect to systemd socket %s", notify_socket);