Home
last modified time | relevance | path

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

12

/rocksdb-6.9/db/
Dcuckoo_table_db_test.cc243 for (int idx = 0; idx < 28; ++idx) { in TEST_F() local
244 ASSERT_OK(Put(Key(idx), std::string(10000, 'a' + char(idx)))); in TEST_F()
252 for (int idx = 0; idx < 28; ++idx) { in TEST_F() local
253 ASSERT_EQ(std::string(10000, 'a' + char(idx)), Get(Key(idx))); in TEST_F()
266 for (int idx = 0; idx < 11; ++idx) { in TEST_F() local
267 ASSERT_OK(Put(Key(idx), std::string(10000, 'a'))); in TEST_F()
273 for (int idx = 0; idx < 11; ++idx) { in TEST_F() local
274 ASSERT_OK(Put(Key(idx), std::string(10000, 'a' + char(idx)))); in TEST_F()
280 for (int idx = 0; idx < 11; ++idx) { in TEST_F() local
281 ASSERT_EQ(std::string(10000, 'a' + char(idx)), Get(Key(idx))); in TEST_F()
Dcompacted_db_impl.cc66 int idx = 0; in MultiGet() local
70 std::string& value = (*values)[idx]; in MultiGet()
72 GetContext::kNotFound, keys[idx], &pinnable_val, in MultiGet()
74 LookupKey lkey(keys[idx], kMaxSequenceNumber); in MultiGet()
78 statuses[idx] = Status::OK(); in MultiGet()
81 ++idx; in MultiGet()
Dlistener_test.cc705 int idx; in Index() local
708 idx = 0; in Index()
711 idx = 1; in Index()
714 idx = -1; in Index()
716 return idx; in Index()
736 if (idx >= 0) { in OnTableFileCreationStarted()
737 started_[idx]++; in OnTableFileCreationStarted()
747 if (idx >= 0) { in OnTableFileCreated()
748 finished_[idx]++; in OnTableFileCreated()
761 if (idx >= 0) { in OnTableFileCreated()
[all …]
Ddb_iter_stress_test.cc133 size_t idx = rnd->Next() % data->entries.size(); in MaybeMutate() local
134 Entry& e = data->entries[idx]; in MaybeMutate()
137 std::cout << "hiding idx " << idx << std::endl; in MaybeMutate()
140 data->hidden.push_back(idx); in MaybeMutate()
151 size_t idx = data->hidden[hi]; in MaybeMutate() local
153 std::cout << "unhiding idx " << idx << std::endl; in MaybeMutate()
155 Entry& e = data->entries[idx]; in MaybeMutate()
Drange_tombstone_fragmenter.h53 std::vector<SequenceNumber>::const_iterator seq_iter(size_t idx) const { in seq_iter()
54 return std::next(tombstone_seqs_.begin(), idx); in seq_iter()
Dfault_injection_test.cc355 for (size_t idx = 0; idx < kNumIterations; idx++) { in TEST_P() local
Dversion_set.h207 int CompactionScoreLevel(int idx) const { return compaction_level_[idx]; } in CompactionScoreLevel() argument
210 double CompactionScore(int idx) const { return compaction_score_[idx]; } in CompactionScore() argument
/rocksdb-6.9/util/
Dcompression_context_cache.cc41 ZSTDUncompressCachedData GetUncompressData(int64_t idx) { in GetUncompressData()
47 result.InitFromCache(uncomp_cached_data_, idx); in GetUncompressData()
75 int64_t idx = static_cast<int64_t>(p.second); in GetZSTDUncompressData() local
76 return p.first->GetUncompressData(idx); in GetZSTDUncompressData()
78 void ReturnZSTDUncompressData(int64_t idx) { in ReturnZSTDUncompressData() argument
79 assert(idx >= 0); in ReturnZSTDUncompressData()
80 auto* cn = per_core_uncompr_.AccessAtCore(static_cast<size_t>(idx)); in ReturnZSTDUncompressData()
102 void CompressionContextCache::ReturnCachedZSTDUncompressData(int64_t idx) { in ReturnCachedZSTDUncompressData() argument
103 rep_->ReturnZSTDUncompressData(idx); in ReturnCachedZSTDUncompressData()
Dcompression_context_cache.h36 void ReturnCachedZSTDUncompressData(int64_t idx);
/rocksdb-6.9/java/jmh/src/main/java/org/rocksdb/jmh/
DGetBenchmarks.java105 int idx = cfHandlesIdx.getAndIncrement(); in getColumnFamily() local
106 if (idx > cfs) { in getColumnFamily()
108 idx = 0; in getColumnFamily()
110 return cfHandles[idx]; in getColumnFamily()
118 int idx; in next() local
121 idx = keyIndex.get(); in next()
122 nextIdx = idx + 1; in next()
127 if (keyIndex.compareAndSet(idx, nextIdx)) { in next()
131 return idx; in next()
DMultiGetBenchmarks.java114 int idx = cfHandlesIdx.getAndIncrement(); in getColumnFamily() local
115 if (idx > cfs) { in getColumnFamily()
117 idx = 0; in getColumnFamily()
119 return cfHandles[idx]; in getColumnFamily()
131 int idx; in next() local
134 idx = keyIndex.get(); in next()
135 nextIdx = idx + inc; in next()
140 if (keyIndex.compareAndSet(idx, nextIdx)) { in next()
148 return idx; in next()
DPutBenchmarks.java89 int idx = cfHandlesIdx.getAndIncrement(); in getColumnFamily() local
90 if (idx > cfs) { in getColumnFamily()
92 idx = 0; in getColumnFamily()
94 return cfHandles[idx]; in getColumnFamily()
DComparatorBenchmarks.java82 final int idx = comparatorName.indexOf("_reused-"); in setup() local
83 String s = comparatorName.substring(idx + 8); in setup()
/rocksdb-6.9/java/src/main/java/org/rocksdb/util/
DByteUtil.java37 for (int idx = 0; idx < count; idx++) { in memcmp()
38 final int aa = x.get(idx) & 0xff; in memcmp()
39 final int bb = y.get(idx) & 0xff; in memcmp()
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_builder.cc159 bool CuckooTableBuilder::IsDeletedKey(uint64_t idx) const { in IsDeletedKey()
161 return idx >= num_values_; in IsDeletedKey()
164 Slice CuckooTableBuilder::GetKey(uint64_t idx) const { in GetKey()
166 if (IsDeletedKey(idx)) { in GetKey()
167 …return Slice(&deleted_keys_[static_cast<size_t>((idx - num_values_) * key_size_)], static_cast<siz… in GetKey()
169 …return Slice(&kvs_[static_cast<size_t>(idx * (key_size_ + value_size_))], static_cast<size_t>(key_… in GetKey()
172 Slice CuckooTableBuilder::GetUserKey(uint64_t idx) const { in GetUserKey()
174 return is_last_level_file_ ? GetKey(idx) : ExtractUserKey(GetKey(idx)); in GetUserKey()
177 Slice CuckooTableBuilder::GetValue(uint64_t idx) const { in GetValue()
179 if (IsDeletedKey(idx)) { in GetValue()
[all …]
Dcuckoo_table_builder.h95 inline bool IsDeletedKey(uint64_t idx) const;
96 inline Slice GetKey(uint64_t idx) const;
97 inline Slice GetUserKey(uint64_t idx) const;
98 inline Slice GetValue(uint64_t idx) const;
/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DJNIComparatorTest.java126 int idx = 0; in readAllWithJavaComparator() local
132 keys[idx++] = thisKey; in readAllWithJavaComparator()
157 int idx = 0; in readAllWithCppComparator() local
163 keys[idx++] = thisKey; in readAllWithCppComparator()
/rocksdb-6.9/utilities/transactions/
Doptimistic_transaction_db_impl.cc33 size_t idx) { in LockBucket() argument
34 assert(idx < bucketed_locks_.size()); in LockBucket()
35 return std::unique_lock<std::mutex>(*bucketed_locks_[idx]); in LockBucket()
Doptimistic_transaction_db_impl.h53 std::unique_lock<std::mutex> LockBucket(size_t idx);
/rocksdb-6.9/utilities/persistent_cache/
Dhash_table_evictable.h87 const size_t idx = (start_idx + i) % hash_table::nlocks_; variable
89 WriteLock _(&hash_table::locks_[idx]);
90 LRUListType& lru = lru_lists_[idx];
/rocksdb-6.9/table/block_based/
Ddata_block_hash_index.cc88 uint16_t idx = static_cast<uint16_t>(hash_value % num_buckets_); in Lookup() local
90 return static_cast<uint8_t>(*(bucket_table + idx * sizeof(uint8_t))); in Lookup()
/rocksdb-6.9/file/
Ddelete_scheduler.cc152 size_t idx = file_path.rfind("/"); in MarkAsTrash() local
153 if (idx == std::string::npos || idx == file_path.size() - 1) { in MarkAsTrash()
/rocksdb-6.9/java/rocksjni/
Dttl.cc81 [&jco, &column_families](size_t idx, std::string cf_name) { in Java_org_rocksdb_TtlDB_openCF() argument
83 reinterpret_cast<ROCKSDB_NAMESPACE::ColumnFamilyOptions*>(jco[idx]); in Java_org_rocksdb_TtlDB_openCF()
/rocksdb-6.9/table/
Dmultiget_context.h156 Iterator(const Range* range, size_t idx) in Iterator() argument
157 : range_(range), ctx_(range->ctx_), index_(idx) { in Iterator()
/rocksdb-6.9/db_stress_tool/
Dcf_consistency_stress.cc382 size_t idx = 0; in VerifyDb() local
387 statuses[idx] = iter->status(); in VerifyDb()
389 ++idx; in VerifyDb()

12