• Home
  • Raw
  • Download

Lines Matching refs:consumer_pos_

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