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); 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: