Home
last modified time | relevance | path

Searched refs:dst (Results 1 – 25 of 40) sorted by relevance

12

/rocksdb-6.9/utilities/blob_db/
Dblob_log_format.cc17 assert(dst != nullptr); in EncodeTo()
18 dst->clear(); in EncodeTo()
21 PutFixed32(dst, version); in EncodeTo()
24 dst->push_back(flags); in EncodeTo()
63 assert(dst != nullptr); in EncodeTo()
64 dst->clear(); in EncodeTo()
70 crc = crc32c::Value(dst->c_str(), dst->size()); in EncodeTo()
72 PutFixed32(dst, crc); in EncodeTo()
101 assert(dst != nullptr); in EncodeHeaderTo()
102 dst->clear(); in EncodeHeaderTo()
[all …]
Dblob_log_format.h60 void EncodeTo(std::string* dst);
84 void EncodeTo(std::string* dst);
124 void EncodeHeaderTo(std::string* dst);
/rocksdb-6.9/util/
Dcoding.h211 dst->append(buf, sizeof(buf)); in PutFixed16()
222 dst->append(buf, sizeof(buf)); in PutFixed32()
233 dst->append(buf, sizeof(buf)); in PutFixed64()
240 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint32()
247 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint32Varint32()
256 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint32Varint32Varint32()
273 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint64()
280 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarsignedint64()
287 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint64Varint64()
308 dst->append(value.data(), value.size()); in PutLengthPrefixedSlice()
[all …]
Dcoding_test.cc74 std::string dst; in TEST() local
75 PutFixed32(&dst, 0x04030201); in TEST()
76 ASSERT_EQ(4U, dst.size()); in TEST()
77 ASSERT_EQ(0x01, static_cast<int>(dst[0])); in TEST()
78 ASSERT_EQ(0x02, static_cast<int>(dst[1])); in TEST()
79 ASSERT_EQ(0x03, static_cast<int>(dst[2])); in TEST()
80 ASSERT_EQ(0x04, static_cast<int>(dst[3])); in TEST()
82 dst.clear(); in TEST()
83 PutFixed64(&dst, 0x0807060504030201ull); in TEST()
84 ASSERT_EQ(8U, dst.size()); in TEST()
[all …]
Dcrc32c_test.cc166 uint64_t* dst = (uint64_t*)ROCKSDB_NAMESPACE::crc32c::buffer; in main() local
170 *dst++ = 0; in main()
171 while (dst < end) { in main()
173 reinterpret_cast<char*>(dst), in main()
175 dst++; in main()
Dslice.cc46 bool InRange(const Slice& dst) const override { in InRange()
47 return (dst.size() == prefix_len_); in InRange()
84 bool InRange(const Slice& dst) const override { in InRange()
85 return (dst.size() <= cap_len_); in InRange()
Dcoding.cc23 char* EncodeVarint32(char* dst, uint32_t v) { in EncodeVarint32() argument
25 unsigned char* ptr = reinterpret_cast<unsigned char*>(dst); in EncodeVarint32()
Dxxhash.cc653 XXH_PUBLIC_API void XXH32_canonicalFromHash(XXH32_canonical_t* dst, XXH32_hash_t hash) in XXH32_canonicalFromHash() argument
657 memcpy(dst, &hash, sizeof(*dst)); in XXH32_canonicalFromHash()
1136 XXH_PUBLIC_API void XXH64_canonicalFromHash(XXH64_canonical_t* dst, XXH64_hash_t hash) in XXH64_canonicalFromHash() argument
1140 memcpy(dst, &hash, sizeof(*dst)); in XXH64_canonicalFromHash()
Dxxhash.h261 XXH_PUBLIC_API void XXH32_canonicalFromHash(XXH32_canonical_t* dst, XXH32_hash_t hash);
298 XXH_PUBLIC_API void XXH64_canonicalFromHash(XXH64_canonical_t* dst, XXH64_hash_t hash);
575 XXH_PUBLIC_API void XXH128_canonicalFromHash(XXH128_canonical_t* dst, XXH128_hash_t hash);
/rocksdb-6.9/db/blob/
Dblob_index.h133 assert(dst != nullptr); in EncodeInlinedTTL()
134 dst->clear(); in EncodeInlinedTTL()
137 PutVarint64(dst, expiration); in EncodeInlinedTTL()
144 assert(dst != nullptr); in EncodeBlob()
145 dst->clear(); in EncodeBlob()
149 PutVarint64(dst, offset); in EncodeBlob()
150 PutVarint64(dst, size); in EncodeBlob()
157 assert(dst != nullptr); in EncodeBlobTTL()
158 dst->clear(); in EncodeBlobTTL()
163 PutVarint64(dst, offset); in EncodeBlobTTL()
[all …]
/rocksdb-6.9/db/
Dversion_edit.cc167 PutVarint32(dst, kDbId); in EncodeTo()
168 PutLengthPrefixedSlice(dst, db_id_); in EncodeTo()
171 PutVarint32(dst, kComparator); in EncodeTo()
200 PutVarint32(dst, kNewFile4); in EncodeTo()
276 dst); in EncodeTo()
283 blob_file_addition.EncodeTo(dst); in EncodeTo()
287 PutVarint32(dst, kBlobFileGarbage); in EncodeTo()
288 blob_file_garbage.EncodeTo(dst); in EncodeTo()
306 PutVarint32(dst, kInAtomicGroup); in EncodeTo()
315 dst->DecodeFrom(str); in GetInternalKey()
[all …]
Ddbformat.cc176 char* dst; in LookupKey() local
178 dst = space_; in LookupKey()
180 dst = new char[needed]; in LookupKey()
182 start_ = dst; in LookupKey()
184 dst = EncodeVarint32(dst, static_cast<uint32_t>(usize + ts_sz + 8)); in LookupKey()
185 kstart_ = dst; in LookupKey()
187 dst += usize; in LookupKey()
189 memcpy(dst, ts->data(), ts_sz); in LookupKey()
190 dst += ts_sz; in LookupKey()
193 dst += 8; in LookupKey()
[all …]
Ddb_bloom_filter_test.cc65 bool InRange(const Slice& dst) const override { in InRange()
67 return dst.size() == 5; in InRange()
658 std::string* dst) const override { in CreateFilter()
664 return filter_->CreateFilter(user_keys.get(), n, dst); in CreateFilter()
755 void CreateFilter(const Slice* keys, int n, std::string* dst) const override { in CreateFilter()
756 policy_otherwise_->CreateFilter(keys, n, dst); in CreateFilter()
894 bool InRange(const Slice& dst) const override { in InRange()
896 return dst.size() == 5 && dst[0] == 'x'; in InRange()
/rocksdb-6.9/table/
Dformat.cc54 PutVarint64Varint64(dst, offset_, size_); in EncodeTo()
100 handle.EncodeTo(dst); in EncodeTo()
102 assert(dst->size() != 0); in EncodeTo()
174 void Footer::EncodeTo(std::string* dst) const { in EncodeTo()
179 const size_t original_size = dst->size(); in EncodeTo()
180 metaindex_handle_.EncodeTo(dst); in EncodeTo()
181 index_handle_.EncodeTo(dst); in EncodeTo()
187 const size_t original_size = dst->size(); in EncodeTo()
189 metaindex_handle_.EncodeTo(dst); in EncodeTo()
190 index_handle_.EncodeTo(dst); in EncodeTo()
[all …]
Dsst_file_reader_test.cc28 std::string dst; in EncodeAsUint64() local
29 PutFixed64(&dst, v); in EncodeAsUint64()
30 return dst; in EncodeAsUint64()
Dformat.h52 void EncodeTo(std::string* dst) const;
96 void EncodeTo(std::string* dst, bool have_first_key,
156 void EncodeTo(std::string* dst) const;
Dmeta_blocks.cc57 std::string dst; in Add() local
58 PutVarint64(&dst, val); in Add()
60 Add(name, dst); in Add()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DSstFileReaderTest.java144 byte[] dst = new byte["key1".getBytes().length]; in readSstFile()
145 direct.get(dst); in readSstFile()
146 assertThat(new String(dst)).isEqualTo("key1"); in readSstFile()
150 dst = new byte["value1".getBytes().length]; in readSstFile()
151 direct.get(dst); in readSstFile()
152 assertThat(new String(dst)).isEqualTo("value1"); in readSstFile()
/rocksdb-6.9/test_util/
Dtestutil.cc30 Slice RandomString(Random* rnd, int len, std::string* dst) { in RandomString() argument
31 dst->resize(len); in RandomString()
33 (*dst)[i] = static_cast<char>(' ' + rnd->Uniform(95)); // ' ' .. '~' in RandomString()
35 return Slice(*dst); in RandomString()
75 int len, std::string* dst) { in CompressibleString() argument
82 dst->clear(); in CompressibleString()
83 while (dst->size() < (unsigned int)len) { in CompressibleString()
84 dst->append(raw_data); in CompressibleString()
86 dst->resize(len); in CompressibleString()
87 return Slice(*dst); in CompressibleString()
/rocksdb-6.9/utilities/
Denv_timed.cc110 Status RenameFile(const std::string& src, const std::string& dst) override { in RenameFile() argument
112 return EnvWrapper::RenameFile(src, dst); in RenameFile()
115 Status LinkFile(const std::string& src, const std::string& dst) override { in LinkFile() argument
117 return EnvWrapper::LinkFile(src, dst); in LinkFile()
/rocksdb-6.9/file/
Dfilename.cc457 std::string dst; in NormalizePath() local
459 if (!dst.empty() && c == kFilePathSeparator && in NormalizePath()
460 dst.back() == kFilePathSeparator) { in NormalizePath()
463 dst.push_back(c); in NormalizePath()
465 return dst; in NormalizePath()
/rocksdb-6.9/table/block_based/
Dfilter_policy.cc486 std::string* dst) const { in CreateFilter()
504 const size_t init_size = dst->size(); in CreateFilter()
505 dst->resize(init_size + bytes, 0); in CreateFilter()
506 dst->push_back(static_cast<char>(num_probes)); // Remember # of probes in CreateFilter()
507 char* array = &(*dst)[init_size]; in CreateFilter()
Dfull_filter_block_test.cc79 void CreateFilter(const Slice* keys, int n, std::string* dst) const override { in CreateFilter()
82 PutFixed32(dst, h); in CreateFilter()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc314 Status CopyOrCreateFile(const std::string& src, const std::string& dst,
1197 std::string dst; in RestoreDBFromBackup() local
1203 dst = file.substr(slash + 1); in RestoreDBFromBackup()
1208 dst = GetFileFromChecksumFile(dst); in RestoreDBFromBackup()
1214 bool ok = ParseFileName(dst, &number, &type); in RestoreDBFromBackup()
1220 dst = ((type == kLogFile) ? wal_dir : db_dir) + in RestoreDBFromBackup()
1221 "/" + dst; in RestoreDBFromBackup()
1224 dst.c_str()); in RestoreDBFromBackup()
1226 GetAbsolutePath(file), dst, "" /* contents */, backup_env_, db_env_, in RestoreDBFromBackup()
1296 const std::string& src, const std::string& dst, const std::string& contents, in CopyOrCreateFile() argument
[all …]
/rocksdb-6.9/trace_replay/
Dtrace_replay.cc23 void EncodeCFAndKey(std::string* dst, uint32_t cf_id, const Slice& key) { in EncodeCFAndKey() argument
24 PutFixed32(dst, cf_id); in EncodeCFAndKey()
25 PutLengthPrefixedSlice(dst, key); in EncodeCFAndKey()

12