Searched refs:buffer_state (Results 1 – 3 of 3) sorted by relevance
124 buffer_state_ = &metadata_header_->buffer_state; in ImportBuffer()256 uint64_t buffer_state = buffer_state_->load(); in LocalAcquire() local257 if (!BufferHubDefs::IsBufferPosted(buffer_state, buffer_state_bit())) { in LocalAcquire()260 id(), buffer_state, buffer_state_bit()); in LocalAcquire()336 uint64_t buffer_state = buffer_state_->load(); in LocalRelease() local337 if (!BufferHubDefs::IsBufferAcquired(buffer_state)) { in LocalRelease()339 id(), buffer_state); in LocalRelease()598 uint64_t buffer_state = buffer_state_->load(); in LocalPost() local599 if (!BufferHubDefs::IsBufferGained(buffer_state)) { in LocalPost()601 id(), buffer_state); in LocalPost()[all …]
79 new (&metadata_header_->buffer_state) std::atomic<uint64_t>(0); in ProducerChannel()515 const uint64_t buffer_state = buffer_state_->load(); in RemoveConsumer() local516 if (BufferHubDefs::IsBufferPosted(buffer_state) || in RemoveConsumer()517 BufferHubDefs::IsBufferAcquired(buffer_state)) { in RemoveConsumer()524 if (BufferHubDefs::IsBufferReleased(buffer_state) || in RemoveConsumer()525 BufferHubDefs::IsBufferGained(buffer_state)) { in RemoveConsumer()
38 static inline void ModifyBufferState(std::atomic<uint64_t>* buffer_state, in ModifyBufferState() argument43 old_state = buffer_state->load(); in ModifyBufferState()45 } while (!buffer_state->compare_exchange_weak(old_state, new_state)); in ModifyBufferState()69 std::atomic<uint64_t> buffer_state; member