Home
last modified time | relevance | path

Searched refs:Writer (Results 1 – 25 of 34) sorted by relevance

12

/rocksdb-6.9/db/
Dwrite_thread.h75 struct Writer;
78 Writer* leader = nullptr;
87 Writer* writer;
88 Writer* last_writer;
90 explicit Iterator(Writer* w, Writer* last) in Iterator()
115 struct Writer { struct
138 Writer() in Writer() function
177 ~Writer() { in ~Writer() argument
383 Writer write_stall_dummy_;
407 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
[all …]
Dwrite_thread.cc223 bool WriteThread::LinkOne(Writer* w, std::atomic<Writer*>* newest_writer) { in LinkOne()
262 Writer* w = last_writer; in LinkGroup()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
297 Writer* current = from; in FindNextLeader()
439 Writer* w = leader; in EnterAsBatchGroupLeader()
507 Writer* last_writer = leader; in EnterAsMemTableWriter()
513 Writer* w = leader; in EnterAsMemTableWriter()
559 Writer* w = leader; in ExitAsMemTableWriter()
647 Writer dummy; in ExitAsBatchGroupLeader()
754 Writer* newest_writer = w; in ExitUnbatched()
[all …]
Dlog_writer.cc21 Writer::Writer(std::unique_ptr<WritableFileWriter>&& dest, uint64_t log_number, in Writer() function in ROCKSDB_NAMESPACE::log::Writer
34 Writer::~Writer() { in ~Writer()
40 IOStatus Writer::WriteBuffer() { return dest_->Flush(); } in WriteBuffer()
42 IOStatus Writer::Close() { in Close()
51 IOStatus Writer::AddRecord(const Slice& slice) { in AddRecord()
115 bool Writer::TEST_BufferIsEmpty() { return dest_->TEST_BufferIsEmpty(); } in TEST_BufferIsEmpty()
117 IOStatus Writer::EmitPhysicalRecord(RecordType t, const char* ptr, size_t n) { in EmitPhysicalRecord()
Dlog_writer.h69 class Writer {
74 explicit Writer(std::unique_ptr<WritableFileWriter>&& dest,
78 Writer(const Writer&) = delete;
79 void operator=(const Writer&) = delete;
81 ~Writer();
Dforward_iterator_bench.cc73 struct Writer;
78 Writer* writer;
204 struct Writer { struct
205 explicit Writer(std::vector<ShardState>* shard_states, in Writer() function
209 void start() { thread_ = port::Thread(&Writer::run, this); } in start() argument
260 ~Writer() { thread_.join(); } in ~Writer() argument
356 std::deque<Writer> writers; in main()
370 for (Writer& w : writers) { in main()
Dversion_set_test.cc719 log_writer->reset(new log::Writer(std::move(file_writer), 0, false)); in PrepareManifest()
742 std::unique_ptr<log::Writer> log_writer; in NewDB()
962 std::unique_ptr<log::Writer> log_writer_;
1242 std::unique_ptr<log::Writer> log_writer; in TEST_P()
1342 std::unique_ptr<log::Writer>* log_writer) override { in PrepareManifest()
1354 log_writer->reset(new log::Writer(std::move(file_writer), 0, true)); in PrepareManifest()
1373 std::unique_ptr<log::Writer> log_writer_;
1409 std::unique_ptr<log::Writer>* log_writer) override { in PrepareManifest()
1435 std::unique_ptr<log::Writer> log_writer_;
1735 log_writer->reset(new log::Writer(std::move(file_writer), 0, false)); in PrepareManifest()
[all …]
Dwal_manager_test.cc86 current_log_writer_.reset(new log::Writer(std::move(file_writer), 0, false)); in RollTheLog()
118 std::unique_ptr<log::Writer> current_log_writer_;
138 log::Writer writer(std::move(file_writer), 1, in TEST_F()
Dlog_test.cc165 Writer writer_;
693 Writer recycle_writer(std::move(dest_holder), 123, true); in TEST_P()
724 std::unique_ptr<Writer> log_writer_;
750 log_writer_.reset(new Writer(std::move(dest_holder_), 123, GetParam())); in SetupTestEnv()
Dwrite_callback_test.cc211 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
242 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
Dversion_set.h57 class Writer; variable
1119 log::Writer* log);
1183 std::unique_ptr<log::Writer> descriptor_log_;
Djob_context.h164 autovector<log::Writer*> logs_to_free;
Dwrite_batch_internal.h183 static Status InsertInto(WriteThread::Writer* writer, SequenceNumber sequence,
/rocksdb-6.9/utilities/blob_db/
Dblob_log_writer.cc22 Writer::Writer(std::unique_ptr<WritableFileWriter>&& dest, Env* env, in Writer() function in ROCKSDB_NAMESPACE::blob_db::Writer
35 Status Writer::Sync() { in Sync()
42 Status Writer::WriteHeader(BlobLogHeader& header) { in WriteHeader()
59 Status Writer::AppendFooter(BlobLogFooter& footer) { in AppendFooter()
79 Status Writer::AddRecord(const Slice& key, const Slice& val, in AddRecord()
92 Status Writer::AddRecord(const Slice& key, const Slice& val, in AddRecord()
104 void Writer::ConstructBlobHeader(std::string* buf, const Slice& key, in ConstructBlobHeader()
113 Status Writer::EmitPhysicalRecord(const std::string& headerbuf, in EmitPhysicalRecord()
Dblob_log_writer.h34 class Writer {
39 Writer(std::unique_ptr<WritableFileWriter>&& dest, Env* env,
43 Writer(const Writer&) = delete;
44 Writer& operator=(const Writer&) = delete;
46 ~Writer() = default;
Dblob_file.h88 std::shared_ptr<Writer> log_writer_;
210 std::shared_ptr<Writer> GetWriter() const { return log_writer_; } in GetWriter()
Dblob_db_impl.cc713 Writer::ElemType et = Writer::kEtNone; in CreateWriterLocked()
715 et = Writer::kEtFileHdr; in CreateWriterLocked()
717 et = Writer::kEtRecord; in CreateWriterLocked()
725 bfile->log_writer_ = std::make_shared<Writer>( in CreateWriterLocked()
769 std::shared_ptr<Writer>* writer) { in CheckOrCreateWriterLocked()
785 std::shared_ptr<Writer>* writer) { in CreateBlobFileAndWriter()
841 std::shared_ptr<Writer> writer; in SelectBlobFile()
887 std::shared_ptr<Writer> writer; in SelectBlobFileTTL()
1038 Writer::ConstructBlobHeader(&headerbuf, key, value_compressed, expiration); in PutBlobValue()
1287 std::shared_ptr<Writer> writer; in AppendBlob()
Dblob_db_impl.h266 std::shared_ptr<Writer>* writer);
374 std::shared_ptr<Writer>* writer);
Dblob_compaction_filter.h110 mutable std::shared_ptr<Writer> writer_;
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier_file.h74 class Writer {
76 explicit Writer(PersistentCacheTier* const cache) : cache_(cache) {} in Writer() function
77 virtual ~Writer() {} in ~Writer()
181 Writer* writer, const std::string& dir, in WriteableCacheFile()
239 Writer* const writer_ = nullptr; // File writer thread
256 class ThreadedWriter : public Writer {
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc156 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in WriteImpl()
241 log::Writer* log_writer = logs_.back().writer; in WriteImpl()
469 WriteThread::Writer w(write_options, my_batch, callback, log_ref, in PipelinedWriteImpl()
484 log::Writer* log_writer = logs_.back().writer; in PipelinedWriteImpl()
1121 log::Writer* log_writer = logs_.back().writer; in ConcurrentWriteToWAL()
1279 WriteThread::Writer nonmem_w; in SwitchWAL()
1356 WriteThread::Writer nonmem_w; in HandleWriteBufferFull()
1581 WriteThread::Writer nonmem_w; in ScheduleFlushes()
1636 WriteThread::Writer nonmem_w; in SwitchMemtable()
1638 log::Writer* new_log = nullptr; in SwitchMemtable()
[all …]
Ddb_impl_debug.cc36 log::Writer* cur_log_writer = logs_.back().writer; in TEST_WALBufferIsEmpty()
114 WriteThread::Writer nonmem_w; in TEST_SwitchMemtable()
183 auto w = new WriteThread::Writer(); in TEST_BeginWrite()
189 auto writer = reinterpret_cast<WriteThread::Writer*>(w); in TEST_EndWrite()
Ddb_impl.h818 void AddToLogsToFreeQueue(log::Writer* log_writer) { in AddToLogsToFreeQueue()
1214 LogWriterNumber(uint64_t _number, log::Writer* _writer) in LogWriterNumber()
1217 log::Writer* ReleaseWriter() { in ReleaseWriter()
1232 log::Writer* writer; // own
1504 IOStatus WriteToWAL(const WriteBatch& merged_batch, log::Writer* log_writer,
1508 log::Writer* log_writer, uint64_t* log_used,
1688 size_t preallocate_block_size, log::Writer** new_log);
1860 autovector<log::Writer*> logs_to_free_;
1938 std::deque<log::Writer*> logs_to_free_queue_;
Ddb_impl_open.cc285 log::Writer log(std::move(file_writer), 0, false); in NewDB()
1327 size_t preallocate_block_size, log::Writer** new_log) { in CreateWAL()
1360 *new_log = new log::Writer(std::move(file_writer), log_file_num, in CreateWAL()
1431 log::Writer* new_log = nullptr; in Open()
1505 log::Writer* log_writer = impl->logs_.back().writer; in Open()
Ddb_impl.cc1091 WriteThread::Writer w; in SetDBOptions()
1158 log::Writer* cur_log_writer = logs_.back().writer; in FlushWAL()
1184 autovector<log::Writer*, 1> logs_to_sync; in SyncWAL()
1225 for (log::Writer* log : logs_to_sync) { in SyncWAL()
2349 WriteThread::Writer w; in CreateColumnFamilyImpl()
2451 WriteThread::Writer w; in DropColumnFamilyImpl()
3654 WriteThread::Writer w; in WriteOptionsFile()
4093 WriteThread::Writer w; in IngestExternalFiles()
4095 WriteThread::Writer nonmem_w; in IngestExternalFiles()
4346 WriteThread::Writer w; in CreateColumnFamilyWithImport()
[all …]
Ddb_impl_compaction_flush.cc85 autovector<log::Writer*, 1> logs_to_sync; in SyncClosedLogs()
103 for (log::Writer* log : logs_to_sync) { in SyncClosedLogs()
1597 WriteThread::Writer w; in FlushMemTable()
1598 WriteThread::Writer nonmem_w; in FlushMemTable()
1720 WriteThread::Writer w; in AtomicFlushMemTables()
1721 WriteThread::Writer nonmem_w; in AtomicFlushMemTables()

12