Home
last modified time | relevance | path

Searched refs:j (Results 1 – 25 of 81) sorted by relevance

1234

/rocksdb-6.9/db/
Drepair_test.cc240 for (int j = 0; j < kEntriesPerCf; ++j) { in TEST_F() local
241 Put(i, "key" + ToString(j), "val" + ToString(j)); in TEST_F()
242 if (j == kEntriesPerCf - 1 && i == kNumCfs - 1) { in TEST_F()
264 for (int j = 0; j < kEntriesPerCf; ++j) { in TEST_F() local
265 ASSERT_EQ(Get(i, "key" + ToString(j)), "val" + ToString(j)); in TEST_F()
285 for (int j = 0; j < kEntriesPerCf; ++j) { in TEST_F() local
286 Put(i, "key" + ToString(j), "val" + ToString(j)); in TEST_F()
303 for (int j = 0; j < kEntriesPerCf; ++j) { in TEST_F() local
304 ASSERT_EQ(Get(i, "key" + ToString(j)), "val" + ToString(j)); in TEST_F()
328 for (int j = 0; j < kEntriesPerCf; ++j) { in TEST_F() local
[all …]
Ddb_range_del_test.cc111 for (int j = 0; j < kNumPerFile; j++) { in TEST_F() local
159 for (int j = 0; j < kNumPerFile; j++) { in TEST_F() local
312 for (int j = 0; j < kNumPerFile; ++j) { in TEST_F() local
325 for (int j = 0; j < kNumPerFile; ++j) { in TEST_F() local
356 for (int j = 0; j < kNumFiles; ++j) { in TEST_F() local
415 for (int j = 0; j < kFilesPerLevel; ++j) { in TEST_F() local
979 for (int j = 0; j < kNumFilesPerLevel; ++j) { in TEST_F() local
1052 for (int j = 0; j < kNumFilesPerLevel; ++j) { in TEST_F() local
1185 for (int j = 0; j < kFileBytes / kValueBytes; ++j) { in TEST_F() local
1584 for (int j = 0; j < kNumPerFile; j++) { in TEST_F() local
[all …]
Ddb_with_timestamp_basic_test.cc478 for (size_t j = 0; j != (kNumKeysPerFile - 1) / kNumTimestamps; ++j) { in TEST_P() local
492 for (size_t j = 0; j != (kNumKeysPerFile - 1) / kNumTimestamps; ++j) { in TEST_P() local
594 for (size_t j = begin; j <= end; ++j) { in TEST_P() local
609 for (size_t j = 0; j != kNumKeysPerTimestamp; ++j) { in TEST_P() local
613 if (j == kSplitPosBase + i || j == kNumKeysPerTimestamp - 1) { in TEST_P()
682 for (size_t j = 0; j != kNumKeysPerTimestamp; ++j) { in TEST_F() local
685 for (size_t j = 0; j != kNumKeysPerTimestamp; ++j) { in TEST_F() local
698 for (size_t j = 0; j != kNumKeysPerTimestamp; ++j) { in TEST_F() local
701 values[j]); in TEST_F()
713 for (size_t j = 0; j != kNumKeysPerTimestamp; ++j) { in TEST_F() local
[all …]
Ddb_compaction_test.cc1547 for (int32_t j = 300; j < 4300; j++) { in TEST_F() local
1743 for (auto j = 0; j < 100; j++) { in TEST_F() local
1759 for (auto j = 0; j < 100; j++) { in TEST_F() local
2827 for (int j = 0; j < 100; ++j) { in TEST_P() local
2862 for (int j = 0; j < 100; ++j) { in TEST_P() local
4314 for (int j = 0; j < 2; ++j) { in TEST_F() local
4407 for (int j = 0; j < 5000; j++) { in TEST_F() local
4809 for (auto j = 0; j < 10; ++j) { in TEST_F() local
4889 for (auto j = 0; j < 10; ++j) { in TEST_F() local
4899 for (auto j = 0; j < 10; ++j) { in TEST_F() local
[all …]
Ddb_test2.cc752 for (size_t j = 0; j < batch_keys[i].size(); j++) { in TEST_F() local
777 for (size_t j = 0; j < batch_keys[i].size(); j++) { in TEST_F() local
840 for (size_t j = 0; j < batch_keys[i].size(); j++) { in TEST_F() local
1122 for (int j = 0; j < 10; ++j) { in TEST_F() local
1128 for (int j = 0; j < kNumL0Files; ++j) { in TEST_F() local
1197 for (int j = 0; j < kNumEntriesPerFile; ++j) { in TEST_F() local
1318 for (int j = 0; j < 5; j++) { in TEST_F() local
1377 for (int j = 0; j < 10; j++) { in TEST_F() local
1392 for (int j = 0; j < 10; j++) { in TEST_F() local
2497 for (int j = 0; j < 100; j++) { in TEST_F() local
[all …]
Derror_handler_fs_test.cc895 for (auto j = 0; j < 100; ++j) { in TEST_F() local
938 for (auto j = 0; j < 199; ++j) { in TEST_F() local
939 if (j < 100) { in TEST_F()
940 ASSERT_NE(Get(i, Key(j)), "NOT_FOUND"); in TEST_F()
942 ASSERT_EQ(Get(i, Key(j)), "NOT_FOUND"); in TEST_F()
948 for (auto j = 0; j < 199; ++j) { in TEST_F() local
949 if (j < 100) { in TEST_F()
999 for (auto j = 0; j <= 100; ++j) { in TEST_F() local
1014 for (auto j = 100; j < 199; ++j) { in TEST_F() local
1112 for (auto j = 0; j <= 100; ++j) { in TEST_F() local
[all …]
Drange_del_aggregator_bench.cc200 for (int j = 0; j < FLAGS_num_range_tombstones; j++) { in main() local
204 persistent_range_tombstones[j] = in main()
206 ROCKSDB_NAMESPACE::Key(start), ROCKSDB_NAMESPACE::Key(end), j); in main()
235 for (int j = 0; j < FLAGS_should_deletes_per_run; j++) { in main() local
236 std::string key_string = ROCKSDB_NAMESPACE::Key(first_key + j); in main()
244 if (j == 0) { in main()
Ddb_basic_test.cc880 for (int j = 0; j < kNumPerFile; ++j) { in TEST_F() local
892 for (int j = 0; j < (max_checksum + 1) * kNumPerFile; ++j) { in TEST_F() local
893 ASSERT_EQ(Key(j), Get(Key(j))); in TEST_F()
1095 for (unsigned int j = 0; j < values.size(); ++j) { in TEST_P() local
1096 ASSERT_EQ(values[j], std::get<2>(cf_kv_vec[j]) + "_2"); in TEST_P()
1183 for (unsigned int j = 0; j < values.size(); ++j) { in TEST_P() local
1243 for (unsigned int j = 0; j < values.size(); ++j) { in TEST_P() local
1244 ASSERT_EQ(values[j], "cf" + std::to_string(j) + "_val"); in TEST_P()
1400 for (unsigned int j = 0; j < values.size(); ++j) { in TEST_F() local
1480 for (unsigned int j = 0; j < 48; ++j) { in TEST_F() local
[all …]
Ddb_wal_test.cc942 for (size_t j = kWALFileOffset; j < wal_count + kWALFileOffset; j++) { in FillData() local
943 uint64_t current_log_number = j; in FillData()
1048 for (int j = jstart; j < jend; j++) { /* WAL file */ in TEST_F() local
1095 for (int j = jstart; j < jend; j++) { /* wal files */ in TEST_F() local
1100 /*len%=*/.1, j, trunc); in TEST_F()
1154 for (int j = jstart; j < jend; j++) { /* WAL file */ in TEST_F() local
1161 /*len%=*/.1, j, trunc); in TEST_F()
1182 (j - RecoveryTestHelper::kWALFileOffset); in TEST_F()
1203 for (int j = jstart; j < jend; j++) { /* wal files */ in TEST_F() local
1210 /*len%=*/.1, j, trunc); in TEST_F()
[all …]
Dflush_job_test.cc266 for (size_t j = 0; j < num_keys_per_table; ++j) { in TEST_F() local
267 std::string key(ToString(j + i * num_keys_per_table)); in TEST_F()
269 mem->Add(SequenceNumber(j + i * num_keys_per_table), kTypeValue, key, in TEST_F()
340 for (size_t j = 0; j != num_keys_per_memtable; ++j) { in TEST_F() local
341 std::string key(ToString(j + i * num_keys_per_memtable)); in TEST_F()
450 for (int j = 0; j < insertions; ++j) { in TEST_F() local
457 bool visible = (j == insertions - 1) || in TEST_F()
Ddb_options_test.cc700 for (int j = 0; j < 10; j++) { in TEST_F() local
701 ASSERT_OK(Put(ToString(i * 20 + j), RandomString(&rnd, 980))); in TEST_F()
731 for (int j = 0; j < 10; j++) { in TEST_F() local
732 ASSERT_OK(Put(ToString(i * 20 + j), RandomString(&rnd, 980))); in TEST_F()
763 for (int j = 0; j < 10; j++) { in TEST_F() local
764 ASSERT_OK(Put(ToString(i * 20 + j), RandomString(&rnd, 980))); in TEST_F()
827 for (int j = 0; j < 10; j++) { in TEST_F() local
828 ASSERT_OK(Put(ToString(i * 20 + j), RandomString(&rnd, 980))); in TEST_F()
Ddb_test.cc3354 for (int j = 0; j < 20; j++) { in TEST_F() local
3365 for (int j = 0; j < 20; j++) { in TEST_F() local
3479 for (int j = 0; j < 10; j++) { in TEST_F() local
3514 for (int j = 0; j < 10; j++) { in TEST_F() local
3530 for (int j = 0; j < 10; j++) { in TEST_F() local
3556 for (int j = 0; j < 10; j++) { in TEST_F() local
3594 for (int j = 0; j < 10; j++) { in TEST_F() local
5729 for (int j = 0; j < 2; ++j) { in TEST_F() local
5743 for (int j = 0; j < 2; ++j) { in TEST_F() local
5772 for (int j = 0; j < 2; ++j) { in TEST_F() local
[all …]
/rocksdb-6.9/java/samples/src/main/java/
DRocksDBSample.java132 for (int j = 1; j <= 9; ++j) { in main()
133 db.put(String.format("%dx%d", i, j).getBytes(), in main()
134 String.format("%d", i * j).getBytes()); in main()
139 for (int j = 1; j <= 9; ++j) { in main()
141 String.format("%dx%d", i, j).getBytes()))); in main()
150 for (int j = 10; j <= 19; ++j) { in main()
151 batch.put(String.format("%dx%d", i, j).getBytes(), in main()
152 String.format("%d", i * j).getBytes()); in main()
159 for (int j = 10; j <= 19; ++j) { in main()
162 String.format("%d", i * j))); in main()
[all …]
/rocksdb-6.9/util/
Dfile_checksum_helper.h48 size_t i = 0, j = s.size() - 1; in Uint32ToString() local
49 while (i < j) { in Uint32ToString()
51 s[i] = s[j]; in Uint32ToString()
52 s[j] = tmp; in Uint32ToString()
54 --j; in Uint32ToString()
62 size_t i = 0, j = s.size() - 1; in StringToUint32() local
63 while (i < j) { in StringToUint32()
65 s[i] = s[j]; in StringToUint32()
66 s[j] = tmp; in StringToUint32()
68 --j; in StringToUint32()
/rocksdb-6.9/utilities/
Denv_librados_test.cc476 for (int j = 0; j < bulk_size; ++j) { in TEST_F() local
515 for (int j = 0; j < bulk_size; ++j) { in TEST_F() local
560 for (int j = 0; j < bulk_size; ++j) { in TEST_F() local
564 (long long)(i * bulk_size + j)); in TEST_F()
599 for (int j = 0; j < bulk_size; ++j) { in TEST_F() local
644 for (int j = 0; j < bulk_size; ++j) { in TEST_F() local
648 (long long)(i * bulk_size + j)); in TEST_F()
695 for (int j = 0; j < bulk_size; ++j) { in TEST_F() local
699 (long long)(i * bulk_size + j)); in TEST_F()
943 for (int j = 0; j < bulk_size; ++j) { in TEST_F() local
[all …]
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_trace_analyzer_plot.py117 for j in range(len(miss_ratios[config]["x"])):
118 if miss_ratios["lru-0-0"]["x"][i] == miss_ratios[config]["x"][j]:
164 for j in range(len(data_rows[i])):
165 if j == 0:
166 x.append(sanitize(data_rows[i][j]))
168 label_stats[j - 1].append(float(data_rows[i][j]))
188 for j in range(len(data_rows[i])):
189 if j == 0:
192 label_stats[i - 1].append(float(data_rows[i][j]))
297 for j in range(len(label_stats[i])):
[all …]
/rocksdb-6.9/examples/
Dmulti_processes_example.cc90 size_t i = 0, j = ret.size() - 1; in Key() local
91 while (i < j) { in Key()
93 ret[i] = ret[j]; in Key()
94 ret[j] = tmp; in Key()
96 --j; in Key()
103 size_t i = 0, j = key.size() - 1; in Key() local
104 while (i < j) { in Key()
106 key[i] = key[j]; in Key()
107 key[j] = tmp; in Key()
109 --j; in Key()
/rocksdb-6.9/table/
Dtable_reader_bench.cc39 static std::string MakeKey(int i, int j, bool through_db) { in MakeKey() argument
41 snprintf(buf, sizeof(buf), "%04d__key___%04d", i, j); in MakeKey()
115 for (int j = 0; j < num_keys2; j++) { in TableReaderBenchmark() local
116 std::string key = MakeKey(i * 2, j, through_db); in TableReaderBenchmark()
160 for (int j = 0; j < num_keys2; j++) { in TableReaderBenchmark() local
/rocksdb-6.9/db/compaction/
Dcompaction.cc133 for (size_t j = 0; j < inputs[i].files.size(); j++) { in PopulateWithAtomicBoundaries() local
134 const auto* f = inputs[i].files[j]; in PopulateWithAtomicBoundaries()
135 if (j == 0) { in PopulateWithAtomicBoundaries()
147 add_unit_boundary(j); in PopulateWithAtomicBoundaries()
391 for (size_t j = 0; j < inputs_[i].size(); j++) { in MarkFilesBeingCompacted() local
392 assert(mark_as_compacted ? !inputs_[i][j]->being_compacted in MarkFilesBeingCompacted()
393 : inputs_[i][j]->being_compacted); in MarkFilesBeingCompacted()
394 inputs_[i][j]->being_compacted = mark_as_compacted; in MarkFilesBeingCompacted()
/rocksdb-6.9/utilities/blob_db/
Dblob_dump_tool.cc251 for (size_t j = 0; j < 16 && i + j < s.size(); j++) { in DumpSlice() local
252 unsigned char c = s[i + j]; in DumpSlice()
253 snprintf(buf + j * 3 + 15, 2, "%x", c >> 4); in DumpSlice()
254 snprintf(buf + j * 3 + 16, 2, "%x", c & 0xf); in DumpSlice()
255 snprintf(buf + j + 65, 2, "%c", (0x20 <= c && c <= 0x7e) ? c : '.'); in DumpSlice()
/rocksdb-6.9/third-party/folly/folly/synchronization/test/
DDistributedMutexTest.cpp48 for (auto j = 0; j < iterations; ++j) { in basicNThreads() local
669 for (auto j = 0; j < iterations; ++j) { in stressTryLockWithConcurrentLocks() local
720 for (auto j = 0; j < iterations; ++j) { in concurrentTryLocks() local
897 for (auto j = 0; !stop.load(std::memory_order_relaxed); ++j) { in concurrentLocksManyMutexes() local
898 auto& mutex = mutexes[j % kNumMutexes]; in concurrentLocksManyMutexes()
899 auto& barrier = barriers[j % kNumMutexes]; in concurrentLocksManyMutexes()
999 for (auto j = 0; !stop.load(); ++j) { in concurrentExceptionPropagationStress() local
1012 if (!(j % 3)) { in concurrentExceptionPropagationStress()
1016 return j; in concurrentExceptionPropagationStress()
1022 EXPECT_EQ(value, j); in concurrentExceptionPropagationStress()
[all …]
/rocksdb-6.9/java/jmh/src/main/java/org/rocksdb/jmh/
DGetBenchmarks.java78 for (int j = 0; j < keyCount; j++) { in setup()
79 db.put(cfHandles[i], ba("key" + j), ba("value" + j)); in setup()
DMultiGetBenchmarks.java87 for (int j = 0; j < keyCount; j++) { in setup()
88 db.put(cfHandles[i], ba("key" + j), ba("value" + j)); in setup()
/rocksdb-6.9/table/plain/
Dplain_table_index.cc188 int j; in FillIndexes() local
189 for (j = num_keys_for_bucket - 1; j >= 0 && record; in FillIndexes()
190 j--, record = record->next) { in FillIndexes()
191 EncodeFixed32(sub_index_pos + j * sizeof(uint32_t), record->offset); in FillIndexes()
193 assert(j == -1 && record == nullptr); in FillIndexes()
/rocksdb-6.9/file/
Dsst_file_manager_impl.cc95 for (size_t j = 0; j < c->num_input_files(i); j++) { in OnCompactionCompletion() local
96 FileMetaData* filemeta = c->input(i, j); in OnCompactionCompletion()
166 for (size_t j = 0; j < inputs[i].size(); j++) { in EnoughRoomForCompaction() local
167 FileMetaData* filemeta = inputs[i][j]; in EnoughRoomForCompaction()

1234