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

Now the PUSH side of RPOPLPUSH is able to unblock clients blocked on BLPOP

Browse Source
This commit is contained in:
antirez 2010-01-02 10:02:24 -05:00
parent 08ff05b012
commit e20fb74f69
1 changed files with 15 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
redis.c
View File

@ -3862,20 +3862,24 @@ static void rpoplpushcommand(redisClient *c) {
robj *ele = listNodeValue(ln); robj *ele = listNodeValue(ln);
list *dstlist; list *dstlist;
if (dobj == NULL) { if (dobj && dobj->type != REDIS_LIST) {
addReply(c,shared.wrongtypeerr);
return;
}
/* Add the element to the target list (unless it's directly
* passed to some BLPOP-ing client */
if (!handleClientsWaitingListPush(c,c->argv[2],ele)) {
if (dobj == NULL) {
/* Create the list if the key does not exist */ /* Create the list if the key does not exist */
dobj = createListObject(); dobj = createListObject();
dictAdd(c->db->dict,c->argv[2],dobj); dictAdd(c->db->dict,c->argv[2],dobj);
incrRefCount(c->argv[2]); incrRefCount(c->argv[2]);
} else if (dobj->type != REDIS_LIST) {
addReply(c,shared.wrongtypeerr);
return;
} }
/* Add the element to the target list */
dstlist = dobj->ptr; dstlist = dobj->ptr;
listAddNodeHead(dstlist,ele); listAddNodeHead(dstlist,ele);
incrRefCount(ele); incrRefCount(ele);
}
/* Send the element to the client as reply as well */ /* Send the element to the client as reply as well */
addReplyBulkLen(c,ele); addReplyBulkLen(c,ele);