Home
last modified time | relevance | path

Searched refs:shard (Results 1 – 8 of 8) sorted by relevance

/rocksdb-6.9/db/
Dforward_iterator_bench.cc105 uint64_t shard; in run() local
109 shard = shards_pending_queue_.front(); in run()
111 shards_pending_set_.reset(shard); in run()
113 readOnceFromShard(shard); in run()
117 void readOnceFromShard(uint64_t shard) { in readOnceFromShard()
166 assert(key.shard() == shard); in readOnceFromShard()
174 void onWrite(uint64_t shard) { in onWrite()
178 shards_pending_queue_.push(shard); in onWrite()
179 shards_pending_set_.set(shard); in onWrite()
244 Key key(shard, seqno); in run()
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DBlockBasedTableConfigTest.java116 for (int shard = 0; shard < 8; shard++) { in blockCacheIntegration()
123 RocksDB.open(options, dbFolder.getRoot().getAbsolutePath() + "/" + shard)) { in blockCacheIntegration()
131 assertThat(statistics.getTickerCount(TickerType.BLOCK_CACHE_ADD)).isEqualTo(shard + 1); in blockCacheIntegration()
189 for (int shard = 0; shard < 8; shard++) { in blockCacheCompressedIntegration()
194 RocksDB.open(options, dbFolder.getRoot().getAbsolutePath() + "/" + shard)) { in blockCacheCompressedIntegration()
207 … assertThat(statistics.getTickerCount(TickerType.BLOCK_CACHE_COMPRESSED_ADD)).isEqualTo(shard + 1); in blockCacheCompressedIntegration()
/rocksdb-6.9/cache/
Dsharded_cache.h62 virtual CacheShard* GetShard(int shard) = 0;
63 virtual const CacheShard* GetShard(int shard) const = 0;
Dlru_cache.cc494 CacheShard* LRUCache::GetShard(int shard) { in GetShard() argument
495 return reinterpret_cast<CacheShard*>(&shards_[shard]); in GetShard()
498 const CacheShard* LRUCache::GetShard(int shard) const { in GetShard()
499 return reinterpret_cast<CacheShard*>(&shards_[shard]); in GetShard()
Dclock_cache.cc720 CacheShard* GetShard(int shard) override { in GetShard() argument
721 return reinterpret_cast<CacheShard*>(&shards_[shard]); in GetShard()
724 const CacheShard* GetShard(int shard) const override { in GetShard()
725 return reinterpret_cast<CacheShard*>(&shards_[shard]); in GetShard()
Dlru_cache.h322 virtual CacheShard* GetShard(int shard) override;
323 virtual const CacheShard* GetShard(int shard) const override;
/rocksdb-6.9/docs/_posts/
D2017-03-02-rocksdb-5-2-1-released.markdown9 * NewLRUCache() will determine number of shard bits automatically based on capacity, if the user do…
/rocksdb-6.9/
DHISTORY.md677 * NewLRUCache() will determine number of shard bits automatically based on capacity, if the user do…