Home
last modified time | relevance | path

Searched refs:contents (Results 1 – 25 of 49) sorted by relevance

12

/rocksdb-6.9/table/block_based/
Dblock_test.cc94 BlockContents contents; in TEST_F() local
95 contents.data = rawblock; in TEST_F()
143 BlockContents contents; in GetBlockContents() local
144 contents.data = rawblock; in GetBlockContents()
146 return contents; in GetBlockContents()
378 BlockContents contents; in TEST_F() local
379 contents.data = rawblock; in TEST_F()
411 BlockContents contents; in TEST_F() local
446 BlockContents contents; in TEST_F() local
566 BlockContents contents; in TEST_P() local
[all …]
Ddata_block_hash_index_test.cc285 BlockContents contents; in TEST() local
286 contents.data = rawblock; in TEST()
307 BlockContents contents; in TEST() local
308 contents.data = rawblock; in TEST()
338 BlockContents contents; in TEST() local
339 contents.data = rawblock; in TEST()
362 BlockContents contents; in TEST() local
389 BlockContents contents; in TEST() local
390 contents.data = rawblock; in TEST()
471 BlockContents contents; in TEST() local
[all …]
Dfilter_policy.cc606 const Slice& contents) const { in GetFilterBitsReader()
607 uint32_t len_with_meta = static_cast<uint32_t>(contents.size()); in GetFilterBitsReader()
626 static_cast<int8_t>(contents.data()[len_with_meta - 5]); in GetFilterBitsReader()
637 return GetBloomBitsReader(contents); in GetFilterBitsReader()
652 uint32_t num_lines = DecodeFixed32(contents.data() + len_with_meta - 4); in GetFilterBitsReader()
675 return new LegacyBloomBitsReader(contents.data(), num_probes, num_lines, in GetFilterBitsReader()
681 const Slice& contents) const { in GetBloomBitsReader()
682 uint32_t len_with_meta = static_cast<uint32_t>(contents.size()); in GetBloomBitsReader()
712 char sub_impl_val = contents.data()[len_with_meta - 4]; in GetBloomBitsReader()
713 char block_and_probes = contents.data()[len_with_meta - 3]; in GetBloomBitsReader()
[all …]
Dfull_filter_block_test.cc54 explicit TestFilterBitsReader(const Slice& contents) in TestFilterBitsReader() argument
55 : data_(contents.data()), len_(static_cast<uint32_t>(contents.size())) {} in TestFilterBitsReader()
100 FilterBitsReader* GetFilterBitsReader(const Slice& contents) const override { in GetFilterBitsReader()
101 return new TestFilterBitsReader(contents); in GetFilterBitsReader()
Dblock_based_table_reader.cc95 return new BlockContents(std::move(contents)); in Create()
141 return new UncompressionDict(contents.data, std::move(contents.allocation), in Create()
169 BlockContents contents; in ReadBlockFromFile() local
1148 BlockContents contents; in GetDataBlockFromCache() local
1375 BlockContents* contents) const { in MaybeReadBlockAndLoadToCache()
1406 if (!contents) { in MaybeReadBlockAndLoadToCache()
1428 if (!contents) { in MaybeReadBlockAndLoadToCache()
1439 contents = &raw_block_contents; in MaybeReadBlockAndLoadToCache()
1746 BlockContents contents; in RetrieveMultipleBlocks() local
2722 BlockContents contents; in VerifyChecksumInBlocks() local
[all …]
Dblock_based_filter_block.cc221 const BlockContents& contents, const char** data, const char** offset, in ParseFieldsFromBlock() argument
228 const size_t n = contents.data.size(); in ParseFieldsFromBlock()
233 const uint32_t last_word = DecodeFixed32(contents.data.data() + n - 5); in ParseFieldsFromBlock()
238 *data = contents.data.data(); in ParseFieldsFromBlock()
241 *base_lg = contents.data[n - 1]; in ParseFieldsFromBlock()
Dparsed_full_filter_block.cc13 BlockContents&& contents) in ParsedFullFilterBlock() argument
14 : block_contents_(std::move(contents)), in ParsedFullFilterBlock()
Dfilter_policy_internal.h112 FilterBitsReader* GetFilterBitsReader(const Slice& contents) const override;
139 FilterBitsReader* GetBloomBitsReader(const Slice& contents) const;
Dblock.cc868 Block::Block(BlockContents&& contents, size_t read_amp_bytes_per_bit, in Block() argument
870 : contents_(std::move(contents)), in Block()
900 contents.data.data(), in Block()
901 static_cast<uint16_t>(contents.data.size() - in Block()
/rocksdb-6.9/table/
Dpersistent_cache_helper.cc29 const BlockContents& contents) { in InsertUncompressedPage() argument
42 cache_options.persistent_cache->Insert(key, contents.data.data(), in InsertUncompressedPage()
43 contents.data.size()); in InsertUncompressedPage()
78 BlockContents* contents) { in LookupUncompressedPage() argument
81 if (!contents) { in LookupUncompressedPage()
109 *contents = BlockContents(std::move(data), size); in LookupUncompressedPage()
Dformat.cc342 BlockContents* contents, uint32_t format_version, in UncompressBlockContentsForCompressionType() argument
364 *contents = BlockContents(std::move(ubuf), ulength); in UncompressBlockContentsForCompressionType()
377 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
389 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
401 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
413 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
425 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
436 *contents = BlockContents(std::move(ubuf), decompress_size); in UncompressBlockContentsForCompressionType()
447 contents->data.size()); in UncompressBlockContentsForCompressionType()
462 BlockContents* contents, uint32_t format_version, in UncompressBlockContents() argument
[all …]
Dpersistent_cache_helper.h30 const BlockContents& contents);
41 BlockContents* contents);
Dformat.h307 BlockContents* contents, const ImmutableCFOptions& ioptions,
320 BlockContents* contents,
330 BlockContents* contents, uint32_t compress_format_version,
Dblock_fetcher.h42 BlockContents* contents, const ImmutableCFOptions& ioptions,
54 contents_(contents), in file_()
Dtable_test.cc236 BlockContents contents; in FinishImpl() local
237 contents.data = data_; in FinishImpl()
238 block_ = new Block(std::move(contents)); in FinishImpl()
382 std::move(file_reader_), TEST_GetSink()->contents().size(), in FinishImpl()
417 std::move(file_reader_), TEST_GetSink()->contents().size(), in Reopen()
1252 new test::StringSource(ss_rw->contents()))); in CalculateFileChecksum()
3373 new test::StringSource(ss->contents(), 72242, true))); in TEST_F()
4368 uint64_t file_size = ss_rw.contents().size(); in TEST_P()
4375 BlockContents* contents) { in TEST_P() argument
4382 contents, ioptions, false /* decompress */, in TEST_P()
[all …]
/rocksdb-6.9/db/
Dlog_test.cc63 : contents_(contents), in StringSource()
781 std::string contents() { in contents() function in ROCKSDB_NAMESPACE::log::RetriableLogTest
828 size_t old_sz = contents().size(); in TEST_P()
830 size_t new_sz = contents().size(); in TEST_P()
831 std::string part1 = contents().substr(old_sz, delta); in TEST_P()
871 size_t old_sz = contents().size(); in TEST_P()
873 size_t new_sz = contents().size(); in TEST_P()
874 std::string part1 = contents().substr(old_sz, delta); in TEST_P()
905 size_t old_sz = contents().size(); in TEST_P()
907 size_t new_sz = contents().size(); in TEST_P()
[all …]
Dtable_properties_collector_test.cc292 new test::StringSource(fwf->contents()))); in TestCustomizedTablePropertiesCollector()
294 Status s = ReadTableProperties(fake_file_reader.get(), fwf->contents().size(), in TestCustomizedTablePropertiesCollector()
433 new test::StringSource(fwf->contents()))); in TestInternalKeyPropertiesCollector()
436 ReadTableProperties(reader.get(), fwf->contents().size(), magic_number, in TestInternalKeyPropertiesCollector()
Dcorruption_test.cc183 std::string contents; in CorruptFile() local
184 Status s = ReadFileToString(Env::Default(), fname, &contents); in CorruptFile()
187 contents[i + offset] ^= 0x80; in CorruptFile()
189 s = WriteStringToFile(Env::Default(), contents, fname); in CorruptFile()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc339 std::string contents; member
352 contents(""), in CopyOrCreateWorkItem()
370 contents = std::move(o.contents); in operator =()
389 contents(std::move(_contents)),
495 const std::string& contents = std::string());
1300 assert(src.empty() != contents.empty()); in CopyOrCreateFile()
1350 data = contents; in CopyOrCreateFile()
1394 const std::string& contents) { in AddBackupFileWorkItem() argument
1396 assert(contents.empty() != src_dir.empty()); in AddBackupFileWorkItem()
1458 if (!contents.empty()) { in AddBackupFileWorkItem()
[all …]
/rocksdb-6.9/test_util/
Dtestutil.h210 const std::string& contents() const { return contents_; } in contents() function
280 const std::string& contents() const { return ss_->contents(); } in contents() function
297 const std::string& contents() const { return contents_; } in contents() function
331 explicit StringSource(const Slice& contents, uint64_t uniq_id = 0,
333 : contents_(contents.data(), contents.size()),
570 explicit StringSink(std::string* contents) in StringSink() argument
571 : WritableFile(), contents_(contents) {} in StringSink()
/rocksdb-6.9/file/
Dfilename.cc376 Slice contents = manifest; in SetCurrentFile() local
377 assert(contents.starts_with(dbname + "/")); in SetCurrentFile()
378 contents.remove_prefix(dbname.size() + 1); in SetCurrentFile()
380 IOStatus s = WriteStringToFile(fs, contents.ToString() + "\n", tmp, true); in SetCurrentFile()
Dfile_util.cc73 const std::string& contents, bool use_fsync) { in CreateFile() argument
85 s = dest_writer->Append(Slice(contents)); in CreateFile()
/rocksdb-6.9/utilities/blob_db/
Dblob_dump_tool.cc209 BlockContents contents; in DumpRecord() local
215 &contents, 2 /*compress_format_version*/, in DumpRecord()
220 uncompressed_value = contents.data.ToString(); in DumpRecord()
/rocksdb-6.9/db/compaction/
Dcompaction_job_test.cc132 void AddMockFile(const stl_wrappers::KVMap& contents, int level = 0) { in AddMockFile() argument
133 assert(contents.size() > 0); in AddMockFile()
141 for (auto kv : contents) { in AddMockFile()
185 env_, GenerateFileName(file_number), std::move(contents))); in AddMockFile()
218 auto contents = mock::MakeMockFile(); in CreateTwoFiles() local
233 contents.insert({ internal_key.Encode().ToString(), value }); in CreateTwoFiles()
240 AddMockFile(contents); in CreateTwoFiles()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_impl.cc127 [&](const std::string& fname, const std::string& contents, FileType) { in CreateCheckpoint() argument
130 contents, db_options.use_fsync); in CreateCheckpoint()
175 std::function<Status(const std::string& fname, const std::string& contents, in CreateCustomCheckpoint() argument

12