Home
last modified time | relevance | path

Searched refs:dictFind (Results 1 – 25 of 25) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dblocked.c272 de = dictFind(rl->db->blocking_keys,rl->key); in handleClientsBlockedOnKeys()
333 de = dictFind(rl->db->blocking_keys,rl->key); in handleClientsBlockedOnKeys()
376 dictEntry *de = dictFind(rl->db->blocking_keys,rl->key); in handleClientsBlockedOnKeys()
524 de = dictFind(c->db->blocking_keys,keys[j]); in blockForKeys()
589 if (dictFind(db->blocking_keys,key) == NULL) return; in signalKeyAsReady()
592 if (dictFind(db->ready_keys,key) != NULL) return; in signalKeyAsReady()
H A Dpubsub.c68 de = dictFind(server.pubsub_channels,channel); in pubsubSubscribeChannel()
100 de = dictFind(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
232 de = dictFind(server.pubsub_channels,channel); in pubsubPublishMessage()
H A Devict.c180 if (sampledict != keydict) de = dictFind(keydict, key); in evictionPoolPopulate()
506 de = dictFind(server.db[pool[k].dbid].dict, in freeMemoryIfNeeded()
509 de = dictFind(server.db[pool[k].dbid].expires, in freeMemoryIfNeeded()
H A Ddict.c476 dictEntry *dictFind(dict *d, const void *key) in dictFind() function
500 he = dictFind(d,key); in dictFetchValue()
1181 dictEntry *de = dictFind(dict,key); in main()
1190 dictEntry *de = dictFind(dict,key); in main()
1199 dictEntry *de = dictFind(dict,key); in main()
1209 dictEntry *de = dictFind(dict,key); in main()
H A Ddb.c56 dictEntry *de = dictFind(db->dict,key->ptr); in lookupKey()
190 dictEntry *de = dictFind(db->dict,key->ptr); in dbOverwrite()
228 return dictFind(db->dict,key->ptr) != NULL; in dbExists()
249 if (dictFind(db->expires,key)) { in dbRandomKey()
1068 serverAssertWithInfo(NULL,key,dictFind(db->dict,key->ptr) != NULL); in removeExpire()
1080 kde = dictFind(db->dict,key->ptr); in setExpire()
1097 (de = dictFind(db->expires,key->ptr)) == NULL) return -1; in getExpire()
1101 serverAssertWithInfo(NULL,key,dictFind(db->dict,key->ptr) != NULL); in getExpire()
H A Ddict.h161 dictEntry * dictFind(dict *d, const void *key);
H A Dexpire.c303 dictEntry *expire = dictFind(db->expires,keyname); in expireSlaveKeys()
H A Dmulti.c332 if (dictFind(wk->db->dict, wk->key->ptr) != NULL) in touchWatchedKeysOnFlush()
H A Dt_hash.c95 de = dictFind(o->ptr, field); in hashTypeGetFromHashTable()
240 dictEntry *de = dictFind(o->ptr,field); in hashTypeSet()
H A Ddebug.c391 if ((de = dictFind(c->db->dict,c->argv[2]->ptr)) == NULL) { in debugCommand()
443 if ((de = dictFind(c->db->dict,c->argv[2]->ptr)) == NULL) { in debugCommand()
1143 de = dictFind(cc->db->dict, key->ptr); in logCurrentClient()
H A Dlatency.c596 de = dictFind(server.latency_events,c->argv[2]->ptr); in latencyCommand()
H A Dt_zset.c1262 dictEntry *de = dictFind(zs->dict, member); in zsetScore()
1376 de = dictFind(zs->dict,ele); in zsetAdd()
1510 de = dictFind(zs->dict,ele); in zsetRank()
2098 if (dictFind(ht,val->ele) != NULL) { in zuiFind()
2120 if ((de = dictFind(zs->dict,val->ele)) != NULL) { in zuiFind()
H A Dobject.c1237 if ((de = dictFind(c->db->dict,key->ptr)) == NULL) return NULL; in objectCommandLookup()
1330 if ((de = dictFind(c->db->dict,c->argv[2]->ptr)) == NULL) { in memoryCommand()
H A Dscripting.c1189 if ((de = dictFind(server.lua_scripts,sha)) != NULL) { in luaCreateFunction()
1511 if (dictFind(server.lua_scripts,c->argv[j]->ptr)) in scriptCommand()
H A Dt_set.c110 return dictFind((dict*)subject->ptr,value) != NULL; in setTypeIsMember()
H A Ddefrag.c956 dictEntry *de = dictFind(db->dict, current_key); in defragLaterStep()
H A Dmodule.c493 dictEntry *he = dictFind(server.moduleapi, funcname); in RM_GetApi()
763 dictEntry *de = dictFind(modules,modulename); in RM_IsModuleNameBusy()
4753 dictEntry *de = dictFind(server.sharedapi, apiname); in RM_GetSharedAPI()
H A Dcluster.c939 de = dictFind(server.cluster->nodes,s); in clusterLookupNode()
1150 de = dictFind(server.cluster->nodes_black_list,id); in clusterBlacklistAddNode()
1163 retval = dictFind(server.cluster->nodes_black_list,id) != NULL; in clusterBlacklistExists()
H A Dredis-cli.c2450 dictEntry *entry = dictFind(related, key); in clusterManagerGetAntiAffinityScore()
3793 dictEntry *entry = dictFind(clusterManagerUncoveredSlots, slot); in clusterManagerFixSlotsCoverage()
3824 dictEntry *entry = dictFind(clusterManagerUncoveredSlots, slot); in clusterManagerFixSlotsCoverage()
6320 dictEntry *de = dictFind(types_dict, typereply); in getKeyTypes()
H A Dreplication.c2380 return dictFind(server.repl_scriptcache_dict,sha1) != NULL; in replicationScriptCacheExists()
H A Dconfig.c2029 if (dictFind(state->rewritten,option) == NULL) {
H A Dsentinel.c1195 if (dictFind(table,sdsname)) { in createSentinelRedisInstance()
/f-stack/app/redis-5.0.5/deps/hiredis/
H A Ddict.c168 entry = dictFind(ht, key); in dictReplace()
243 static dictEntry *dictFind(dict *ht, const void *key) { in dictFind() function
H A Ddict.h121 static dictEntry * dictFind(dict *ht, const void *key);
H A Dasync.c388 de = dictFind(callbacks,sname); in __redisGetSubscribeCallback()