Searched refs:read_head (Results 1 – 2 of 2) sorted by relevance
40 size_t read_head = read_head_.load(std::memory_order_relaxed); in GetFreeSize() local41 size_t write_tail = read_head > 0 ? read_head - 1 : buffer_size_ - 1; in GetFreeSize()50 size_t read_head = read_head_.load(std::memory_order_acquire); in AllocWriteSpace() local51 size_t write_tail = read_head > 0 ? read_head - 1 : buffer_size_ - 1; in AllocWriteSpace()81 size_t read_head = read_head_.load(std::memory_order_relaxed); in GetCurrentRecord() local82 if (read_head == write_head) { in GetCurrentRecord()86 if (read_head > write_head) { in GetCurrentRecord()87 if (buffer_size_ - read_head < sizeof(header) || in GetCurrentRecord()88 (memcpy(&header, buffer_.get() + read_head, sizeof(header)) && header.size == 0)) { in GetCurrentRecord()90 cur_read_record_size_ += buffer_size_ - read_head; in GetCurrentRecord()[all …]
236 uint64_t read_head = mmap_metadata_page_->data_tail; in GetAvailableMmapDataSize() local239 if (write_head <= read_head) { in GetAvailableMmapDataSize()245 data_pos = read_head & (mmap_data_buffer_size_ - 1); in GetAvailableMmapDataSize()246 return write_head - read_head; in GetAvailableMmapDataSize()288 uint64_t read_head = mmap_metadata_page_->aux_tail; in GetAvailableAuxData() local289 if (write_head <= read_head) { in GetAvailableAuxData()295 size_t data_pos = read_head & (aux_buffer_size_ - 1); in GetAvailableAuxData()296 size_t data_size = write_head - read_head; in GetAvailableAuxData()306 return read_head; in GetAvailableAuxData()