| /external/libchrome/base/message_loop/ |
| D | incoming_task_queue.cc | 100 DCHECK(!queue_.empty()); in Peek()
101 return queue_.front(); in Peek()
107 DCHECK(!queue_.empty()); in Pop()
108 PendingTask pending_task = std::move(queue_.front()); in Pop()
109 queue_.pop(); in Pop()
116 return !queue_.empty(); in HasTasks()
155 if (queue_.empty()) { in ReloadFromIncomingQueueIfEmpty()
156 outer_->ReloadWorkQueue(&queue_); in ReloadFromIncomingQueueIfEmpty()
172 queue_.push(std::move(pending_task)); in Push()
177 DCHECK(!queue_.empty()); in Peek()
[all …]
|
| D | incoming_task_queue.h | 168 TaskQueue queue_; variable
192 DelayedTaskQueue queue_;
215 TaskQueue queue_;
|
| /external/webrtc/webrtc/common_audio/ |
| D | swap_queue.h | 83 explicit SwapQueue(size_t size) : queue_(size) { in SwapQueue()
89 : queue_item_verifier_(queue_item_verifier), queue_(size) { in SwapQueue()
94 SwapQueue(size_t size, const T& prototype) : queue_(size, prototype) { in SwapQueue()
102 : queue_item_verifier_(queue_item_verifier), queue_(size, prototype) { in SwapQueue()
127 if (num_elements_ == queue_.size()) { in Insert()
132 swap(*input, queue_[next_write_index_]); in Insert()
135 if (next_write_index_ == queue_.size()) { in Insert()
141 RTC_DCHECK_LT(next_write_index_, queue_.size()); in Insert()
142 RTC_DCHECK_LE(num_elements_, queue_.size()); in Insert()
165 swap(*output, queue_[next_read_index_]); in Remove()
[all …]
|
| /external/libchrome/base/task_scheduler/ |
| D | sequence.cc | 26 queue_.push(std::move(task)); in PushTask()
29 return queue_.size() == 1; in PushTask()
34 DCHECK(!queue_.empty()); in TakeTask()
35 DCHECK(queue_.front().task); in TakeTask()
37 const int priority_index = static_cast<int>(queue_.front().traits.priority()); in TakeTask()
41 return std::move(queue_.front()); in TakeTask()
46 DCHECK(!queue_.empty()); in Pop()
47 DCHECK(!queue_.front().task); in Pop()
48 queue_.pop(); in Pop()
49 return queue_.empty(); in Pop()
[all …]
|
| /external/libchrome/base/threading/ |
| D | thread_collision_warner_unittest.cc | 152 explicit QueueUser(NonThreadSafeQueue* queue) : queue_(queue) {} in TEST()
155 queue_->push(0); in TEST()
156 queue_->pop(); in TEST()
160 NonThreadSafeQueue* queue_; in TEST() member in TEST::QueueUser
209 explicit QueueUser(NonThreadSafeQueue* queue) : queue_(queue) {} in TEST()
212 queue_->push(0); in TEST()
213 queue_->pop(); in TEST()
217 NonThreadSafeQueue* queue_; in TEST() member in TEST::QueueUser
269 : queue_(queue), lock_(lock) {} in TEST()
274 queue_->push(0); in TEST()
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | bufferqueue.cc | 22 for (Buffer* buffer : queue_) { in ~BufferQueue()
32 return queue_.size(); in size()
37 if (queue_.empty()) { in ReadFront()
41 bool was_writable = queue_.size() < capacity_; in ReadFront()
42 Buffer* packet = queue_.front(); in ReadFront()
43 queue_.pop_front(); in ReadFront()
60 if (queue_.size() == capacity_) { in WriteBack()
64 bool was_readable = !queue_.empty(); in WriteBack()
77 queue_.push_back(packet); in WriteBack()
|
| /external/webrtc/webrtc/modules/desktop_capture/ |
| D | screen_capturer_x11.cc | 108 ScreenCaptureFrameQueue queue_; member in webrtc::__anon791a27d30111::ScreenCapturerLinux
238 queue_.MoveToNextFrame(); in Capture()
255 if (!queue_.current_frame()) { in Capture()
258 queue_.ReplaceCurrentFrame(frame.release()); in Capture()
262 DesktopFrame* frame = queue_.current_frame(); in Capture()
310 DesktopFrame* frame = queue_.current_frame()->Share(); in CaptureScreen()
321 if (use_damage_ && queue_.previous_frame()) in CaptureScreen()
327 if (use_damage_ && queue_.previous_frame()) { in CaptureScreen()
360 if (queue_.previous_frame()) { in CaptureScreen()
364 RTC_DCHECK(queue_.previous_frame()->data()); in CaptureScreen()
[all …]
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | message_queue.cc | 20 return queue_.empty(); in IsEmpty()
24 queue_.emplace(std::move(*message)); in Push()
28 DCHECK(!queue_.empty()); in Pop()
29 *message = std::move(queue_.front()); in Pop()
34 DCHECK(!queue_.empty()); in Pop()
35 queue_.pop(); in Pop()
|
| D | message_queue.h | 30 size_t size() const { return queue_.size(); } in size()
35 base::queue<Message> queue_; variable
|
| /external/webrtc/webrtc/modules/audio_processing/transient/ |
| D | moving_moments.cc | 22 queue_(), in MovingMoments()
27 queue_.push(0.0); in MovingMoments()
38 const float old_value = queue_.front(); in CalculateMoments()
39 queue_.pop(); in CalculateMoments()
40 queue_.push(in[i]); in CalculateMoments()
|
| /external/webrtc/webrtc/modules/desktop_capture/win/ |
| D | screen_capturer_win_gdi.cc | 76 queue_.MoveToNextFrame(); in Capture()
95 const DesktopFrame* current_frame = queue_.current_frame(); in Capture()
96 const DesktopFrame* last_frame = queue_.previous_frame(); in Capture()
124 DesktopFrame* frame = queue_.current_frame()->Share(); in Capture()
219 queue_.Reset(); in PrepareCaptureResources()
235 if (!queue_.current_frame() || in CaptureImage()
236 !queue_.current_frame()->size().equals(screen_rect.size())) { in CaptureImage()
248 queue_.ReplaceCurrentFrame(buffer.release()); in CaptureImage()
254 queue_.current_frame()->GetUnderlyingFrame()); in CaptureImage()
|
| D | screen_capturer_win_magnifier.cc | 87 queue_.MoveToNextFrame(); in Capture()
132 const DesktopFrame* current_frame = queue_.current_frame(); in Capture()
133 const DesktopFrame* last_frame = queue_.previous_frame(); in Capture()
160 DesktopFrame* frame = queue_.current_frame()->Share(); in Capture()
390 DesktopFrame* current_frame = queue_.current_frame(); in OnCaptured()
424 if (!queue_.current_frame() || !queue_.current_frame()->size().equals(size)) { in CreateCurrentFrameIfNecessary()
436 queue_.ReplaceCurrentFrame(buffer.release()); in CreateCurrentFrameIfNecessary()
|
| /external/perfetto/src/traced/probes/filesystem/ |
| D | file_scanner.cc | 48 queue_(std::move(root_directories)), in FileScanner()
79 std::string directory = std::move(queue_.back()); in NextDirectory()
80 queue_.pop_back(); in NextDirectory()
107 if (queue_.empty()) in Step()
132 queue_.emplace_back(filepath); in Step()
140 queue_.clear(); in Step()
151 return !current_dir_handle_ && queue_.empty(); in Done()
|
| /external/webrtc/webrtc/modules/utility/source/ |
| D | process_thread_impl.cc | 54 while (!queue_.empty()) { in ~ProcessThreadImpl()
55 delete queue_.front(); in ~ProcessThreadImpl()
56 queue_.pop(); in ~ProcessThreadImpl()
126 queue_.push(task.release()); in PostTask()
220 while (!queue_.empty()) { in Process()
221 ProcessTask* task = queue_.front(); in Process()
222 queue_.pop(); in Process()
|
| /external/v8/src/libplatform/ |
| D | default-worker-threads-task-runner.cc | 16 thread_pool_.push_back(base::make_unique<WorkerThread>(&queue_)); in DefaultWorkerThreadsTaskRunner()
28 queue_.Terminate(); in Terminate()
36 queue_.Append(std::move(task)); in PostTask()
44 queue_.Append(std::move(task)); in PostDelayedTask()
|
| D | worker-thread.cc | 14 : Thread(Options("V8 WorkerThread")), queue_(queue) { in WorkerThread()
25 while (std::unique_ptr<Task> task = queue_->GetNext()) { in Run()
|
| /external/google-breakpad/src/client/ios/ |
| D | BreakpadController.mm | 110 queue_ = dispatch_queue_create("com.google.BreakpadQueue", NULL);
121 dispatch_release(queue_);
143 dispatch_async(queue_, startBlock);
150 dispatch_sync(queue_, ^{
173 dispatch_async(queue_, ^{
236 dispatch_async(queue_, ^{
245 dispatch_async(queue_, ^{
254 dispatch_async(queue_, ^{
262 dispatch_async(queue_, ^{
270 dispatch_async(queue_, ^{
[all …]
|
| /external/v8/src/compiler/ |
| D | control-flow-optimizer.cc | 23 queue_(zone), in ControlFlowOptimizer()
30 while (!queue_.empty()) { in Optimize()
31 Node* node = queue_.front(); in Optimize()
32 queue_.pop(); in Optimize()
50 queue_.push(node); in Enqueue()
|
| D | loop-analysis.cc | 57 queue_(zone), in LoopFinderImpl()
109 NodeDeque queue_; member in v8::internal::compiler::LoopFinderImpl
185 while (!queue_.empty()) { in PropagateBackward()
186 Node* node = queue_.front(); in PropagateBackward()
188 queue_.pop_front(); in PropagateBackward()
303 while (!queue_.empty()) { in PropagateForward()
304 Node* node = queue_.front(); in PropagateForward()
305 queue_.pop_front(); in PropagateForward()
348 queue_.push_back(node); in Queue()
|
| /external/tensorflow/tensorflow/core/summary/ |
| D | summary_file_writer.cc | 143 queue_.emplace_back(std::move(event)); in WriteEvent()
144 if (queue_.size() > max_queue_ || in WriteEvent()
159 for (const std::unique_ptr<Event>& e : queue_) { in InternalFlush()
162 queue_.clear(); in InternalFlush()
175 std::vector<std::unique_ptr<Event>> queue_ GUARDED_BY(mu_);
|
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/test/ |
| D | packet_sender.cc | 172 for (Packet* packet : queue_) in ~PacedVideoSender()
262 queue_.merge(*batch, DereferencingComparator<Packet>); in QueuePackets()
263 if (queue_.empty()) { in QueuePackets()
266 Packets::iterator it = queue_.begin(); in QueuePackets()
267 for (; it != queue_.end(); ++it) { in QueuePackets()
273 to_transfer.splice(to_transfer.begin(), queue_, queue_.begin(), it); in QueuePackets()
297 queue_.push_back(media_packet); in TimeToSendPacket()
|
| /external/perfetto/include/perfetto/base/ |
| D | circular_queue.h | 60 : queue_(queue), in Iterator()
72 PERFETTO_DCHECK(generation_ == queue_->generation());
74 return queue_->Get(pos_);
159 PERFETTO_DCHECK(pos_ <= queue_->end_); in Add()
162 CircularQueue* queue_; variable
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | shared_batch_scheduler.h | 345 size_t max_task_size() const override { return queue_->max_task_size(); } in max_task_size()
353 Queue<TaskType>* queue_; variable
679 : scheduler_(scheduler), queue_(queue) {} in QueueHandle()
683 queue_->CloseAndWaitUntilEmpty(); in ~QueueHandle()
688 return queue_->Schedule(task); in Schedule()
693 return queue_->NumEnqueuedTasks(); in NumEnqueuedTasks()
698 return queue_->SchedulingCapacity(); in SchedulingCapacity()
|
| /external/webrtc/webrtc/examples/peerconnection/server/ |
| D | peer_channel.cc | 136 assert(queue_.size() == 0); in QueueResponse()
151 queue_.push(qr); in QueueResponse()
157 if (ds && !queue_.empty()) { in SetWaitingSocket()
159 const QueuedResponse& response = queue_.front(); in SetWaitingSocket()
162 queue_.pop(); in SetWaitingSocket()
|
| /external/tensorflow/tensorflow/core/profiler/internal/ |
| D | traceme_recorder.cc | 170 void Record(TraceMeRecorder::Event&& event) { queue_.Push(std::move(event)); } in Record()
174 return {info_, queue_.Consume()}; in Clear()
179 EventQueue queue_; member in tensorflow::profiler::__anond292cb750111::ThreadLocalRecorder
|