Home
last modified time | relevance | path

Searched refs:file_reader (Results 1 – 22 of 22) sorted by relevance

/rocksdb-6.9/utilities/blob_db/
Dblob_file.cc260 std::unique_ptr<RandomAccessFileReader> file_reader( in ReadMetadata() local
268 if (file_reader->use_direct_io()) { in ReadMetadata()
269 s = file_reader->Read(0, BlobLogHeader::kSize, &header_slice, nullptr, in ReadMetadata()
273 s = file_reader->Read(0, BlobLogHeader::kSize, &header_slice, in ReadMetadata()
308 if (file_reader->use_direct_io()) { in ReadMetadata()
309 s = file_reader->Read(file_size - BlobLogFooter::kSize, in ReadMetadata()
314 s = file_reader->Read(file_size - BlobLogFooter::kSize, in ReadMetadata()
Dblob_log_reader.cc19 Reader::Reader(std::unique_ptr<RandomAccessFileReader>&& file_reader, Env* env, in Reader() argument
21 : file_(std::move(file_reader)), in Reader()
Dblob_log_reader.h43 Reader(std::unique_ptr<RandomAccessFileReader>&& file_reader, Env* env,
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader_test.cc115 std::unique_ptr<RandomAccessFileReader> file_reader( in CreateCuckooFileAndCheckReader() local
119 CuckooTableReader reader(ioptions, std::move(file_reader), file_size, ucomp, in CreateCuckooFileAndCheckReader()
145 std::unique_ptr<RandomAccessFileReader> file_reader( in CheckIterator() local
149 CuckooTableReader reader(ioptions, std::move(file_reader), file_size, ucomp, in CheckIterator()
336 std::unique_ptr<RandomAccessFileReader> file_reader( in TEST_F() local
340 CuckooTableReader reader(ioptions, std::move(file_reader), file_size, ucmp, in TEST_F()
447 std::unique_ptr<RandomAccessFileReader> file_reader( in WriteFile() local
452 CuckooTableReader reader(ioptions, std::move(file_reader), file_size, in WriteFile()
480 std::unique_ptr<RandomAccessFileReader> file_reader( in ReadKeys() local
485 CuckooTableReader reader(ioptions, std::move(file_reader), file_size, in ReadKeys()
Dcuckoo_table_builder_test.cc67 std::unique_ptr<RandomAccessFileReader> file_reader( in CheckFileContents() local
70 ASSERT_OK(ReadTableProperties(file_reader.get(), read_file_size, in CheckFileContents()
116 ASSERT_OK(file_reader->Read(i * bucket_size, bucket_size, &read_slice, in CheckFileContents()
/rocksdb-6.9/table/
Dsst_file_reader.cc45 std::unique_ptr<RandomAccessFileReader> file_reader; in Open() local
51 file_reader.reset(new RandomAccessFileReader( in Open()
59 s = r->options.table_factory->NewTableReader(t_opt, std::move(file_reader), in Open()
Dtable_reader_bench.cc141 std::unique_ptr<RandomAccessFileReader> file_reader( in TableReaderBenchmark() local
147 std::move(file_reader), file_size, &table_reader); in TableReaderBenchmark()
Dtable_test.cc3371 std::unique_ptr<RandomAccessFileReader> file_reader( in TEST_F() local
3376 auto s = ReadTableProperties(file_reader.get(), ss->contents().size(), in TEST_F()
4091 std::unique_ptr<RandomAccessFileReader> file_reader( in TEST_P() local
4096 ASSERT_OK(ReadTableProperties(file_reader.get(), ss_rw.contents().size(), in TEST_P()
4122 std::unique_ptr<RandomAccessFileReader> file_reader( in TEST_P() local
4129 std::move(file_reader), ss_rw.contents().size(), &table_reader); in TEST_P()
4268 std::unique_ptr<RandomAccessFileReader> file_reader( in TEST_P() local
4275 ASSERT_OK(ReadTableProperties(file_reader.get(), ss_rw.contents().size(), in TEST_P()
4301 std::move(file_reader), ss_rw.contents().size(), &table_reader)); in TEST_P()
4362 std::unique_ptr<RandomAccessFileReader> file_reader( in TEST_P() local
[all …]
/rocksdb-6.9/utilities/trace/
Dfile_trace_reader_writer.cc100 std::unique_ptr<RandomAccessFileReader> file_reader; in NewFileTraceReader() local
101 file_reader.reset(new RandomAccessFileReader( in NewFileTraceReader()
103 trace_reader->reset(new FileTraceReader(std::move(file_reader))); in NewFileTraceReader()
/rocksdb-6.9/file/
Dfile_prefetch_buffer.h46 FilePrefetchBuffer(RandomAccessFileReader* file_reader = nullptr,
50 file_reader_(file_reader),
/rocksdb-6.9/db/
Dconvenience.cc58 std::unique_ptr<RandomAccessFileReader> file_reader( in VerifySstFileChecksum() local
65 std::move(file_reader), file_size, &table_reader, in VerifySstFileChecksum()
Dtransaction_log_impl.cc44 std::unique_ptr<SequentialFileReader>* file_reader) { in OpenLogFile() argument
65 file_reader->reset(new SequentialFileReader(std::move(file), fname)); in OpenLogFile()
Dwal_manager.cc471 std::unique_ptr<SequentialFileReader> file_reader( in ReadFirstLine() local
484 log::Reader reader(db_options_.info_log, std::move(file_reader), &reporter, in ReadFirstLine()
Dcorruption_test.cc546 std::unique_ptr<RandomAccessFileReader> file_reader( in TEST_F() local
555 file_reader.get(), file_size, kBlockBasedTableMagicNumber, in TEST_F()
Dtable_cache.cc110 std::unique_ptr<RandomAccessFileReader> file_reader( in GetTableReader() local
119 std::move(file_reader), fd.GetFileSize(), table_reader, in GetTableReader()
Dversion_set.cc1244 std::unique_ptr<RandomAccessFileReader> file_reader( in GetTableProperties() local
1250 file_reader.get(), file_meta->fd.GetFileSize(), in GetTableProperties()
4793 std::unique_ptr<SequentialFileReader> file_reader; in ListColumnFamilies() local
4800 file_reader.reset(new SequentialFileReader(std::move(file), manifest_path)); in ListColumnFamilies()
4808 log::Reader reader(nullptr, std::move(file_reader), &reporter, in ListColumnFamilies()
4964 std::unique_ptr<SequentialFileReader> file_reader; in DumpManifest() local
4976 file_reader.reset(new SequentialFileReader( in DumpManifest()
5004 log::Reader reader(nullptr, std::move(file_reader), &reporter, in DumpManifest()
5107 file_reader.reset(); in DumpManifest()
Dplain_table_db_test.cc53 std::unique_ptr<RandomAccessFileReader> file_reader( in TEST_F() local
56 new PlainTableReaderFileInfo(std::move(file_reader), EnvOptions(), in TEST_F()
/rocksdb-6.9/tools/
Dldb_cmd_test.cc122 std::unique_ptr<SequentialFile> file_reader; in VerifyChecksum() local
124 s = options_.env->NewSequentialFile(file_path, &file_reader, soptions); in VerifyChecksum()
141 s = file_reader->Read(2048, &result, scratch.get()); in VerifyChecksum()
147 s = file_reader->Read(2048, &result, scratch.get()); in VerifyChecksum()
/rocksdb-6.9/db/db_impl/
Ddb_impl_secondary.h23 std::unique_ptr<SequentialFileReader>&& file_reader, in LogReaderContainer() argument
36 reader_ = new log::FragmentBufferedReader(info_log, std::move(file_reader), in LogReaderContainer()
Ddb_impl_secondary.cc145 std::unique_ptr<SequentialFileReader> file_reader; in MaybeInitLogReader() local
155 file_reader.reset(new SequentialFileReader( in MaybeInitLogReader()
162 std::move(file_reader), log_number); in MaybeInitLogReader()
Ddb_impl_open.cc785 std::unique_ptr<SequentialFileReader> file_reader; in RecoverLogFiles() local
801 file_reader.reset(new SequentialFileReader( in RecoverLogFiles()
821 log::Reader reader(immutable_db_options_.info_log, std::move(file_reader), in RecoverLogFiles()
/rocksdb-6.9/table/block_based/
Ddata_block_hash_index_test.cc541 std::unique_ptr<RandomAccessFileReader> file_reader; in TestBoundary() local
581 file_reader.reset(test::GetRandomAccessFileReader(new test::StringSource( in TestBoundary()
590 std::move(file_reader), in TestBoundary()