Searched refs:read_head_ (Results 1 – 3 of 3) sorted by relevance
58 : data_(capacity), read_head_(0), valid_bytes_(0) {} in UnixSocketMessageBuffer()69 uint32_t write_head = (read_head_ + valid_bytes_) % data_.size(); in StoreMessage()83 *pdata = &data_[read_head_]; in PeekData()84 if (read_head_ + valid_bytes_ <= data_.size()) { in PeekData()87 return data_.size() - read_head_; in PeekData()92 read_head_ = (read_head_ + size) % data_.size(); in CommitData()98 uint32_t read_head_; variable
34 : read_head_(0), write_head_(0), buffer_size_(buffer_size), buffer_(new char[buffer_size]) { in RecordBuffer()39 size_t read_head = read_head_.load(std::memory_order_relaxed); in GetFreeSize()49 size_t read_head = read_head_.load(std::memory_order_acquire); in AllocWriteSpace()80 size_t read_head = read_head_.load(std::memory_order_relaxed); in GetCurrentRecord()101 size_t read_head = read_head_.load(std::memory_order_relaxed); in MoveToNextRecord()103 read_head_.store(read_head, std::memory_order_release); in MoveToNextRecord()
57 std::atomic_size_t read_head_;