Searched refs:read_head (Results 1 – 2 of 2) sorted by relevance
41 size_t read_head = read_head_.load(std::memory_order_relaxed); in GetFreeSize() local42 size_t write_tail = read_head > 0 ? read_head - 1 : buffer_size_ - 1; in GetFreeSize()51 size_t read_head = read_head_.load(std::memory_order_acquire); in AllocWriteSpace() local52 size_t write_tail = read_head > 0 ? read_head - 1 : buffer_size_ - 1; in AllocWriteSpace()82 size_t read_head = read_head_.load(std::memory_order_relaxed); in GetCurrentRecord() local83 if (read_head == write_head) { in GetCurrentRecord()87 if (read_head > write_head) { in GetCurrentRecord()88 if (buffer_size_ - read_head < sizeof(header) || in GetCurrentRecord()89 (memcpy(&header, buffer_.get() + read_head, sizeof(header)) && header.size == 0)) { in GetCurrentRecord()91 cur_read_record_size_ += buffer_size_ - read_head; in GetCurrentRecord()[all …]
244 uint64_t read_head = mmap_metadata_page_->data_tail; in GetAvailableMmapDataSize() local247 if (write_head <= read_head) { in GetAvailableMmapDataSize()253 data_pos = read_head & (mmap_data_buffer_size_ - 1); in GetAvailableMmapDataSize()254 return write_head - read_head; in GetAvailableMmapDataSize()296 uint64_t read_head = mmap_metadata_page_->aux_tail; in GetAvailableAuxData() local297 if (write_head <= read_head) { in GetAvailableAuxData()303 size_t data_pos = read_head & (aux_buffer_size_ - 1); in GetAvailableAuxData()304 size_t data_size = write_head - read_head; in GetAvailableAuxData()314 return read_head; in GetAvailableAuxData()