Lines Matching refs:db
199 robj *lobj = lookupKeyWrite(c->db,c->argv[1]); in pushGenericCommand()
212 dbAdd(c->db,c->argv[1],lobj); in pushGenericCommand()
221 signalModifiedKey(c->db,c->argv[1]); in pushGenericCommand()
222 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in pushGenericCommand()
257 signalModifiedKey(c->db,c->argv[1]); in pushxGenericCommand()
259 c->argv[1],c->db->id); in pushxGenericCommand()
270 signalModifiedKey(c->db,c->argv[1]); in pushxGenericCommand()
271 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in pushxGenericCommand()
349 signalModifiedKey(c->db,c->argv[1]); in lsetCommand()
350 notifyKeyspaceEvent(NOTIFY_LIST,"lset",c->argv[1],c->db->id); in lsetCommand()
370 notifyKeyspaceEvent(NOTIFY_LIST,event,c->argv[1],c->db->id); in popGenericCommand()
373 c->argv[1],c->db->id); in popGenericCommand()
374 dbDelete(c->db,c->argv[1]); in popGenericCommand()
376 signalModifiedKey(c->db,c->argv[1]); in popGenericCommand()
471 notifyKeyspaceEvent(NOTIFY_LIST,"ltrim",c->argv[1],c->db->id); in ltrimCommand()
473 dbDelete(c->db,c->argv[1]); in ltrimCommand()
474 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],c->db->id); in ltrimCommand()
476 signalModifiedKey(c->db,c->argv[1]); in ltrimCommand()
513 signalModifiedKey(c->db,c->argv[1]); in lremCommand()
514 notifyKeyspaceEvent(NOTIFY_GENERIC,"lrem",c->argv[1],c->db->id); in lremCommand()
518 dbDelete(c->db,c->argv[1]); in lremCommand()
519 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],c->db->id); in lremCommand()
547 dbAdd(c->db,dstkey,dstobj); in rpoplpushHandlePush()
549 signalModifiedKey(c->db,dstkey); in rpoplpushHandlePush()
551 notifyKeyspaceEvent(NOTIFY_LIST,"lpush",dstkey,c->db->id); in rpoplpushHandlePush()
566 robj *dobj = lookupKeyWrite(c->db,c->argv[2]); in rpoplpushCommand()
581 notifyKeyspaceEvent(NOTIFY_LIST,"rpop",touchedkey,c->db->id); in rpoplpushCommand()
583 dbDelete(c->db,touchedkey); in rpoplpushCommand()
585 touchedkey,c->db->id); in rpoplpushCommand()
587 signalModifiedKey(c->db,touchedkey); in rpoplpushCommand()
632 de = dictFind(c->db->blocking_keys,keys[j]); in blockForKeys()
638 retval = dictAdd(c->db->blocking_keys,keys[j],l); in blockForKeys()
663 l = dictFetchValue(c->db->blocking_keys,key); in unblockClientWaitingData()
668 dictDelete(c->db->blocking_keys,key); in unblockClientWaitingData()
687 void signalListAsReady(redisDb *db, robj *key) { in signalListAsReady() argument
691 if (dictFind(db->blocking_keys,key) == NULL) return; in signalListAsReady()
694 if (dictFind(db->ready_keys,key) != NULL) return; in signalListAsReady()
699 rl->db = db; in signalListAsReady()
707 serverAssert(dictAdd(db->ready_keys,key,NULL) == DICT_OK); in signalListAsReady()
729 int serveClientBlockedOnList(client *receiver, robj *key, robj *dstkey, redisDb *db, robj *value, i… in serveClientBlockedOnList() argument
740 db->id,argv,2,PROPAGATE_AOF|PROPAGATE_REPL); in serveClientBlockedOnList()
749 lookupKeyWrite(receiver->db,dstkey); in serveClientBlockedOnList()
757 db->id,argv,2, in serveClientBlockedOnList()
767 db->id,argv,3, in serveClientBlockedOnList()
806 dictDelete(rl->db->ready_keys,rl->key); in handleClientsBlockedOnLists()
810 robj *o = lookupKeyWrite(rl->db,rl->key); in handleClientsBlockedOnLists()
816 de = dictFind(rl->db->blocking_keys,rl->key); in handleClientsBlockedOnLists()
838 rl->key,dstkey,rl->db,value, in handleClientsBlockedOnLists()
855 dbDelete(rl->db,rl->key); in handleClientsBlockedOnLists()
880 o = lookupKeyWrite(c->db,c->argv[j]); in blockingPopGenericCommand()
897 c->argv[j],c->db->id); in blockingPopGenericCommand()
899 dbDelete(c->db,c->argv[j]); in blockingPopGenericCommand()
901 c->argv[j],c->db->id); in blockingPopGenericCommand()
903 signalModifiedKey(c->db,c->argv[j]); in blockingPopGenericCommand()
941 robj *key = lookupKeyWrite(c->db, c->argv[1]); in brpoplpushCommand()