Lines Matching refs:db
111 propagate(server.multiCommand,c->db->id,&multistring,1, in execCommandPropagateMulti()
213 replicationFeedMonitors(c,server.monitors,c->db->id,c->argv,c->argc); in execCommand()
230 redisDb *db; member
244 if (wk->db == c->db && equalStringObjects(key,wk->key)) in watchForKey()
248 clients = dictFetchValue(c->db->watched_keys,key); in watchForKey()
251 dictAdd(c->db->watched_keys,key,clients); in watchForKey()
258 wk->db = c->db; in watchForKey()
278 clients = dictFetchValue(wk->db->watched_keys, wk->key); in unwatchAllKeys()
283 dictDelete(wk->db->watched_keys, wk->key); in unwatchAllKeys()
293 void touchWatchedKey(redisDb *db, robj *key) { in touchWatchedKey() argument
298 if (dictSize(db->watched_keys) == 0) return; in touchWatchedKey()
299 clients = dictFetchValue(db->watched_keys, key); in touchWatchedKey()
331 if (dbid == -1 || wk->db->id == dbid) { in touchWatchedKeysOnFlush()
332 if (dictFind(wk->db->dict, wk->key->ptr) != NULL) in touchWatchedKeysOnFlush()