Lines Matching refs:db

80     if ((flags & OBJ_SET_NX && lookupKeyWrite(c->db,key) != NULL) ||  in setGenericCommand()
81 (flags & OBJ_SET_XX && lookupKeyWrite(c->db,key) == NULL)) in setGenericCommand()
86 setKey(c->db,key,val); in setGenericCommand()
88 if (expire) setExpire(c,c->db,key,mstime()+milliseconds); in setGenericCommand()
89 notifyKeyspaceEvent(NOTIFY_STRING,"set",key,c->db->id); in setGenericCommand()
91 "expire",key,c->db->id); in setGenericCommand()
179 setKey(c->db,c->argv[1],c->argv[2]); in getsetCommand()
180 notifyKeyspaceEvent(NOTIFY_STRING,"set",c->argv[1],c->db->id); in getsetCommand()
197 o = lookupKeyWrite(c->db,c->argv[1]); in setrangeCommand()
210 dbAdd(c->db,c->argv[1],o); in setrangeCommand()
230 o = dbUnshareStringValue(c->db,c->argv[1],o); in setrangeCommand()
236 signalModifiedKey(c->db,c->argv[1]); in setrangeCommand()
238 "setrange",c->argv[1],c->db->id); in setrangeCommand()
290 robj *o = lookupKeyRead(c->db,c->argv[j]); in mgetCommand()
315 if (lookupKeyWrite(c->db,c->argv[j]) != NULL) { in msetGenericCommand()
324 setKey(c->db,c->argv[j],c->argv[j+1]); in msetGenericCommand()
325 notifyKeyspaceEvent(NOTIFY_STRING,"set",c->argv[j],c->db->id); in msetGenericCommand()
343 o = lookupKeyWrite(c->db,c->argv[1]); in incrDecrCommand()
364 dbOverwrite(c->db,c->argv[1],new); in incrDecrCommand()
366 dbAdd(c->db,c->argv[1],new); in incrDecrCommand()
369 signalModifiedKey(c->db,c->argv[1]); in incrDecrCommand()
370 notifyKeyspaceEvent(NOTIFY_STRING,"incrby",c->argv[1],c->db->id); in incrDecrCommand()
403 o = lookupKeyWrite(c->db,c->argv[1]); in incrbyfloatCommand()
416 dbOverwrite(c->db,c->argv[1],new); in incrbyfloatCommand()
418 dbAdd(c->db,c->argv[1],new); in incrbyfloatCommand()
419 signalModifiedKey(c->db,c->argv[1]); in incrbyfloatCommand()
420 notifyKeyspaceEvent(NOTIFY_STRING,"incrbyfloat",c->argv[1],c->db->id); in incrbyfloatCommand()
437 o = lookupKeyWrite(c->db,c->argv[1]); in appendCommand()
441 dbAdd(c->db,c->argv[1],c->argv[2]); in appendCommand()
456 o = dbUnshareStringValue(c->db,c->argv[1],o); in appendCommand()
460 signalModifiedKey(c->db,c->argv[1]); in appendCommand()
461 notifyKeyspaceEvent(NOTIFY_STRING,"append",c->argv[1],c->db->id); in appendCommand()