Home
last modified time | relevance | path

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

12

/rocksdb-6.9/util/
Dautovector_test.cc164 for (auto pos = vec.rbegin(); pos != vec.rend(); ++pos) { in TEST_F() local
176 for (auto pos = cvec.rbegin(); pos != cvec.rend(); ++pos) { in TEST_F() local
181 auto pos = vec.begin(); in TEST_F() local
183 auto old_val = *pos; in TEST_F()
184 auto old = pos++; in TEST_F()
188 ASSERT_TRUE(pos == vec.end() || old_val != *pos); in TEST_F()
191 pos = vec.begin(); in TEST_F()
194 ASSERT_TRUE(pos + 2 - 2 == pos); in TEST_F()
195 pos += 2; in TEST_F()
251 for (auto pos = v.begin(); pos != end; ++pos) { in BenchmarkSequenceAccess() local
[all …]
/rocksdb-6.9/memtable/
Dskiplist_test.cc244 Key pos = RandomTarget(rnd); in ReadStep() local
246 iter.Seek(pos); in ReadStep()
259 while (pos < current) { in ReadStep()
260 ASSERT_LT(key(pos), K) << pos; in ReadStep()
267 << "key: " << key(pos) << "; gen: " << gen(pos) in ReadStep()
271 if (key(pos) < key(current)) { in ReadStep()
272 pos = MakeKey(key(pos) + 1, 0); in ReadStep()
274 pos = MakeKey(key(pos), gen(pos) + 1); in ReadStep()
284 pos = MakeKey(key(pos), gen(pos) + 1); in ReadStep()
287 if (new_target > pos) { in ReadStep()
[all …]
Dinlineskiplist_test.cc438 Key pos = RandomTarget(rnd); in ReadStep() local
440 iter.Seek(Encode(&pos)); in ReadStep()
453 while (pos < current) { in ReadStep()
454 ASSERT_LT(key(pos), K) << pos; in ReadStep()
461 << "key: " << key(pos) << "; gen: " << gen(pos) in ReadStep()
465 if (key(pos) < key(current)) { in ReadStep()
466 pos = MakeKey(key(pos) + 1, 0); in ReadStep()
468 pos = MakeKey(key(pos), gen(pos) + 1); in ReadStep()
478 pos = MakeKey(key(pos), gen(pos) + 1); in ReadStep()
481 if (new_target > pos) { in ReadStep()
[all …]
/rocksdb-6.9/utilities/simulator_cache/
Dsim_cache_test.cc179 std::string::size_type pos; in TEST_F() local
182 pos = 0; in TEST_F()
183 while ((pos = file_contents.find("LOOKUP -", pos)) != std::string::npos) { in TEST_F()
185 pos += 1; in TEST_F()
189 pos = 0; in TEST_F()
190 while ((pos = file_contents.find("ADD -", pos)) != std::string::npos) { in TEST_F()
192 pos += 1; in TEST_F()
/rocksdb-6.9/file/
Drandom_access_file_reader.cc94 size_t pos = 0; in Read() local
96 while (pos < n) { in Read()
102 allowed = rate_limiter_->RequestToken(n - pos, 0 /* alignment */, in Read()
121 s = file_->Read(offset + pos, allowed, IOOptions(), &tmp_result, in Read()
122 scratch + pos, nullptr); in Read()
127 NotifyOnFileReadFinish(offset + pos, tmp_result.size(), start_ts, in Read()
138 assert(tmp_result.data() == res_scratch + pos); in Read()
140 pos += tmp_result.size(); in Read()
145 *result = Slice(res_scratch, s.ok() ? pos : 0); in Read()
Dfilename.cc122 int pos = static_cast<int>(name.find_last_of('.')); in TableFileNameToNumber() local
123 while (--pos >= 0 && name[pos] >= '0' && name[pos] <= '9') { in TableFileNameToNumber()
124 number += (name[pos] - '0') * base; in TableFileNameToNumber()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_listener.h195 size_t pos = file_path.find_last_of("/"); in VerifyFilePath() local
196 if (pos == std::string::npos) { in VerifyFilePath()
199 if (pos > 0) { in VerifyFilePath()
200 VerifyFileDir(file_path.substr(0, pos)); in VerifyFilePath()
202 VerifyFileName(file_path.substr(pos)); in VerifyFilePath()
Ddb_stress_common.h328 size_t pos = 0; in SplitString() local
330 while ((pos_comma = src.find(',', pos)) != std::string::npos) { in SplitString()
331 ret.push_back(src.substr(pos, pos_comma - pos)); in SplitString()
332 pos = pos_comma + 1; in SplitString()
334 ret.push_back(src.substr(pos, src.length())); in SplitString()
/rocksdb-6.9/table/block_based/
Dblock_prefix_index.cc172 uint64_t pos = 0; in Create() local
188 if (pos + prefix_size > prefixes.size()) { in Create()
193 Slice prefix(prefixes.data() + pos, prefix_size); in Create()
196 pos += prefix_size; in Create()
199 if (s.ok() && pos != prefixes.size()) { in Create()
Dblock_based_table_factory.cc516 size_t pos = value.find(':', kName.size()); in ParseBlockBasedTableOption() local
517 if (pos == std::string::npos) { in ParseBlockBasedTableOption()
521 ParseDouble(trim(value.substr(kName.size(), pos - kName.size()))); in ParseBlockBasedTableOption()
523 ParseBoolean("use_block_based_builder", trim(value.substr(pos + 1))); in ParseBlockBasedTableOption()
/rocksdb-6.9/options/
Doptions_helper.cc862 size_t pos = 0; in StringToMap() local
869 std::string key = trim(opts.substr(pos, eq_pos - pos)); in StringToMap()
875 pos = eq_pos + 1; in StringToMap()
876 while (pos < opts.size() && isspace(opts[pos])) { in StringToMap()
877 ++pos; in StringToMap()
900 (*opts_map)[key] = trim(opts.substr(pos + 1, brace_pos - pos - 1)); in StringToMap()
904 while (pos < opts.size() && isspace(opts[pos])) { in StringToMap()
905 ++pos; in StringToMap()
907 if (pos < opts.size() && opts[pos] != ';') { in StringToMap()
911 ++pos; in StringToMap()
[all …]
/rocksdb-6.9/utilities/persistent_cache/
Dpersistent_cache_test.h101 int pos = static_cast<int>(pad_size) - 1; in PaddedNumber() local
107 ret[pos--] = '0' + t % 10; in PaddedNumber()
111 while (pos >= 0) { in PaddedNumber()
112 ret[pos--] = '0'; in PaddedNumber()
116 assert(pos == -1); in PaddedNumber()
Dblock_cache_tier.cc83 size_t pos = file.find("."); in IsCacheFile() local
84 if (pos == std::string::npos) { in IsCacheFile()
88 std::string suffix = file.substr(pos); in IsCacheFile()
/rocksdb-6.9/monitoring/
Dpersistent_stats_history.cc99 std::string::size_type pos = key_str.find("#"); in parseKey() local
101 if (pos == std::string::npos) { in parseKey()
105 uint64_t parsed_time = ParseUint64(key_str.substr(0, pos)); in parseKey()
112 std::string key_resize = key_str.substr(pos + 1); in parseKey()
Dhistogram.cc149 double pos = 0; in Percentile() local
152 pos = (threshold - left_sum) / right_left_diff; in Percentile()
154 double r = left_point + (right_point - left_point) * pos; in Percentile()
/rocksdb-6.9/db/
Dtable_properties_collector.cc19 auto pos = props.find(property_name); in GetUint64Property() local
20 if (pos == props.end()) { in GetUint64Property()
24 Slice raw = pos->second; in GetUint64Property()
Dcomparator_db_test.cc590 uint32_t pos = size2 - 1; in TEST_P() local
592 if (pos >= size1 || rnd.OneIn(4)) { in TEST_P()
594 s2[pos] = static_cast<char>(rnd.Uniform(256)); in TEST_P()
602 int s1_char = static_cast<int>(static_cast<unsigned char>(s1[pos])); in TEST_P()
610 s2[pos] = static_cast<char>(s2_char); in TEST_P()
612 } while (pos-- != 0); in TEST_P()
/rocksdb-6.9/utilities/
Denv_librados.cc76 int pos = fn.size() - 1; in split() local
77 while ('/' == fn[pos]) --pos; in split()
78 size_t fstart = fn.rfind('/', pos); in split()
79 *file = fn.substr(fstart + 1, pos - fstart); in split()
81 pos = fstart; in split()
82 while (pos >= 0 && '/' == fn[pos]) --pos; in split()
84 if (pos < 0) { in split()
87 size_t dstart = fn.rfind('/', pos); in split()
88 *dir = fn.substr(dstart + 1, pos - dstart); in split()
/rocksdb-6.9/java/benchmark/src/main/java/org/rocksdb/benchmark/
DDbBenchmark.java1564 int pos = 0; in RandomGenerator() local
1565 while (pos < dataLength_) { in RandomGenerator()
1567 System.arraycopy(value, 0, data_, pos, in RandomGenerator()
1568 Math.min(value.length, dataLength_ - pos)); in RandomGenerator()
1569 pos += value.length; in RandomGenerator()
1581 int pos; in compressibleBytes() local
1582 for (pos = 0; pos < baseLength; ++pos) { in compressibleBytes()
1585 while (pos < value.length) { in compressibleBytes()
1586 System.arraycopy(value, 0, value, pos, in compressibleBytes()
1587 Math.min(baseLength, value.length - pos)); in compressibleBytes()
[all …]
/rocksdb-6.9/hdfs/
Denv_hdfs.h223 size_t pos = s.find(delim); in split() local
224 while (pos != std::string::npos) { in split()
225 elems.push_back(s.substr(prev, pos)); in split()
226 prev = pos + 1; in split()
227 pos = s.find(delim, prev); in split()
/rocksdb-6.9/utilities/blob_db/
Dblob_db_impl.cc1644 int pos = snprintf(buf, sizeof(buf), in SanityCheck() local
1657 pos += snprintf(buf + pos, sizeof(buf) - pos, in SanityCheck()
1661 pos += snprintf(buf + pos, sizeof(buf) - pos, in SanityCheck()
1667 pos += snprintf(buf + pos, sizeof(buf) - pos, ", obsolete at %" PRIu64, in SanityCheck()
1670 snprintf(buf + pos, sizeof(buf) - pos, "."); in SanityCheck()
/rocksdb-6.9/utilities/ttl/
Dttl_test.cc322 size_t pos = key_string.find_first_of(search_str); in Filter() local
324 if (pos != std::string::npos) { in Filter()
325 auto key_substr = key_string.substr(pos, key.size() - pos); in Filter()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db_test.cc444 auto pos = metadata.find("private"); in CorruptChecksum() local
445 if (pos == std::string::npos) { in CorruptChecksum()
448 pos = metadata.find(" crc32 ", pos + 6); in CorruptChecksum()
449 if (pos == std::string::npos) { in CorruptChecksum()
453 if (metadata.size() < pos + 7) { in CorruptChecksum()
458 if (metadata[pos + 8] == '\n') { in CorruptChecksum()
460 metadata.insert(pos + 8, 1, '0'); in CorruptChecksum()
462 metadata.erase(pos + 8, 1); in CorruptChecksum()
465 metadata[pos + 7] = 'a'; in CorruptChecksum()
/rocksdb-6.9/table/plain/
Dplain_table_reader.cc224 uint32_t pos = data_start_offset_; in PopulateIndexRecordList() local
230 while (pos < file_info_.data_end_offset) { in PopulateIndexRecordList()
231 uint32_t key_offset = pos; in PopulateIndexRecordList()
235 Status s = Next(&decoder, &pos, &key, nullptr, &value_slice, &seekable); in PopulateIndexRecordList()
/rocksdb-6.9/tools/
Ddb_bench_tool.cc2576 const char* pos = key.data(); in KeyExpired() local
2577 pos += 8; in KeyExpired()
2762 char* pos = start; in GenerateKeyFromInt() local
2776 memset(pos + 8, '0', prefix_size_ - 8); in GenerateKeyFromInt()
2778 pos += prefix_size_; in GenerateKeyFromInt()
2789 pos += bytes_to_fill; in GenerateKeyFromInt()
2790 if (key_size_ > pos - start) { in GenerateKeyFromInt()
2791 memset(pos, '0', key_size_ - (pos - start)); in GenerateKeyFromInt()
5255 if (pos < type_[i]) { in GetType()
5361 pos >= 0 && pos < static_cast<int64_t>(keyrange_set_.size())); in InitiateExpDistribution()
[all …]

12