Searched refs:writer_ (Results 1 – 9 of 9) sorted by relevance
| /rocksdb-6.9/trace_replay/ |
| D | block_cache_tracer.cc | 443 BlockCacheTracer::BlockCacheTracer() { writer_.store(nullptr); } in BlockCacheTracer()
451 if (writer_.load()) { in StartTrace()
456 writer_.store( in StartTrace()
458 return writer_.load()->WriteHeader(); in StartTrace()
463 if (!writer_.load()) { in EndTrace()
466 delete writer_.load(); in EndTrace()
467 writer_.store(nullptr); in EndTrace()
474 if (!writer_.load() || !ShouldTrace(block_key, trace_options_)) { in WriteBlockAccess()
478 if (!writer_.load()) { in WriteBlockAccess()
481 return writer_.load()->WriteBlockAccess(record, block_key, cf_name, in WriteBlockAccess()
[all …]
|
| D | block_cache_tracer.h | 276 return writer_.load(std::memory_order_relaxed); in is_tracing_enabled()
290 std::atomic<BlockCacheTraceWriter*> writer_; variable
|
| /rocksdb-6.9/db/ |
| D | log_test.cc | 144 auto dest = test::GetStringSinkFromLegacyWriter(writer_.file()); in dest_contents()
150 auto dest = test::GetStringSinkFromLegacyWriter(writer_.file()); in dest_contents()
165 Writer writer_; member in ROCKSDB_NAMESPACE::log::LogTest
194 writer_.AddRecord(Slice(msg)); in Write()
223 auto dest = test::GetStringSinkFromLegacyWriter(writer_.file()); in ShrinkSize()
729 std::unique_ptr<WritableFileWriter> writer_; member in ROCKSDB_NAMESPACE::log::RetriableLogTest
742 writer_(nullptr), in RetriableLogTest()
760 writer_.reset(new WritableFileWriter( in SetupTestEnv()
763 assert(writer_ != nullptr); in SetupTestEnv()
790 writer_->Append(data); in Write()
[all …]
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_compaction_filter.cc | 155 assert(writer_); in OpenNewBlobFileIfNeeded()
163 /* has_ttl */ false, ExpirationRange(), "GC", &blob_file_, &writer_); in OpenNewBlobFileIfNeeded()
173 assert(writer_); in OpenNewBlobFileIfNeeded()
212 assert(writer_); in WriteBlobToNewFile()
214 const Status s = writer_->AddRecord(key, blob, kNoExpiration, &new_key_offset, in WriteBlobToNewFile()
|
| D | blob_compaction_filter.h | 110 mutable std::shared_ptr<Writer> writer_; variable
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | block_cache_tier.h | 49 writer_(this, opt_.writer_qdepth, static_cast<size_t>(opt_.writer_dispatch_size)) { in BlockCacheTier()
148 ThreadedWriter writer_; // Writer threads variable
|
| D | block_cache_tier_file.h | 186 writer_(writer), in WriteableCacheFile()
239 Writer* const writer_ = nullptr; // File writer thread variable
|
| D | block_cache_tier.cc | 128 writer_.Stop(); in Close()
331 new WriteableCacheFile(opt_.env, &buffer_allocator_, &writer_, in NewCacheFile()
|
| D | block_cache_tier_file.cc | 420 writer_->Write(file_.get(), buf, file_off, in DispatchBuffer()
|