Searched refs:read_buffer (Results 1 – 3 of 3) sorted by relevance
| /rocksdb-6.9/db/ |
| D | log_reader.cc | 236 Slice read_buffer; in UnmarkEOFInternal() local
237 Status status = file_->Read(remaining, &read_buffer, in UnmarkEOFInternal()
240 size_t added = read_buffer.size(); in UnmarkEOFInternal()
252 if (read_buffer.data() != backing_store_ + eof_offset_) { in UnmarkEOFInternal()
254 memmove(backing_store_ + eof_offset_, read_buffer.data(), in UnmarkEOFInternal()
255 read_buffer.size()); in UnmarkEOFInternal()
|
| D | version_set.cc | 4370 log::Reader* reader, AtomicGroupReadBuffer* read_buffer, in ReadAndRecover() argument
4377 assert(read_buffer != nullptr); in ReadAndRecover()
4394 s = read_buffer->AddEdit(&edit); in ReadAndRecover()
4399 if (read_buffer->IsFull()) { in ReadAndRecover()
4402 for (auto& e : read_buffer->replay_buffer()) { in ReadAndRecover()
4414 read_buffer->Clear(); in ReadAndRecover()
4428 read_buffer->Clear(); in ReadAndRecover()
4498 AtomicGroupReadBuffer read_buffer; in Recover() local
4499 s = ReadAndRecover(&reader, &read_buffer, cf_name_to_options, in Recover()
|
| D | version_set.h | 1127 log::Reader* reader, AtomicGroupReadBuffer* read_buffer,
|