| /rocksdb-6.9/table/block_based/ |
| D | filter_policy.cc | 170 uint32_t byte_offset; in MayMatch()
217 uint32_t dont_care1; in CalculateSpace()
218 uint32_t dont_care2; in CalculateSpace()
234 uint32_t GetTotalBitsForLocality(uint32_t total_bits);
241 uint32_t CalculateSpace(const int num_entry, uint32_t* total_bits,
245 void AddHash(uint32_t h, char* data, uint32_t num_lines, uint32_t total_bits);
313 uint32_t num_lines = in GetTotalBitsForLocality()
492 uint32_t bits = static_cast<uint32_t>(n * whole_bits_per_key_); in CreateFilter()
522 const uint32_t bits = static_cast<uint32_t>(len - 1) * 8; in KeyMayMatch()
607 uint32_t len_with_meta = static_cast<uint32_t>(contents.size()); in GetFilterBitsReader()
[all …]
|
| D | block_prefix_index.cc | 23 inline uint32_t PrefixToBucket(const Slice& prefix, uint32_t num_buckets) { in PrefixToBucket()
50 inline uint32_t DecodeIndex(uint32_t block_id) { in DecodeIndex()
56 inline uint32_t EncodeIndex(uint32_t index) { in EncodeIndex()
64 uint32_t start_block;
65 uint32_t end_block;
66 uint32_t num_blocks;
75 void Add(const Slice& key_prefix, uint32_t start_block, uint32_t num_blocks) { in Add()
87 uint32_t num_buckets = static_cast<uint32_t>(prefixes_.size()) + 1; in Finish()
123 uint32_t* block_array_buffer = new uint32_t[total_block_array_entries]; in Finish()
124 uint32_t* buckets = new uint32_t[num_buckets]; in Finish()
[all …]
|
| D | block.h | 76 void Mark(uint32_t start_offset, uint32_t end_offset) { in Mark()
79 uint32_t start_bit = in Mark()
123 const uint32_t kBytesPersEntry = sizeof(uint32_t); // 4 bytes
136 uint32_t rnd_;
235 uint32_t restarts, uint32_t num_restarts, in InitializeBase()
312 uint32_t current_;
338 uint32_t GetRestartPoint(uint32_t index) { in GetRestartPoint()
376 uint32_t restarts, uint32_t num_restarts, in Initialize()
455 uint32_t offset;
496 uint32_t restarts, uint32_t num_restarts, in Initialize()
[all …]
|
| D | block.cc | 39 uint32_t* shared, uint32_t* non_shared, in operator ()()
70 uint32_t* shared, uint32_t* non_shared, in operator ()()
101 uint32_t* shared, uint32_t* non_shared) { in operator ()()
112 uint32_t* shared, uint32_t* non_shared) { in operator ()()
245 uint32_t index = 0; in Seek()
284 uint32_t map_offset = restarts_ + num_restarts_ * sizeof(uint32_t); in SeekForGetImpl()
388 uint32_t index = 0; in Seek()
424 uint32_t index = 0; in SeekForPrev()
667 uint32_t right, uint32_t* index, in BinarySeek()
723 uint32_t right, uint32_t* index, in BinaryBlockIndexSeek()
[all …]
|
| D | block_builder.cc | 68 estimate_ = sizeof(uint32_t) + sizeof(uint32_t); in BlockBuilder()
75 estimate_ = sizeof(uint32_t) + sizeof(uint32_t); in Reset()
98 estimate += sizeof(uint32_t); // a new restart entry. in EstimateSizeAfterKV()
118 uint32_t num_restarts = static_cast<uint32_t>(restarts_.size()); in Finish()
143 restarts_.push_back(static_cast<uint32_t>(buffer_.size())); in Add()
144 estimate_ += sizeof(uint32_t); in Add()
167 PutVarint32Varint32(&buffer_, static_cast<uint32_t>(shared), in Add()
168 static_cast<uint32_t>(non_shared)); in Add()
171 PutVarint32Varint32Varint32(&buffer_, static_cast<uint32_t>(shared), in Add()
172 static_cast<uint32_t>(non_shared), in Add()
[all …]
|
| D | block_prefix_index.h | 26 uint32_t GetBlocks(const Slice& key, uint32_t** blocks);
30 (num_block_array_buffer_entries_ + num_buckets_) * sizeof(uint32_t); in ApproximateMemoryUsage()
50 uint32_t num_buckets, uint32_t* buckets, in BlockPrefixIndex()
51 uint32_t num_block_array_buffer_entries, in BlockPrefixIndex()
52 uint32_t* block_array_buffer) in BlockPrefixIndex()
60 uint32_t num_buckets_;
61 uint32_t num_block_array_buffer_entries_;
62 uint32_t* buckets_;
63 uint32_t* block_array_buffer_;
|
| /rocksdb-6.9/table/plain/ |
| D | plain_table_key_coding.h | 56 uint32_t fixed_user_key_len_;
90 bool Read(uint32_t file_offset, uint32_t len, Slice* out) { in Read()
101 bool ReadNonMmap(uint32_t file_offset, uint32_t len, Slice* output);
106 inline bool ReadVarint32(uint32_t offset, uint32_t* output,
109 bool ReadVarint32NonMmap(uint32_t offset, uint32_t* output,
123 uint32_t buf_len;
124 uint32_t buf_capacity;
129 uint32_t num_buf_;
132 Slice GetFromBuffer(Buffer* buf, uint32_t file_offset, uint32_t len);
168 uint32_t prefix_len_;
[all …]
|
| D | plain_table_index.h | 116 uint32_t index_size_;
117 uint32_t sub_index_size_;
118 uint32_t num_prefixes_;
120 uint32_t* index_;
157 uint32_t GetTotalSize() const { in GetTotalSize()
185 void AddRecord(uint32_t hash, uint32_t offset);
230 uint32_t num_prefixes_;
231 uint32_t num_keys_per_prefix_;
233 uint32_t prev_key_prefix_hash_;
235 uint32_t index_size_;
[all …]
|
| D | plain_table_key_coding.cc | 69 uint32_t extra_size; in DecodeSize()
70 uint32_t tmp_bytes_read; in DecodeSize()
94 uint32_t user_key_size = static_cast<uint32_t>(key.size() - 8); in AppendKey()
134 uint32_t prefix_len = in AppendKey()
178 bool PlainTableFileReader::ReadNonMmap(uint32_t file_offset, uint32_t len, in ReadNonMmap()
225 inline bool PlainTableFileReader::ReadVarint32(uint32_t offset, uint32_t* out, in ReadVarint32()
240 bool PlainTableFileReader::ReadVarint32NonMmap(uint32_t offset, uint32_t* out, in ReadVarint32NonMmap()
261 uint32_t file_offset, uint32_t user_key_size, ParsedInternalKey* parsed_key, in ReadInternalKey()
301 uint32_t tmp_read; in NextPlainEncodingKey()
347 uint32_t size = 0; in NextPrefixEncodingKey()
[all …]
|
| D | plain_table_bloom.h | 39 explicit PlainTableBloomV1(uint32_t num_probes = 6);
47 void AddHash(uint32_t hash);
50 bool MayContainHash(uint32_t hash) const;
52 void Prefetch(uint32_t hash);
58 void SetRawData(char* raw_data, uint32_t total_bits, uint32_t num_blocks = 0);
65 uint32_t kTotalBits;
66 uint32_t kNumBlocks;
67 const uint32_t kNumProbes;
80 inline void PlainTableBloomV1::Prefetch(uint32_t h) { in Prefetch()
82 uint32_t ignored; in Prefetch()
[all …]
|
| D | plain_table_index.cc | 17 inline uint32_t GetBucketIdFromHash(uint32_t hash, uint32_t num_buckets) { in GetBucketIdFromHash()
35 index_ = reinterpret_cast<uint32_t*>(index_data_begin); in InitFromRawData()
41 uint32_t prefix_hash, uint32_t* bucket_value) const { in GetOffset()
123 std::vector<uint32_t>* entries_per_bucket) { in BucketizeIndexes()
125 uint32_t prev_hash = 0; in BucketizeIndexes()
129 uint32_t cur_hash = index_record->hash; in BucketizeIndexes()
155 const std::vector<uint32_t>& entries_per_bucket) { in FillIndexes()
164 uint32_t* index = in FillIndexes()
168 uint32_t sub_index_offset = 0; in FillIndexes()
169 for (uint32_t i = 0; i < index_size_; i++) { in FillIndexes()
[all …]
|
| D | plain_table_reader.cc | 87 uint32_t offset_;
88 uint32_t next_offset_;
370 uint32_t num_blocks = 0; in PopulateIndex()
449 uint32_t upper_bound; in GetOffset()
452 uint32_t low = 0; in GetOffset()
464 uint32_t tmp; in GetOffset()
488 uint32_t tmp; in GetOffset()
537 uint32_t bytes_read; in Next()
560 uint32_t prefix_hash; in Get()
581 uint32_t offset; in Get()
[all …]
|
| /rocksdb-6.9/util/ |
| D | bloom_impl.h | 194 static inline void AddHash(uint32_t h1, uint32_t h2, uint32_t len_bytes, in AddHash()
202 uint32_t h = h2; in AddHashPrepared()
210 static inline void PrepareHash(uint32_t h1, uint32_t len_bytes, in PrepareHash()
219 static inline bool HashMayMatch(uint32_t h1, uint32_t h2, uint32_t len_bytes, in HashMayMatch()
227 uint32_t h = h2; in HashMayMatchPrepared()
358 static inline void AddHash(uint32_t h, uint32_t total_bits, int num_probes, in AddHash()
368 static inline bool HashMayMatch(uint32_t h, uint32_t total_bits, in HashMayMatch()
400 static inline uint32_t GetLine(uint32_t h, uint32_t num_lines) { in GetLine()
426 static inline void AddHash(uint32_t h, uint32_t num_lines, int num_probes, in AddHash()
444 static inline void PrepareHashMayMatch(uint32_t h, uint32_t num_lines, in PrepareHashMayMatch()
[all …]
|
| D | random.h | 23 enum : uint32_t {
30 uint32_t seed_;
32 static uint32_t GoodSeed(uint32_t s) { return (s & M) != 0 ? (s & M) : 1; } in GoodSeed()
36 enum : uint32_t { kMaxNext = M };
42 uint32_t Next() { in Next()
84 uint32_t Skewed(int max_log) { in Skewed()
104 uint32_t Next() { return static_cast<uint32_t>(generator_()); } in Next()
108 uint32_t Uniform(uint32_t n) { in Uniform()
109 return static_cast<uint32_t>( in Uniform()
117 uint32_t Uniformish(uint32_t n) { in Uniformish()
[all …]
|
| D | coding.h | 40 uint32_t value2);
42 uint32_t value2, uint32_t value3);
123 inline uint32_t DecodeFixed32(const char* ptr) { in DecodeFixed32()
126 uint32_t result; in DecodeFixed32()
243 inline void PutVarint32Varint32(std::string* dst, uint32_t v1, uint32_t v2) { in PutVarint32Varint32()
251 uint32_t v2, uint32_t v3) { in PutVarint32Varint32Varint32()
352 if (input->size() < sizeof(uint32_t)) { in GetFixed32()
356 input->remove_prefix(sizeof(uint32_t)); in GetFixed32()
417 uint32_t len = 0; in GetLengthPrefixedSlice()
428 uint32_t len = 0; in GetLengthPrefixedSlice()
[all …]
|
| D | filter_bench.cc | 153 Slice Get(uint32_t filter_num, uint32_t val_num) { in Get()
188 uint32_t filter_id_ = 0;
191 uint32_t keys_added_ = 0;
243 uint32_t sz = static_cast<uint32_t>(s.size()); in DryRunNoHash()
315 const uint32_t variance_range = in Go()
432 uint32_t outside_q_per_f = in Go()
448 uint32_t hash = in Go()
530 uint32_t num_infos = static_cast<uint32_t>(infos_.size()); in RandomQueryTest()
531 uint32_t dry_run_hash = 0; in RandomQueryTest()
555 uint32_t batch_size = 1; in RandomQueryTest()
[all …]
|
| D | hash.h | 38 inline uint64_t NPHash64(const char* data, size_t n, uint32_t seed) { in NPHash64()
52 extern uint32_t Hash(const char* data, size_t n, uint32_t seed);
55 inline uint32_t BloomHash(const Slice& key) { in BloomHash()
68 inline uint32_t GetSliceHash(const Slice& s) { in GetSliceHash()
73 inline uint32_t Upper32of64(uint64_t v) { in Upper32of64()
74 return static_cast<uint32_t>(v >> 32); in Upper32of64()
76 inline uint32_t Lower32of64(uint64_t v) { return static_cast<uint32_t>(v); } in Lower32of64()
81 uint32_t operator()(const Slice& s) const { return GetSliceHash(s); } in operator()
86 inline uint32_t fastrange32(uint32_t hash, uint32_t range) { in fastrange32()
88 return static_cast<uint32_t>(product >> 32); in fastrange32()
[all …]
|
| D | thread_local.cc | 57 uint32_t GetId();
59 uint32_t PeekId() const;
62 void ReclaimId(uint32_t id);
65 void* Get(uint32_t id) const;
67 void Reset(uint32_t id, void* ptr);
69 void* Swap(uint32_t id, void* ptr);
113 UnrefHandler GetHandler(uint32_t id);
128 uint32_t next_instance_id_;
131 autovector<uint32_t> free_instance_ids_;
293 uint32_t id = 0; in OnThreadExit()
[all …]
|
| D | dynamic_bloom.h | 60 void AddHash(uint32_t hash);
63 void AddHashConcurrently(uint32_t hash);
71 bool MayContainHash(uint32_t hash) const;
73 void Prefetch(uint32_t h);
78 uint32_t kLen;
81 const uint32_t kNumDoubleProbes;
88 void AddHash(uint32_t hash, const OrFunc& or_func);
90 bool DoubleProbe(uint32_t h32, size_t a) const;
99 inline void DynamicBloom::AddHash(uint32_t hash) { in AddHash()
106 inline void DynamicBloom::AddHashConcurrently(uint32_t hash) { in AddHashConcurrently()
[all …]
|
| /rocksdb-6.9/tools/ |
| D | trace_analyzer_tool.h | 40 uint32_t type;
41 uint32_t cf_id;
56 uint32_t cf_id;
81 uint32_t cf_id;
98 std::map<uint32_t, uint32_t> a_qps_stats;
99 std::map<uint32_t, std::map<std::string, uint32_t>> a_qps_prefix_stats;
112 std::priority_queue<std::pair<uint32_t, uint32_t>,
113 std::vector<std::pair<uint32_t, uint32_t>>,
114 std::greater<std::pair<uint32_t, uint32_t>>>
157 uint32_t cf_id;
[all …]
|
| /rocksdb-6.9/monitoring/ |
| D | statistics.h | 33 enum TickersInternal : uint32_t {
38 enum HistogramsInternal : uint32_t {
48 virtual uint64_t getTickerCount(uint32_t ticker_type) const override;
49 virtual void histogramData(uint32_t histogram_type,
60 void measureTime(uint32_t histogramType, uint64_t time) override { in measureTime()
63 virtual void recordInHistogram(uint32_t histogram_type,
69 virtual bool HistEnabledForType(uint32_t type) const override;
103 uint64_t getTickerCountLocked(uint32_t ticker_type) const;
105 uint32_t histogram_type) const;
106 void setTickerCountLocked(uint32_t ticker_type, uint64_t count);
[all …]
|
| /rocksdb-6.9/table/cuckoo/ |
| D | cuckoo_table_builder.h | 26 uint32_t max_num_hash_func, uint32_t max_search_depth,
32 uint32_t column_family_id,
83 uint32_t vector_idx;
86 uint32_t make_space_for_key_call_id;
88 static const uint32_t kMaxVectorIdx = port::kMaxInt32;
91 const uint32_t call_id,
100 uint32_t num_hash_func_;
103 const uint32_t max_num_hash_func_;
104 const uint32_t max_search_depth_;
105 const uint32_t cuckoo_block_size_;
[all …]
|
| D | cuckoo_table_reader.cc | 30 const uint32_t kInvalidIndex = std::numeric_limits<uint32_t>::max();
86 user_key_length_ = *reinterpret_cast<const uint32_t*>( in CuckooTableReader()
94 value_length_ = *reinterpret_cast<const uint32_t*>( in CuckooTableReader()
137 cuckoo_block_size_ = *reinterpret_cast<const uint32_t*>( in CuckooTableReader()
221 uint32_t bucket_len, uint32_t user_key_len, in BucketComparator()
228 bool operator()(const uint32_t first, const uint32_t second) const { in operator ()()
241 const uint32_t bucket_len_;
242 const uint32_t user_key_len_;
251 std::vector<uint32_t> sorted_bucket_ids_;
253 uint32_t curr_key_idx_;
[all …]
|
| /rocksdb-6.9/utilities/transactions/ |
| D | transaction_lock_mgr.h | 33 uint32_t buffer_idx_;
38 explicit DeadlockInfoBuffer(uint32_t n_latest_dlocks) in DeadlockInfoBuffer()
41 void Resize(uint32_t target_size);
47 uint32_t m_cf_id;
58 int64_t max_num_locks, uint32_t max_num_deadlocks,
68 void AddColumnFamily(uint32_t column_family_id);
72 void RemoveColumnFamily(uint32_t column_family_id);
76 Status TryLock(PessimisticTransaction* txn, uint32_t column_family_id,
83 void UnLock(PessimisticTransaction* txn, uint32_t column_family_id,
89 void Resize(uint32_t);
[all …]
|
| /rocksdb-6.9/third-party/folly/folly/detail/ |
| D | Futex-inl.h | 48 uint32_t wakeMask);
51 uint32_t expected,
54 uint32_t waitMask);
59 uint32_t wakeMask);
62 uint32_t expected,
65 uint32_t waitMask);
71 uint32_t expected, in futexWaitImpl()
73 uint32_t waitMask) { in futexWaitImpl()
81 uint32_t expected, in futexWaitImpl()
89 futexWait(const Futex* futex, uint32_t expected, uint32_t waitMask) { in futexWait()
[all …]
|