| /rocksdb-6.9/env/ |
| D | env_basic_test.cc | 145 ASSERT_OK(writable_file->Close()); in TEST_P()
146 writable_file.reset(); in TEST_P()
161 ASSERT_OK(writable_file->Close()); in TEST_P()
162 writable_file.reset(); in TEST_P()
165 ASSERT_OK(writable_file->Close()); in TEST_P()
166 writable_file.reset(); in TEST_P()
219 writable_file.reset(); in TEST_P()
252 ASSERT_OK(writable_file->Sync()); in TEST_P()
255 writable_file.reset(); in TEST_P()
272 writable_file.reset(); in TEST_P()
[all …]
|
| D | mock_env_test.cc | 32 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
33 ASSERT_OK(env_->NewWritableFile(kFileName, &writable_file, soptions_)); in TEST_F()
34 ASSERT_OK(writable_file->Append(kGood)); in TEST_F()
35 ASSERT_TRUE(writable_file->GetFileSize() == kGood.size()); in TEST_F()
46 ASSERT_OK(writable_file->Fsync()); in TEST_F()
53 ASSERT_OK(writable_file->Append(kCorrupted)); in TEST_F()
54 ASSERT_TRUE(writable_file->GetFileSize() == kGood.size() + kCorrupted.size()); in TEST_F()
|
| D | env.cc | 459 std::unique_ptr<WritableFile> writable_file; in NewEnvLogger() local
460 const auto status = env->NewWritableFile(fname, &writable_file, options); in NewEnvLogger()
466 NewLegacyWritableFileWrapper(std::move(writable_file)), fname, options, in NewEnvLogger()
|
| D | env_test.cc | 860 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
865 ASSERT_OK(env_->NewWritableFile(ift.name() + "/f", &writable_file, options)); in TEST_F()
871 ASSERT_OK(writable_file->PositionedAppend(data_a, 0U)); in TEST_F()
875 ASSERT_OK(writable_file->PositionedAppend(data_b, kBlockSize)); in TEST_F()
876 ASSERT_OK(writable_file->Close()); in TEST_F()
|
| /rocksdb-6.9/utilities/ |
| D | env_mirror_test.cc | 36 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
49 writable_file.reset(); in TEST_F()
69 ASSERT_OK(writable_file->Append("abc")); in TEST_F()
70 writable_file.reset(); in TEST_F()
125 writable_file.reset(); in TEST_F()
170 ASSERT_OK(writable_file->Sync()); in TEST_F()
171 ASSERT_OK(writable_file->Flush()); in TEST_F()
172 ASSERT_OK(writable_file->Close()); in TEST_F()
173 writable_file.reset(); in TEST_F()
187 ASSERT_OK(writable_file->Append("foo")); in TEST_F()
[all …]
|
| D | env_librados_test.cc | 124 writable_file.reset(); in TEST_F()
137 writable_file.reset(); in TEST_F()
184 writable_file.reset(); in TEST_F()
238 ASSERT_OK(writable_file->Sync()); in TEST_F()
239 ASSERT_OK(writable_file->Flush()); in TEST_F()
241 writable_file.reset(); in TEST_F()
258 writable_file.reset(); in TEST_F()
294 writable_file.reset(); in TEST_F()
328 writable_file.reset(); in TEST_F()
823 writable_file.reset(); in TEST_F()
[all …]
|
| D | env_timed_test.cc | 23 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
24 timed_env->NewWritableFile("f", &writable_file, EnvOptions()); in TEST_F()
|
| /rocksdb-6.9/table/cuckoo/ |
| D | cuckoo_table_builder_test.cc | 166 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
209 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
259 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
308 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
363 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
414 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
458 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
503 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
550 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
596 std::unique_ptr<WritableFile> writable_file; in TEST_F() local
[all …]
|
| D | cuckoo_table_reader_test.cc | 92 std::unique_ptr<WritableFile> writable_file; in CreateCuckooFileAndCheckReader() local
93 ASSERT_OK(env->NewWritableFile(fname, &writable_file, env_options)); in CreateCuckooFileAndCheckReader()
95 NewLegacyWritableFileWrapper(std::move(writable_file)), fname, in CreateCuckooFileAndCheckReader()
423 std::unique_ptr<WritableFile> writable_file; in WriteFile() local
424 ASSERT_OK(env->NewWritableFile(fname, &writable_file, env_options)); in WriteFile()
426 NewLegacyWritableFileWrapper(std::move(writable_file)), fname, in WriteFile()
|
| /rocksdb-6.9/logging/ |
| D | env_logger.h | 30 EnvLogger(std::unique_ptr<FSWritableFile>&& writable_file,
34 file_(std::move(writable_file), fname, options, env), in Logger()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_job.cc | 1478 std::unique_ptr<FSWritableFile> writable_file; in OpenCompactionOutputFile() local
1484 Status s = NewWritableFile(fs_, fname, &writable_file, file_options_); in OpenCompactionOutputFile()
1527 writable_file->SetIOPriority(Env::IOPriority::IO_LOW); in OpenCompactionOutputFile()
1528 writable_file->SetWriteLifeTimeHint(write_hint_); in OpenCompactionOutputFile()
1529 writable_file->SetPreallocationBlockSize(static_cast<size_t>( in OpenCompactionOutputFile()
1534 new WritableFileWriter(std::move(writable_file), fname, file_options_, in OpenCompactionOutputFile()
|
| /rocksdb-6.9/db/ |
| D | table_properties_collector_test.cc | 288 static_cast<LegacyWritableFileWrapper*>(writer->writable_file()); in TestCustomizedTablePropertiesCollector()
429 static_cast<LegacyWritableFileWrapper*>(writable->writable_file()); in TestInternalKeyPropertiesCollector()
|
| D | log_test.cc | 755 std::unique_ptr<WritableFile> writable_file; in SetupTestEnv() local
757 s = env_->NewWritableFile(log_file_, &writable_file, env_options_); in SetupTestEnv()
761 NewLegacyWritableFileWrapper(std::move(writable_file)), log_file_, in SetupTestEnv()
|
| /rocksdb-6.9/file/ |
| D | writable_file_writer.h | 154 FSWritableFile* writable_file() const { return writable_file_.get(); } in writable_file() function
|
| /rocksdb-6.9/util/ |
| D | file_reader_writer_test.cc | 225 static_cast<LegacyWritableFileWrapper*>(writer->writable_file()); in TEST_F()
|
| /rocksdb-6.9/test_util/ |
| D | testutil.h | 385 static_cast<LegacyWritableFileWrapper*>(writer->writable_file()); in GetStringSinkFromLegacyWriter()
|
| /rocksdb-6.9/table/block_based/ |
| D | block_based_table_builder.cc | 493 table_options.block_cache_compressed.get(), file->writable_file(), in BlockBasedTableBuilder()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.cc | 1202 if (!it->writer->file()->writable_file()->IsSyncThreadSafe()) { in SyncWAL()
|