Lines Matching refs:db
276 set = lookupKeyWrite(c->db,c->argv[1]); in saddCommand()
279 dbAdd(c->db,c->argv[1],set); in saddCommand()
292 signalModifiedKey(c->db,c->argv[1]); in saddCommand()
293 notifyKeyspaceEvent(NOTIFY_SET,"sadd",c->argv[1],c->db->id); in saddCommand()
310 dbDelete(c->db,c->argv[1]); in sremCommand()
317 signalModifiedKey(c->db,c->argv[1]); in sremCommand()
318 notifyKeyspaceEvent(NOTIFY_SET,"srem",c->argv[1],c->db->id); in sremCommand()
321 c->db->id); in sremCommand()
329 srcset = lookupKeyWrite(c->db,c->argv[1]); in smoveCommand()
330 dstset = lookupKeyWrite(c->db,c->argv[2]); in smoveCommand()
355 notifyKeyspaceEvent(NOTIFY_SET,"srem",c->argv[1],c->db->id); in smoveCommand()
359 dbDelete(c->db,c->argv[1]); in smoveCommand()
360 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],c->db->id); in smoveCommand()
366 dbAdd(c->db,c->argv[2],dstset); in smoveCommand()
369 signalModifiedKey(c->db,c->argv[1]); in smoveCommand()
370 signalModifiedKey(c->db,c->argv[2]); in smoveCommand()
376 notifyKeyspaceEvent(NOTIFY_SET,"sadd",c->argv[2],c->db->id); in smoveCommand()
440 notifyKeyspaceEvent(NOTIFY_SET,"spop",c->argv[1],c->db->id); in spopWithCountCommand()
451 dbDelete(c->db,c->argv[1]); in spopWithCountCommand()
452 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],c->db->id); in spopWithCountCommand()
456 signalModifiedKey(c->db,c->argv[1]); in spopWithCountCommand()
497 alsoPropagate(server.sremCommand,c->db->id,propargv,3, in spopWithCountCommand()
528 dbOverwrite(c->db,c->argv[1],newset); in spopWithCountCommand()
543 alsoPropagate(server.sremCommand,c->db->id,propargv,3, in spopWithCountCommand()
558 signalModifiedKey(c->db,c->argv[1]); in spopWithCountCommand()
592 notifyKeyspaceEvent(NOTIFY_SET,"spop",c->argv[1],c->db->id); in spopCommand()
605 dbDelete(c->db,c->argv[1]); in spopCommand()
606 notifyKeyspaceEvent(NOTIFY_GENERIC,"del",c->argv[1],c->db->id); in spopCommand()
610 signalModifiedKey(c->db,c->argv[1]); in spopCommand()
803 lookupKeyWrite(c->db,setkeys[j]) : in sinterGenericCommand()
804 lookupKeyRead(c->db,setkeys[j]); in sinterGenericCommand()
808 if (dbDelete(c->db,dstkey)) { in sinterGenericCommand()
809 signalModifiedKey(c->db,dstkey); in sinterGenericCommand()
906 int deleted = dbDelete(c->db,dstkey); in sinterGenericCommand()
908 dbAdd(c->db,dstkey,dstset); in sinterGenericCommand()
911 dstkey,c->db->id); in sinterGenericCommand()
917 dstkey,c->db->id); in sinterGenericCommand()
919 signalModifiedKey(c->db,dstkey); in sinterGenericCommand()
949 lookupKeyWrite(c->db,setkeys[j]) : in sunionDiffGenericCommand()
950 lookupKeyRead(c->db,setkeys[j]); in sunionDiffGenericCommand()
1078 int deleted = dbDelete(c->db,dstkey); in sunionDiffGenericCommand()
1080 dbAdd(c->db,dstkey,dstset); in sunionDiffGenericCommand()
1084 dstkey,c->db->id); in sunionDiffGenericCommand()
1090 dstkey,c->db->id); in sunionDiffGenericCommand()
1092 signalModifiedKey(c->db,dstkey); in sunionDiffGenericCommand()