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->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()
314 if (lookupKeyWrite(c->db,c->argv[j]) != NULL) { in msetGenericCommand()
326 setKey(c->db,c->argv[j],c->argv[j+1]); in msetGenericCommand()
327 notifyKeyspaceEvent(NOTIFY_STRING,"set",c->argv[j],c->db->id); in msetGenericCommand()
345 o = lookupKeyWrite(c->db,c->argv[1]); in incrDecrCommand()
366 dbOverwrite(c->db,c->argv[1],new); in incrDecrCommand()
368 dbAdd(c->db,c->argv[1],new); in incrDecrCommand()
371 signalModifiedKey(c->db,c->argv[1]); in incrDecrCommand()
372 notifyKeyspaceEvent(NOTIFY_STRING,"incrby",c->argv[1],c->db->id); in incrDecrCommand()
405 o = lookupKeyWrite(c->db,c->argv[1]); in incrbyfloatCommand()
418 dbOverwrite(c->db,c->argv[1],new); in incrbyfloatCommand()
420 dbAdd(c->db,c->argv[1],new); in incrbyfloatCommand()
421 signalModifiedKey(c->db,c->argv[1]); in incrbyfloatCommand()
422 notifyKeyspaceEvent(NOTIFY_STRING,"incrbyfloat",c->argv[1],c->db->id); in incrbyfloatCommand()
439 o = lookupKeyWrite(c->db,c->argv[1]); in appendCommand()
443 dbAdd(c->db,c->argv[1],c->argv[2]); in appendCommand()
458 o = dbUnshareStringValue(c->db,c->argv[1],o); in appendCommand()
462 signalModifiedKey(c->db,c->argv[1]); in appendCommand()
463 notifyKeyspaceEvent(NOTIFY_STRING,"append",c->argv[1],c->db->id); in appendCommand()