Searched refs:next_data_pos_ (Results 1 – 4 of 4) sorted by relevance
174 current_data_pos_ = next_data_pos_; in InitBatchWrites()220 next_data_pos_ = next_op_pos_ + cluster_size_; in InitPos()222 next_data_pos_ = next_op_pos_ + sizeof(CowOperationV2); in InitPos()406 op.source = next_data_pos_; in EmitBlocks()476 op.source = next_data_pos_; in EmitSequenceData()513 auto continue_data_pos = next_data_pos_; in Finalize()569 next_data_pos_ = continue_data_pos; in Finalize()582 info.cow_size = next_data_pos_ + sizeof(footer_); in GetCowSizeInfo()633 current_data_pos_ = next_data_pos_; in FlushCluster()640 !EnsureSpaceAvailable(next_data_pos_ + size)) { in WriteOperation()[all …]
255 next_data_pos_ = GetDataOffset(header_); in OpenForWrite()277 next_data_pos_ = GetDataOffset(header_); in OpenForAppend()284 next_data_pos_ += op.data_length; in OpenForAppend()375 op.set_source(next_data_pos_ + compressed_bytes); in ConstructCowOpCompressedBuffers()485 CHECK_EQ(next_data_pos_ + header_.sequence_data_count * sizeof(uint32_t), in EmitSequenceData()487 next_data_pos_ = GetDataOffset(header_); in EmitSequenceData()510 op.set_source(next_data_pos_ + bytes_written); in FlushCacheOps()701 next_data_pos_ += (header_.op_count - header_.op_count_max) * sizeof(CowOperationV3); in WriteOperation()704 next_data_pos_ += total_data_size; in WriteOperation()724 const auto ret = pwritev(fd_, data.data() + i, chunk, next_data_pos_ + total_written); in WriteOperation()[all …]
73 uint64_t next_data_pos_ = 0; variable
110 uint64_t next_data_pos_ = 0; variable