Lines Matching refs:record
82 bool TransactionLogIteratorImpl::RestrictedRead(Slice* record) { in RestrictedRead() argument
87 return current_log_reader_->ReadRecord(record, &scratch_); in RestrictedRead()
92 Slice record; in SeekToStartSequence() local
105 while (RestrictedRead(&record)) { in SeekToStartSequence()
106 if (record.size() < WriteBatchInternal::kHeader) { in SeekToStartSequence()
108 record.size(), Status::Corruption("very small log record")); in SeekToStartSequence()
111 UpdateCurrentWriteBatch(record); in SeekToStartSequence()
156 Slice record; in NextImpl() local
167 while (RestrictedRead(&record)) { in NextImpl()
168 if (record.size() < WriteBatchInternal::kHeader) { in NextImpl()
170 record.size(), Status::Corruption("very small log record")); in NextImpl()
177 UpdateCurrentWriteBatch(record); in NextImpl()
224 void TransactionLogIteratorImpl::UpdateCurrentWriteBatch(const Slice& record) { in UpdateCurrentWriteBatch() argument
226 WriteBatchInternal::SetContents(batch.get(), record); in UpdateCurrentWriteBatch()