Searched refs:log_writer_ (Results 1 – 5 of 5) sorted by relevance
948 log_writer_.reset(); in TearDown()1380 log_writer_.reset(); in TEST_F()1443 log_writer_.reset(); in TEST_P()1484 s = log_writer_->AddRecord(record); in TEST_P()1487 log_writer_.reset(); in TEST_P()1533 log_writer_.reset(); in TEST_P()1590 log_writer_.reset(); in TEST_P()1646 log_writer_.reset(); in TEST_P()1905 log_writer_.reset(); in TEST_F()1956 log_writer_.reset(); in TEST_F()[all …]
724 std::unique_ptr<Writer> log_writer_; member in ROCKSDB_NAMESPACE::log::RetriableLogTest738 log_writer_(nullptr), in RetriableLogTest()750 log_writer_.reset(new Writer(std::move(dest_holder_), 123, GetParam())); in SetupTestEnv()751 assert(log_writer_ != nullptr); in SetupTestEnv()782 auto file = test::GetStringSinkFromLegacyWriter(log_writer_->file()); in contents()787 void Encode(const std::string& msg) { log_writer_->AddRecord(Slice(msg)); } in Encode()
96 expiration_range_.second, (!!log_writer_), (!!ra_file_reader_)); in DumpState()120 Status s = log_writer_->AppendFooter(footer); in WriteFooterAndCloseLocked()127 log_writer_.reset(); in WriteFooterAndCloseLocked()173 if (log_writer_.get()) { in Fsync()174 s = log_writer_->Sync(); in Fsync()
88 std::shared_ptr<Writer> log_writer_; variable210 std::shared_ptr<Writer> GetWriter() const { return log_writer_; } in GetWriter()
725 bfile->log_writer_ = std::make_shared<Writer>( in CreateWriterLocked()728 bfile->log_writer_->last_elem_type_ = et; in CreateWriterLocked()