Searched refs:pop_from_ (Results 1 – 4 of 4) sorted by relevance
51 if (is_queue_finished_[pop_from_]) { in Pop()56 RETURN_IF_NOT_OK(queues_[pop_from_]->PopFront(result)); in Pop()58 is_queue_finished_[pop_from_] = true; in Pop()62 int32_t nextQueueIndex = (pop_from_ + offset) % num_producers_; in Pop()64 pop_from_ = nextQueueIndex; in Pop()
54 if (is_queue_finished_[pop_from_]) { in Pop()59 RETURN_IF_NOT_OK(queues_[pop_from_]->PopFront(result)); in Pop()61 is_queue_finished_[pop_from_] = true; in Pop()65 int32_t nextQueueIndex = (pop_from_ + offset) % num_producers_; in Pop()67 pop_from_ = nextQueueIndex; in Pop()
83 pop_from_ = 0; in Connector()103 RETURN_IF_NOT_OK(queues_[pop_from_]->PopFront(result)); in Pop()104 pop_from_ = (pop_from_ + 1) % num_producers_; in Pop()144 pop_from_ = 0; in Reset()198 int32_t pop_from_; variable
80 RETURN_IF_NOT_OK(queues_[pop_from_]->PopFront(result));85 pop_from_ = (pop_from_ + 1) % num_producers_;