Home
last modified time | relevance | path

Searched refs:file_writer (Results 1 – 18 of 18) sorted by relevance

/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_builder_test.cc179 ASSERT_OK(file_writer->Close()); in TEST_F()
228 ASSERT_OK(file_writer->Close()); in TEST_F()
278 ASSERT_OK(file_writer->Close()); in TEST_F()
328 ASSERT_OK(file_writer->Close()); in TEST_F()
382 ASSERT_OK(file_writer->Close()); in TEST_F()
433 ASSERT_OK(file_writer->Close()); in TEST_F()
477 ASSERT_OK(file_writer->Close()); in TEST_F()
522 ASSERT_OK(file_writer->Close()); in TEST_F()
569 ASSERT_OK(file_writer->Close()); in TEST_F()
613 ASSERT_OK(file_writer->Close()); in TEST_F()
[all …]
Dcuckoo_table_reader_test.cc94 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in CreateCuckooFileAndCheckReader() local
99 file_writer.get(), 0.9, kNumHashFunc, 100, ucomp, 2, false, false, in CreateCuckooFileAndCheckReader()
110 ASSERT_OK(file_writer->Close()); in CreateCuckooFileAndCheckReader()
425 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in WriteFile() local
429 file_writer.get(), hash_ratio, 64, 1000, test::Uint64Comparator(), 5, in WriteFile()
441 ASSERT_OK(file_writer->Close()); in WriteFile()
/rocksdb-6.9/db/
Dbuilder.cc113 std::unique_ptr<WritableFileWriter> file_writer; in BuildTable() local
135 file_writer.reset(new WritableFileWriter( in BuildTable()
142 column_family_name, file_writer.get(), compression, in BuildTable()
212 *io_status = file_writer->Sync(ioptions.use_fsync); in BuildTable()
215 *io_status = file_writer->Close(); in BuildTable()
219 meta->file_checksum = file_writer->GetFileChecksum(); in BuildTable()
220 meta->file_checksum_func_name = file_writer->GetFileChecksumFuncName(); in BuildTable()
Dwal_manager_test.cc84 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in RollTheLog() local
86 current_log_writer_.reset(new log::Writer(std::move(file_writer), 0, false)); in RollTheLog()
136 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in TEST_F() local
138 log::Writer writer(std::move(file_writer), 1, in TEST_F()
Dversion_set_test.cc716 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in PrepareManifest() local
719 log_writer->reset(new log::Writer(std::move(file_writer), 0, false)); in PrepareManifest()
1351 std::unique_ptr<WritableFileWriter> file_writer( in PrepareManifest() local
1354 log_writer->reset(new log::Writer(std::move(file_writer), 0, true)); in PrepareManifest()
1423 std::unique_ptr<WritableFileWriter> file_writer( in PrepareManifest() local
1427 log_writer->reset(new log::Writer(std::move(file_writer), 0, false)); in PrepareManifest()
1733 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in PrepareManifest() local
1735 log_writer->reset(new log::Writer(std::move(file_writer), 0, false)); in PrepareManifest()
Dflush_job_test.cc94 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in NewDB() local
97 log::Writer log(std::move(file_writer), 0, false); in NewDB()
Ddb_wal_test.cc947 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in FillData() local
950 new log::Writer(std::move(file_writer), current_log_number, in FillData()
Dversion_set.cc3871 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in ProcessManifestWrites() local
3875 new log::Writer(std::move(file_writer), 0, false)); in ProcessManifestWrites()
/rocksdb-6.9/table/
Dsst_file_writer.cc43 std::unique_ptr<WritableFileWriter> file_writer; member
154 file_writer->InvalidateCache(0, 0); in InvalidatePageCache()
245 r->file_writer.reset( in Open()
253 table_builder_options, cf_id, r->file_writer.get())); in Open()
296 s = r->file_writer->Sync(r->ioptions.use_fsync); in Finish()
299 s = r->file_writer->Close(); in Finish()
Dtable_reader_bench.cc90 std::unique_ptr<WritableFileWriter> file_writer; in TableReaderBenchmark() local
98 file_writer.reset(new WritableFileWriter( in TableReaderBenchmark()
107 0 /* column_family_id */, file_writer.get()); in TableReaderBenchmark()
126 file_writer->Close(); in TableReaderBenchmark()
Dmock_table.cc98 WritableFileWriter file_writer(NewLegacyWritableFileWrapper(std::move(file)), in CreateMockTable() local
101 uint32_t id = GetAndWriteNextID(&file_writer); in CreateMockTable()
Dtable_test.cc3342 std::unique_ptr<WritableFileWriter> file_writer( in TEST_F() local
3358 file_writer.get())); in TEST_F()
3367 file_writer->Flush(); in TEST_F()
4053 std::unique_ptr<WritableFileWriter> file_writer( in TEST_P() local
4072 file_writer.get())); in TEST_P()
4082 file_writer->Flush(); in TEST_P()
4236 std::unique_ptr<WritableFileWriter> file_writer( in TEST_P() local
4253 file_writer.get())); in TEST_P()
4265 file_writer->Flush(); in TEST_P()
4347 file_writer.get())); in TEST_P()
[all …]
/rocksdb-6.9/utilities/trace/
Dfile_trace_reader_writer.cc116 std::unique_ptr<WritableFileWriter> file_writer; in NewFileTraceWriter() local
117 file_writer.reset(new WritableFileWriter( in NewFileTraceWriter()
120 trace_writer->reset(new FileTraceWriter(std::move(file_writer))); in NewFileTraceWriter()
Dfile_trace_reader_writer.h36 explicit FileTraceWriter(std::unique_ptr<WritableFileWriter>&& file_writer) in FileTraceWriter() argument
37 : file_writer_(std::move(file_writer)) {} in FileTraceWriter()
/rocksdb-6.9/table/block_based/
Ddata_block_hash_index_test.cc540 std::unique_ptr<WritableFileWriter> file_writer; in TestBoundary() local
553 file_writer.reset( in TestBoundary()
566 file_writer.get())); in TestBoundary()
573 file_writer->Flush(); in TestBoundary()
577 test::GetStringSinkFromLegacyWriter(file_writer.get())->contents().size(), in TestBoundary()
582 test::GetStringSinkFromLegacyWriter(file_writer.get())->contents(), in TestBoundary()
591 test::GetStringSinkFromLegacyWriter(file_writer.get())->contents().size(), in TestBoundary()
/rocksdb-6.9/tools/
Dsst_dump_test.cc56 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in createSST() local
67 file_writer.get())); in createSST()
75 file_writer->Close(); in createSST()
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc282 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in NewDB() local
285 log::Writer log(std::move(file_writer), 0, false); in NewDB()
1357 std::unique_ptr<WritableFileWriter> file_writer( in CreateWAL() local
1360 *new_log = new log::Writer(std::move(file_writer), log_file_num, in CreateWAL()
/rocksdb-6.9/db/compaction/
Dcompaction_job_test.cc274 std::unique_ptr<WritableFileWriter> file_writer(new WritableFileWriter( in NewDB() local
277 log::Writer log(std::move(file_writer), 0, false); in NewDB()