Searched refs:input_queue_ (Results 1 – 6 of 6) sorted by relevance
36 : input_queue_(kDefaultInputIOBufferCapacity), in WebSocketInflater()41 : input_queue_(input_queue_capacity), in WebSocketInflater()72 if (!input_queue_.IsEmpty()) { in AddBytes()74 input_queue_.Push(data, size); in AddBytes()80 input_queue_.Push(&data[size - stream_->avail_in], stream_->avail_in); in AddBytes()148 if (input_queue_.IsEmpty()) in InflateChokedInput()152 while (!input_queue_.IsEmpty()) { in InflateChokedInput()153 std::pair<char*, size_t> top = input_queue_.Top(); in InflateChokedInput()156 input_queue_.Consume(top.second - stream_->avail_in); in InflateChokedInput()
122 InputQueue input_queue_; variable
20 DeleteArray(input_queue_); in ~OptimizingCompilerThread()90 OptimizedCompileJob* job = input_queue_[InputQueueIndex(0)]; in NextInput()268 input_queue_[InputQueueIndex(0)] = job; in QueueForOptimization()274 input_queue_[InputQueueIndex(input_queue_length_)] = job; in QueueForOptimization()
43 input_queue_ = NewArray<OptimizedCompileJob*>(input_queue_capacity_); in OptimizingCompilerThread()116 OptimizedCompileJob** input_queue_; variable
183 input_queue_.push(make_linked_ptr(job_record.release())); in ProcessTask()431 << input_queue_.size() << "] => DEVICE[" in ServiceDeviceTask()446 while (!input_queue_.empty() && !free_input_buffers_.empty()) { in Enqueue()583 DCHECK(!input_queue_.empty()); in EnqueueInputRecord()587 linked_ptr<JobRecord> job_record = input_queue_.front(); in EnqueueInputRecord()588 input_queue_.pop(); in EnqueueInputRecord()692 while (!input_queue_.empty()) in StopDevicePoll()693 input_queue_.pop(); in StopDevicePoll()
145 std::queue<linked_ptr<JobRecord> > input_queue_; variable