Searched refs:read_head (Results 1 – 2 of 2) sorted by relevance
39 size_t read_head = read_head_.load(std::memory_order_relaxed); in GetFreeSize() local40 size_t write_tail = read_head > 0 ? read_head - 1 : buffer_size_ - 1; in GetFreeSize()49 size_t read_head = read_head_.load(std::memory_order_acquire); in AllocWriteSpace() local50 size_t write_tail = read_head > 0 ? read_head - 1 : buffer_size_ - 1; in AllocWriteSpace()80 size_t read_head = read_head_.load(std::memory_order_relaxed); in GetCurrentRecord() local81 if (read_head == write_head) { in GetCurrentRecord()85 if (read_head > write_head) { in GetCurrentRecord()86 if (buffer_size_ - read_head < sizeof(header) || in GetCurrentRecord()87 (memcpy(&header, buffer_.get() + read_head, sizeof(header)) && header.size == 0)) { in GetCurrentRecord()89 cur_read_record_size_ += buffer_size_ - read_head; in GetCurrentRecord()[all …]
237 uint64_t read_head = mmap_metadata_page_->data_tail; in GetAvailableMmapDataSize() local238 if (write_head == read_head) { in GetAvailableMmapDataSize()244 data_pos = read_head & (mmap_data_buffer_size_ - 1); in GetAvailableMmapDataSize()245 return write_head - read_head; in GetAvailableMmapDataSize()