| 3675 | |
| 3676 | template<typename T, typename Traits> |
| 3677 | ConsumerToken::ConsumerToken(ConcurrentQueue<T, Traits> &queue) |
| 3678 | : itemsConsumedFromCurrent(0), currentProducer(nullptr), desiredProducer(nullptr) { |
| 3679 | initialOffset = queue.nextExplicitConsumerId.fetch_add(1, std::memory_order_release); |
| 3680 | lastKnownGlobalOffset = -1; |
| 3681 | } |
| 3682 | |
| 3683 | template<typename T, typename Traits> |
| 3684 | ConsumerToken::ConsumerToken(BlockingConcurrentQueue<T, Traits> &queue) |
nothing calls this directly
no outgoing calls
no test coverage detected