Home
last modified time | relevance | path

Searched refs:v (Results 1 – 25 of 139) sorted by relevance

123456

/rocksdb-6.9/util/
Dcoding_test.cc19 for (uint16_t v = 0; v < 0xFFFF; v++) { in TEST() local
20 PutFixed16(&s, v); in TEST()
24 for (uint16_t v = 0; v < 0xFFFF; v++) { in TEST() local
26 ASSERT_EQ(v, actual); in TEST()
33 for (uint32_t v = 0; v < 100000; v++) { in TEST() local
34 PutFixed32(&s, v); in TEST()
38 for (uint32_t v = 0; v < 100000; v++) { in TEST() local
40 ASSERT_EQ(v, actual); in TEST()
49 PutFixed64(&s, v - 1); in TEST()
99 PutVarint32(&s, v); in TEST()
[all …]
Dcoding.cc27 if (v < (1 << 7)) { in EncodeVarint32()
28 *(ptr++) = v; in EncodeVarint32()
30 *(ptr++) = v | B; in EncodeVarint32()
31 *(ptr++) = v >> 7; in EncodeVarint32()
33 *(ptr++) = v | B; in EncodeVarint32()
34 *(ptr++) = (v >> 7) | B; in EncodeVarint32()
35 *(ptr++) = v >> 14; in EncodeVarint32()
37 *(ptr++) = v | B; in EncodeVarint32()
40 *(ptr++) = v >> 21; in EncodeVarint32()
42 *(ptr++) = v | B; in EncodeVarint32()
[all …]
Dfile_checksum_helper.h39 s.append(reinterpret_cast<char*>(&v), sizeof(v)); in Uint32ToString()
41 char buf[sizeof(v)]; in Uint32ToString()
42 buf[0] = v & 0xff; in Uint32ToString()
43 buf[1] = (v >> 8) & 0xff; in Uint32ToString()
44 buf[2] = (v >> 16) & 0xff; in Uint32ToString()
45 buf[3] = (v >> 24) & 0xff; in Uint32ToString()
46 s.append(buf, sizeof(v)); in Uint32ToString()
70 uint32_t v = 0; in StringToUint32() local
72 memcpy(&v, s.c_str(), sizeof(uint32_t)); in StringToUint32()
75 v |= static_cast<uint32_t>(buf[0]); in StringToUint32()
[all …]
Dcrc32c_arm64.h16 #define crc32c_u8(crc, v) __crc32cb(crc, v) argument
17 #define crc32c_u16(crc, v) __crc32ch(crc, v) argument
18 #define crc32c_u32(crc, v) __crc32cw(crc, v) argument
19 #define crc32c_u64(crc, v) __crc32cd(crc, v) argument
21 __asm__("PRFM PLDL1KEEP, [%x[v],%[c]]" ::[v] "r"(buffer), \
23 __asm__("PRFM PLDL1KEEP, [%x[v],%[c]]" ::[v] "r"(buffer), \
25 __asm__("PRFM PLDL1KEEP, [%x[v],%[c]]" ::[v] "r"(buffer), \
27 __asm__("PRFM PLDL1KEEP, [%x[v],%[c]]" ::[v] "r"(buffer), \
Ddefer_test.cc16 int v = 1; in TEST() local
18 Defer defer([&v]() { v *= 2; }); in TEST()
20 ASSERT_EQ(2, v); in TEST()
24 int v = 1; in TEST() local
25 auto f = [&v]() { in TEST()
26 Defer defer([&v]() { v *= 2; }); in TEST()
27 v = 2; in TEST()
30 ASSERT_EQ(4, v); in TEST()
Dcoding.h94 extern int VarintLength(uint64_t v);
239 char* ptr = EncodeVarint32(buf, v); in PutVarint32()
262 while (v >= B) { in EncodeVarint64()
263 *(ptr++) = (v & (B - 1)) | B; in EncodeVarint64()
264 v >>= 7; in EncodeVarint64()
266 *(ptr++) = static_cast<unsigned char>(v); in EncodeVarint64()
272 char* ptr = EncodeVarint64(buf, v); in PutVarint64()
279 char* ptr = EncodeVarint64(buf, i64ToZigzag(v)); in PutVarsignedint64()
333 inline int VarintLength(uint64_t v) { in VarintLength() argument
335 while (v >= 128) { in VarintLength()
[all …]
Dheap.h108 T v = std::move(data_[index]); in upheap() local
111 if (!cmp_(data_[parent], v)) { in upheap()
117 data_[index] = std::move(v); in upheap()
122 T v = std::move(data_[index]); in downheap() local
139 if (!cmp_(v, data_[picked_child])) { in downheap()
157 data_[index] = std::move(v); in downheap()
Dhash.h73 inline uint32_t Upper32of64(uint64_t v) { in Upper32of64() argument
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() argument
Dautovector_test.cc227 TVector v; in BenchmarkVectorCreationAndInsertion() local
229 v.push_back(items[index++]); in BenchmarkVectorCreationAndInsertion()
240 TVector v; in BenchmarkSequenceAccess() local
242 v.push_back(item); in BenchmarkSequenceAccess()
250 auto end = v.end(); in BenchmarkSequenceAccess()
251 for (auto pos = v.begin(); pos != end; ++pos) { in BenchmarkSequenceAccess()
/rocksdb-6.9/db/
Dc.cc2471 switch(v) { in rocksdb_options_set_access_hint_on_compaction_start()
3148 unsigned char v) { in rocksdb_readoptions_set_verify_checksums() argument
3225 uint64_t v) { in rocksdb_readoptions_set_max_skippable_internal_keys() argument
3249 opt->rep.sync = v; in rocksdb_writeoptions_set_sync()
3258 unsigned char v) { in rocksdb_writeoptions_set_ignore_missing_column_families() argument
3317 opt->rep.wait = v; in rocksdb_flushoptions_set_wait()
4318 delete (v); in rocksdb_get_pinned()
4324 return v; in rocksdb_get_pinned()
4335 delete v; in rocksdb_get_pinned_cf()
4341 return v; in rocksdb_get_pinned_cf()
[all …]
Dcorruption_test.cc422 std::string v; in TEST_F() local
423 ASSERT_OK(db_->Get(ReadOptions(), "foo", &v)); in TEST_F()
424 ASSERT_EQ("v5", v); in TEST_F()
428 ASSERT_OK(db_->Get(ReadOptions(), "foo", &v)); in TEST_F()
429 ASSERT_EQ("v6", v); in TEST_F()
432 ASSERT_EQ("v6", v); in TEST_F()
447 std::string v; in TEST_F() local
449 ASSERT_EQ("hello", v); in TEST_F()
527 std::string v; in TEST_F() local
529 ASSERT_EQ(Value(1000, &tmp2).ToString(), v); in TEST_F()
[all …]
Ddb_sst_test.cc405 for (char v = 'a'; v <= 'd'; v++) { in TEST_F() local
472 for (char v = 'a'; v <= 'd'; v++) { in TEST_F() local
473 ASSERT_OK(Put("Key2", DummyString(1024, v))); in TEST_F()
474 ASSERT_OK(Put("Key3", DummyString(1024, v))); in TEST_F()
475 ASSERT_OK(Put("Key4", DummyString(1024, v))); in TEST_F()
476 ASSERT_OK(Put("Key1", DummyString(1024, v))); in TEST_F()
477 ASSERT_OK(Put("Key4", DummyString(1024, v))); in TEST_F()
551 for (char v = 'a'; v <= 'd'; v++) { in TEST_P() local
552 ASSERT_OK(Put("Key2", DummyString(1024, v))); in TEST_P()
553 ASSERT_OK(Put("Key3", DummyString(1024, v))); in TEST_P()
[all …]
Ddb_universal_compaction_test.cc1340 auto v = Get(Key(i)); in TEST_P() local
1342 ASSERT_TRUE(v.size() == 1 || v.size() == 990); in TEST_P()
1348 auto v = Get(Key(i)); in TEST_P() local
1350 ASSERT_TRUE(v.size() == 1 || v.size() == 990); in TEST_P()
1413 ASSERT_TRUE(v.size() == 1 || v.size() == 990); in TEST_P()
1419 ASSERT_TRUE(v.size() == 1 || v.size() == 990); in TEST_P()
1425 ASSERT_TRUE(v.size() == 1 || v.size() == 990); in TEST_P()
1677 auto v = Get(Key(i)); in TEST_P() local
1679 ASSERT_TRUE(v.size() == 1 || v.size() == 990); in TEST_P()
1685 auto v = Get(Key(i)); in TEST_P() local
[all …]
Dversion_set.cc3626 v->Ref(); in AppendVersion()
3631 v->prev_->next_ = v; in AppendVersion()
3632 v->next_->prev_ = v; in AppendVersion()
4022 delete v; in ProcessManifestWrites()
5149 delete v; in DumpManifest()
5414 assert(v); in ApproximateOffsetOf()
5441 assert(v); in ApproximateSize()
5483 v = v->next_) { in AddLiveFiles()
5502 v = v->next_) { in AddLiveFiles()
5738 for (Version* v = dummy_versions->next_; v != dummy_versions; v = v->next_) { in GetNumLiveVersions() local
[all …]
/rocksdb-6.9/tools/
Dldb_cmd_test.cc275 std::string v; in TEST_F() local
276 test::RandomString(&rnd, 100, &v); in TEST_F()
277 ASSERT_OK(db->Put(wopts, buf, v)); in TEST_F()
283 std::string v; in TEST_F() local
284 test::RandomString(&rnd, 100, &v); in TEST_F()
291 std::string v; in TEST_F() local
299 std::string v; in TEST_F() local
362 std::string v; in TEST_F() local
370 std::string v; in TEST_F() local
378 std::string v; in TEST_F() local
[all …]
Ddb_crashtest.py207 dest_params = dict([(k, v() if callable(v) else v)
208 for (k, v) in src_params.items()])
269 for k, v in vars(args).items():
270 if v is not None:
271 params[k] = v
278 '--{0}={1}'.format(k, v)
279 for k, v in [(k, finalzied_params[k]) for k in sorted(finalzied_params)]
282 and v is not None] + unknown_params
493 for k, v in all_params.items():
494 parser.add_argument("--" + k, type=type(v() if callable(v) else v))
Dcheck_format_compatible.sh38 v = ""
40 v = v + vb
41 print >> f, k + " ==> " + v
52 v = "value" + k
53 print >> f, k + " ==> " + v
/rocksdb-6.9/docs/_posts/
D2019-03-08-format-version-4.markdown31 restart_point 0: k, v (off, sz), k, v (delta-sz), ..., k, v (delta-sz)
32 restart_point 1: k, v (off, sz), k, v (delta-sz), ..., k, v (delta-sz)
34 restart_point n-1: k, v (off, sz), k, v (delta-sz), ..., k, v (delta-sz)
35 where, k is key, v is value, and its encoding is in parenthesis.
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DTypes.java35 public static byte[] intToByte(final int v) { in intToByte() argument
37 (byte)((v >>> 0) & 0xff), in intToByte()
38 (byte)((v >>> 8) & 0xff), in intToByte()
39 (byte)((v >>> 16) & 0xff), in intToByte()
40 (byte)((v >>> 24) & 0xff) in intToByte()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_common.cc82 void PoolSizeChangeThread(void* v) { in PoolSizeChangeThread() argument
84 ThreadState* thread = reinterpret_cast<ThreadState*>(v); in PoolSizeChangeThread()
117 void DbVerificationThread(void* v) { in DbVerificationThread() argument
119 auto* thread = reinterpret_cast<ThreadState*>(v); in DbVerificationThread()
212 size_t GenerateValue(uint32_t rand, char* v, size_t max_sz) { in GenerateValue() argument
217 *((uint32_t*)v) = rand; in GenerateValue()
219 v[i] = (char)(rand ^ i); in GenerateValue()
221 v[value_sz] = '\0'; in GenerateValue()
/rocksdb-6.9/table/block_based/
Dblock_test.cc105 Slice v = iter->value(); in TEST_F() local
109 ASSERT_EQ(v.ToString().compare(values[count]), 0); in TEST_F()
124 Slice v = iter->value(); in TEST_F() local
125 ASSERT_EQ(v.ToString().compare(values[index]), 0); in TEST_F()
171 Slice v = regular_iter->value(); in CheckBlockContents() local
172 ASSERT_EQ(v.ToString().compare(values[i]), 0); in CheckBlockContents()
585 IndexValue v = iter->value(); in TEST_P() local
589 EXPECT_EQ(block_handles[index].size(), v.handle.size()); in TEST_P()
591 v.first_internal_key.ToString()); in TEST_P()
610 IndexValue v = iter->value(); in TEST_P() local
[all …]
Dblock_based_table_iterator.cc60 IndexValue v = index_iter_->value(); in SeekImpl() local
62 v.handle.offset() == prev_block_offset_; in SeekImpl()
65 if (!v.first_internal_key.empty() && !same_block && in SeekImpl()
66 (!target || icomp_.Compare(*target, v.first_internal_key) <= 0) && in SeekImpl()
322 IndexValue v = index_iter_->value(); in FindBlockForward() local
325 if (!v.first_internal_key.empty() && in FindBlockForward()
/rocksdb-6.9/buckifier/
Dbuckify_rocksdb.py125 for k, v in data.items():
126 if isinstance(v, dict):
127 v = encode_dict(v)
128 rv[k] = v
/rocksdb-6.9/java/crossbuild/
DVagrantfile35 config.vm.provider "virtualbox" do |v|
36 v.memory = 2048
37 v.cpus = 4
38 v.customize ["modifyvm", :id, "--nictype1", "virtio" ]
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc127 for (auto v : pair.second) { in TestValueAsSecondaryIndexHelper() local
132 ASSERT_EQ(v->type, write_entry.type); in TestValueAsSecondaryIndexHelper()
143 for (auto v = pair->second.rbegin(); v != pair->second.rend(); v++) { in TestValueAsSecondaryIndexHelper() local
168 for (auto v : pair.second) { in TestValueAsSecondaryIndexHelper() local
173 if (v->type != kDeleteRecord) { in TestValueAsSecondaryIndexHelper()
185 for (auto v = pair->second.rbegin(); v != pair->second.rend(); v++) { in TestValueAsSecondaryIndexHelper() local
190 if ((*v)->type != kDeleteRecord) { in TestValueAsSecondaryIndexHelper()
208 for (auto v : pair->second) { in TestValueAsSecondaryIndexHelper() local
212 ASSERT_EQ(v->type, write_entry.type); in TestValueAsSecondaryIndexHelper()
230 for (auto v : pair->second) { in TestValueAsSecondaryIndexHelper() local
[all …]

123456