Home
last modified time | relevance | path

Searched refs:dictSize (Results 1 – 20 of 20) sorted by relevance

/redis-3.2.3/utils/hashtable/
H A Drehashing.c74 dictEntry **des = zmalloc(sizeof(dictEntry*)*dictSize(d)); in stressGetKeys()
76 int requested = rand() % (dictSize(d)+1); in stressGetKeys()
110 printf("Size: %d\n", (int)dictSize(d)); in main()
/redis-3.2.3/src/
H A Dpubsub.c52 return dictSize(c->pubsub_channels)+ in clientSubscriptionsCount()
118 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribeChannel()
169 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribePattern()
193 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribeAllChannels()
218 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribeAllPatterns()
H A Drdb.c608 if ((n = rdbSaveLen(rdb,dictSize(set))) == -1) return -1; in rdbSaveObject()
637 if ((n = rdbSaveLen(rdb,dictSize(zs->dict))) == -1) return -1; in rdbSaveObject()
665 if ((n = rdbSaveLen(rdb,dictSize((dict*)o->ptr))) == -1) return -1; in rdbSaveObject()
779 if (dictSize(d) == 0) continue; in rdbSaveRio()
792 db_size = (dictSize(db->dict) <= UINT32_MAX) ? in rdbSaveRio()
793 dictSize(db->dict) : in rdbSaveRio()
795 expires_size = (dictSize(db->expires) <= UINT32_MAX) ? in rdbSaveRio()
796 dictSize(db->expires) : in rdbSaveRio()
H A Ddict.c632 if (dictSize(d) == 0) return NULL; in dictGetRandomKey()
695 if (dictSize(d) < count) count = dictSize(d); in dictGetSomeKeys()
861 if (dictSize(d) == 0) return 0; in dictScan()
H A Ddb.c229 if (dictSize(db->expires) > 0) dictDelete(db->expires,key->ptr); in dbDelete()
281 removed += dictSize(server.db[j].dict); in emptyDb()
318 server.dirty += dictSize(c->db->dict); in flushdbCommand()
676 addReplyLongLong(c,dictSize(c->db->dict)); in dbsizeCommand()
863 if (dictSize(db->expires) == 0 || in getExpire()
H A Ddict.h146 #define dictSize(d) ((d)->ht[0].used+(d)->ht[1].used) macro
H A Dlatency.c238 if (dictSize(server.latency_events) == 0 && in createLatencyReport()
499 addReplyMultiBulkLen(c,dictSize(server.latency_events)); in latencyCommandReplyWithLatestEvents()
H A Dserver.c666 used = dictSize(dict); in htNeedsResize()
825 if ((num = dictSize(db->expires)) == 0) { in activeExpireCycle()
1145 used = dictSize(server.db[j].dict); in serverCron()
1146 vkeys = dictSize(server.db[j].expires); in serverCron()
2762 addReplyMultiBulkLen(c, dictSize(server.commands)); in commandCommand()
2775 addReplyLongLong(c, dictSize(server.commands)); in commandCommand()
3114 dictSize(server.pubsub_channels), in genRedisInfoString()
3117 dictSize(server.migrate_cached_sockets)); in genRedisInfoString()
3289 keys = dictSize(server.db[j].dict); in genRedisInfoString()
3290 vkeys = dictSize(server.db[j].expires); in genRedisInfoString()
[all …]
H A Dsentinel.c2745 addReplyBulkLongLong(c,dictSize(ri->slaves)); in addReplySentinelRedisInstance()
2749 addReplyBulkLongLong(c,dictSize(ri->sentinels)); in addReplySentinelRedisInstance()
2832 addReplyMultiBulkLen(c,dictSize(instances)); in addReplyDictOfRedisInstances()
2865 int voters = dictSize(master->sentinels)+1; /* Known Sentinels + myself. */ in sentinelIsQuorumReachable()
3130 addReplyMultiBulkLen(c,dictSize(masters_local) * 2); in sentinelCommand()
3138 addReplyMultiBulkLen(c,dictSize(ri->slaves) + 1); /* +1 for self */ in sentinelCommand()
3247 dictSize(sentinel.masters), in sentinelInfoCommand()
3265 dictSize(ri->slaves), in sentinelInfoCommand()
3266 dictSize(ri->sentinels)+1); in sentinelInfoCommand()
3282 addReplyMultiBulkLen(c,dictSize(sentinel.masters)); in sentinelRoleCommand()
[all …]
H A Dsort.c312 case OBJ_ZSET: vectorlen = dictSize(((zset*)sortval->ptr)->dict); break; in sortCommand()
407 long zsetlen = dictSize(((zset*)sortval->ptr)->dict); in sortCommand()
H A Dmulti.c266 if (dictSize(db->watched_keys) == 0) return; in touchWatchedKey()
H A Dcluster.c1911 if (dictSize(server.pubsub_channels) || in clusterProcessPacket()
2185 int freshnodes = dictSize(server.cluster->nodes)-2; in clusterSendPing()
2213 wanted = floor(dictSize(server.cluster->nodes)/10); in clusterSendPing()
3598 if (dictSize(server.db[j].dict)) return C_ERR; in verifyClusterConfigWithData()
3919 if (dictSize(server.db[0].dict) != 0) { in clusterCommand()
4121 dictSize(server.cluster->nodes), in clusterCommand()
4222 (myself->numslots != 0 || dictSize(server.db[0].dict) != 0)) { in clusterCommand()
4338 } else if (dictSize(server.cluster->nodes) > 1) { in clusterCommand()
4378 if (nodeIsMaster(myself) && dictSize(c->db->dict) != 0) { in clusterCommand()
4571 if (dictSize(server.migrate_cached_sockets) == MIGRATE_SOCKET_CACHE_ITEMS) { in migrateGetSocket()
H A Dt_set.c231 return dictSize((dict*)subject->ptr); in setTypeSize()
705 serverAssert(dictSize(d) == size); in srandmemberWithCountCommand()
H A Dt_zset.c1450 if (dictSize(zs->dict) == 0) { in zremCommand()
1552 if (dictSize(zs->dict) == 0) { in zremrangeGenericCommand()
1718 return dictSize(ht); in zuiLength()
2133 dictExpand(dstzset->dict,dictSize(accumulator)); in zunionInterGenericCommand()
H A Dt_hash.c290 length = dictSize((dict*)o->ptr); in hashTypeLength()
H A Dt_list.c656 serverAssertWithInfo(c,NULL,dictSize(c->bpop.keys) != 0); in unblockClientWaitingData()
H A Ddebug.c126 if (dictSize(db->dict) == 0) continue; in computeDatasetDigest()
H A Daof.c1043 if (dictSize(d) == 0) continue; in rewriteAppendOnlyFile()
H A Dnetworking.c1458 (int) dictSize(client->pubsub_channels), in catClientInfoString()
/redis-3.2.3/deps/hiredis/
H A Ddict.h111 #define dictSize(ht) ((ht)->used) macro