Searched refs:bufsink_ (Results 1 – 8 of 8) sorted by relevance
79 if (!reader_->ReadData(*cow_op, &bufsink_)) { in ProcessReplaceOp()88 void* buffer = bufsink_.GetPayloadBuffer(BLOCK_SZ); in ReadFromSourceDevice()139 void* buffer = bufsink_.GetPayloadBuffer(BLOCK_SZ); in ProcessZeroOp()236 bufsink_.Initialize(buf_size); in InitializeBufsink()241 xorsink_.Initialize(&bufsink_, BLOCK_SZ); in Init()292 void* buf = bufsink_.GetPayloadBufPtr(); in WriteDmUserPayload()295 buf = bufsink_.GetBufPtr(); in WriteDmUserPayload()339 bufsink_.ResetBufferOffset(); in ReadAlignedSector()384 bufsink_.UpdateBufferOffset(ret); in ReadAlignedSector()434 bufsink_.ResetBufferOffset(); in ReadUnalignedSector()[all …]
264 bufsink_.ResetBufferOffset(); in ReadAheadAsyncIO()440 uint8_t* xor_data = reinterpret_cast<uint8_t*>((char*)bufsink_.GetPayloadBufPtr() + in ProcessXorData()457 bufsink_.ResetBufferOffset(); in ProcessXorData()470 if (!reader_->ReadData(*xor_op, &bufsink_)) { in ReadXorData()477 bufsink_.UpdateBufferOffset(BLOCK_SZ); in ReadXorData()495 bufsink_.ResetBufferOffset(); in ReadAheadSyncIO()702 bufsink_.Initialize(PAYLOAD_BUFFER_SZ * 2); in InitializeIouring()
115 bufsink_.UpdateBufferOffset(BLOCK_SZ); in MergeReplaceZeroOps()121 int ret = TEMP_FAILURE_RETRY(pwrite(base_path_merge_fd_.get(), bufsink_.GetPayloadBufPtr(), in MergeReplaceZeroOps()148 bufsink_.ResetBufferOffset(); in MergeReplaceZeroOps()
160 BufferSink bufsink_; variable270 BufferSink bufsink_; variable
82 void* buffer = bufsink_.GetPayloadBuffer(BLOCK_SZ); in ConstructKernelCowHeader()98 if (!reader_->ReadData(*cow_op, &bufsink_)) { in ProcessReplaceOp()107 void* buffer = bufsink_.GetPayloadBuffer(BLOCK_SZ); in ReadFromBaseDevice()128 void* buffer = bufsink_.GetPayloadBuffer(BLOCK_SZ); in GetReadAheadPopulatedBuffer()224 bufsink_.ResetBufferOffset(); in ReadUnalignedSector()337 bufsink_.UpdateBufferOffset(BLOCK_SZ); in ReadData()341 bufsink_.ResetBufferOffset(); in ReadData()363 void* buffer = bufsink_.GetPayloadBuffer(size); in ZerofillDiskExceptions()612 void* buf = bufsink_.GetPayloadBufPtr(); in WriteDmUserPayload()615 buf = bufsink_.GetBufPtr(); in WriteDmUserPayload()[all …]
192 BufferSink bufsink_; variable
63 bufsink_ = sink; in Initialize()84 uint8_t* buff = reinterpret_cast<uint8_t*>(bufsink_->GetPayloadBuffer(len + returned_)); in ReturnData()
55 BufferSink* bufsink_;