fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-04 16:51:12 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #3059 from itamarhaber/keyspacenotif-lrem

Browse Source 
Adds keyspace notifications for LREM
This commit is contained in:
Salvatore Sanfilippo 2016-02-05 15:52:57 +01:00
commit aa953b6ec3
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/server.c
View File

@ -3866,7 +3866,7 @@ int redisSupervisedUpstart(void) {
return 0; 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); raise(SIGSTOP);
unsetenv("UPSTART_JOB"); unsetenv("UPSTART_JOB");
return 1; return 1;
@ -3890,7 +3890,7 @@ int redisSupervisedSystemd(void) {
return 0; 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) { if ((fd = socket(AF_UNIX, SOCK_DGRAM, 0)) == -1) {
serverLog(LL_WARNING, serverLog(LL_WARNING,
"Can't connect to systemd socket %s", notify_socket); "Can't connect to systemd socket %s", notify_socket);

7
src/t_list.c
View File

@ -509,12 +509,17 @@ void lremCommand(client *c) {
} }
listTypeReleaseIterator(li); listTypeReleaseIterator(li);
if (removed) {
signalModifiedKey(c->db,c->argv[1]);
notifyKeyspaceEvent(NOTIFY_GENERIC,"lrem",c->argv[1],c->db->id);
}
if (listTypeLength(subject) == 0) { if (listTypeLength(subject) == 0) {
dbDelete(c->db,c->argv[1]); dbDelete(c->db,c->argv[1]);
notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],c->db->id);
} }
addReplyLongLong(c,removed); addReplyLongLong(c,removed);
if (removed) signalModifiedKey(c->db,c->argv[1]);
} }
/* This is the semantic of this command: /* This is the semantic of this command: