Lines Matching refs:db
109 propagate(server.multiCommand,c->db->id,&multistring,1, in execCommandPropagateMulti()
181 replicationFeedMonitors(c,server.monitors,c->db->id,c->argv,c->argc); in execCommand()
198 redisDb *db; member
212 if (wk->db == c->db && equalStringObjects(key,wk->key)) in watchForKey()
216 clients = dictFetchValue(c->db->watched_keys,key); in watchForKey()
219 dictAdd(c->db->watched_keys,key,clients); in watchForKey()
226 wk->db = c->db; in watchForKey()
246 clients = dictFetchValue(wk->db->watched_keys, wk->key); in unwatchAllKeys()
251 dictDelete(wk->db->watched_keys, wk->key); in unwatchAllKeys()
261 void touchWatchedKey(redisDb *db, robj *key) { in touchWatchedKey() argument
266 if (dictSize(db->watched_keys) == 0) return; in touchWatchedKey()
267 clients = dictFetchValue(db->watched_keys, key); in touchWatchedKey()
299 if (dbid == -1 || wk->db->id == dbid) { in touchWatchedKeysOnFlush()
300 if (dictFind(wk->db->dict, wk->key->ptr) != NULL) in touchWatchedKeysOnFlush()