Lines Matching refs:consumer_pos_
72 consumer_pos_ = reinterpret_cast<ConsumerPosition*>(
74 ASSERT(reinterpret_cast<byte*>(consumer_pos_ + 1) <=
76 consumer_pos_->dequeue_chunk_pos = buffer_;
77 consumer_pos_->dequeue_chunk_poll_pos = buffer_ + producer_consumer_distance_;
78 consumer_pos_->dequeue_pos = NULL;
89 if (consumer_pos_->dequeue_pos != NULL) {
90 return consumer_pos_->dequeue_pos;
92 if (*consumer_pos_->dequeue_chunk_poll_pos != kClear) {
93 consumer_pos_->dequeue_pos = consumer_pos_->dequeue_chunk_pos;
94 consumer_pos_->dequeue_end_pos = consumer_pos_->dequeue_pos + chunk_size_;
95 return consumer_pos_->dequeue_pos;
104 consumer_pos_->dequeue_pos += record_size_;
105 if (consumer_pos_->dequeue_pos < consumer_pos_->dequeue_end_pos) return;
107 consumer_pos_->dequeue_pos = NULL;
108 *consumer_pos_->dequeue_chunk_pos = kClear;
109 consumer_pos_->dequeue_chunk_pos += chunk_size_;
110 WrapPositionIfNeeded(&consumer_pos_->dequeue_chunk_pos);
111 consumer_pos_->dequeue_chunk_poll_pos += chunk_size_;
112 WrapPositionIfNeeded(&consumer_pos_->dequeue_chunk_poll_pos);
118 consumer_pos_->dequeue_chunk_poll_pos = consumer_pos_->dequeue_chunk_pos;
