Searched refs:buffer_state_ (Results 1 – 6 of 6) sorted by relevance
94 buffer_state_ = new (&metadata_header_->bufferState) std::atomic<uint32_t>(0); in InitializeBuffer()167 buffer_state_->load(std::memory_order_acquire)); in ~ProducerChannel()184 buffer_state_->load(std::memory_order_acquire), in GetBufferInfo()243 buffer_id(), buffer_state_->load(std::memory_order_acquire)); in OnGetBuffer()299 buffer_state_->fetch_and(~consumer_state_mask, std::memory_order_release); in RemoveConsumerClientMask()334 buffer_state_->load(std::memory_order_acquire); in CreateConsumer()350 while (!buffer_state_->compare_exchange_weak( in CreateConsumer()374 buffer_state_->load(std::memory_order_acquire), in CreateConsumer()396 buffer_state_->load(std::memory_order_acquire)); in OnProducerPost()542 buffer_state_->store(0U); in OnConsumerRelease()[all …]
40 buffer_state_->load(std::memory_order_acquire); in LocalAcquire()52 while (!buffer_state_->compare_exchange_weak( in LocalAcquire()146 buffer_state_->load(std::memory_order_acquire); in LocalRelease()152 while (!buffer_state_->compare_exchange_weak( in LocalRelease()
84 buffer_state_->load(std::memory_order_acquire); in LocalPost()96 while (!buffer_state_->compare_exchange_weak( in LocalPost()165 buffer_state_->load(std::memory_order_acquire); in LocalGain()186 while (!buffer_state_->compare_exchange_weak( in LocalGain()
125 buffer_state_ = &metadata_header_->bufferState; in ImportBuffer()128 id(), buffer_state_->load(std::memory_order_acquire)); in ImportBuffer()
77 return buffer_state_->load(std::memory_order_acquire); in buffer_state()136 std::atomic<uint32_t>* buffer_state_ = nullptr; variable
46 return buffer_state_->load(std::memory_order_acquire); in buffer_state()82 std::atomic<uint32_t>* buffer_state_ = nullptr; variable