| /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/libmojo/mojo/public/cpp/bindings/tests/ |
| D | message_queue.cc | 17 while (!queue_.empty()) in ~MessageQueue()
22 return queue_.empty(); in IsEmpty()
26 queue_.push(new Message()); in Push()
27 message->MoveTo(queue_.back()); in Push()
31 DCHECK(!queue_.empty()); in Pop()
32 queue_.front()->MoveTo(message); in Pop()
37 DCHECK(!queue_.empty()); in Pop()
38 delete queue_.front(); in Pop()
39 queue_.pop(); in Pop()
|
| D | message_queue.h | 32 size_t size() const { return queue_.size(); } in size()
37 std::queue<Message*> queue_; variable
|
| D | router_test_util.cc | 39 : queue_(queue), closure_(closure) {} in MessageAccumulator()
44 queue_->Push(message); in Accept()
|
| D | connector_unittest.cc | 33 queue_.Push(message); in Accept()
39 bool IsEmpty() const { return queue_.IsEmpty(); } in IsEmpty()
41 void Pop(Message* message) { queue_.Pop(message); } in Pop()
45 size_t size() const { return queue_.size(); } in size()
48 MessageQueue queue_; member in mojo::test::__anon293efb0c0111::MessageAccumulator
|
| /external/libchrome/base/task_scheduler/ |
| D | sequence.cc | 23 queue_.push(std::move(task)); in PushTask()
26 return queue_.size() == 1; in PushTask()
32 if (queue_.empty()) in PeekTask()
35 return queue_.front().get(); in PeekTask()
40 DCHECK(!queue_.empty()); in PopTask()
43 static_cast<int>(queue_.front()->traits.priority()); in PopTask()
47 queue_.pop(); in PopTask()
48 return queue_.empty(); in PopTask()
57 DCHECK(!queue_.empty()); in GetSortKey()
70 next_task_sequenced_time = queue_.front()->sequenced_time; in GetSortKey()
|
| /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/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/modules/desktop_capture/ |
| D | screen_capturer_x11.cc | 108 ScreenCaptureFrameQueue queue_; member in webrtc::__anona3bc27320111::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 …]
|
| D | screen_capturer_mac.mm | 242 ScreenCaptureFrameQueue queue_;
363 queue_.Reset();
391 queue_.MoveToNextFrame();
412 if (!queue_.current_frame())
413 queue_.ReplaceCurrentFrame(CreateFrame());
415 DesktopFrame* current_frame = queue_.current_frame();
439 DesktopFrame* new_frame = queue_.current_frame()->Share();
505 if (queue_.previous_frame()) {
520 CopyRect(queue_.previous_frame()->data() + y_offset,
589 if (queue_.previous_frame()) {
[all …]
|
| /external/drm_hwcomposer/ |
| D | queue_worker.h | 43 return !queue_.empty(); in IsWorkPending()
80 std::queue<std::unique_ptr<T>> queue_;
114 auto wait_func = [&] { return !queue_.empty(); }; in Routine()
129 if (!queue_.empty()) { in Routine()
130 workitem = std::move(queue_.front()); in Routine()
131 queue_.pop(); in Routine()
144 auto wait_func = [&] { return queue_.size() < max_queue_size_; }; in QueueWork()
149 queue_.push(std::move(workitem)); in QueueWork()
|
| /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/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/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 | liveness-analyzer.cc | 22 queue_(zone) {} in LivenessAnalyzer()
52 queue_.push(block); in Queue()
64 DCHECK(queue_.empty()); in Run()
72 while (!queue_.empty()) { in Run()
73 LivenessAnalyzerBlock* block = queue_.front(); in Run()
74 queue_.pop(); in Run()
|
| 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()
|
| D | scheduler.cc | 222 queue_(zone), in CFGBuilder()
235 while (!queue_.empty()) { // Breadth-first backwards traversal. in Run()
236 Node* node = queue_.front(); in Run()
237 queue_.pop(); in Run()
260 while (!queue_.empty()) { // Breadth-first backwards traversal. in Run()
261 Node* node = queue_.front(); in Run()
262 queue_.pop(); in Run()
298 queue_.push(node); in Queue()
561 DCHECK(queue_.empty()); in ResetDataStructures()
569 ZoneQueue<Node*> queue_; // Queue used for breadth-first traversal. member in v8::internal::compiler::CFGBuilder
[all …]
|
| /external/libchrome/base/files/ |
| D | file_path_watcher_fsevents.cc | 72 : queue_(dispatch_queue_create( in FilePathWatcherFSEvents()
100 dispatch_async(queue_, ^{ in Watch()
113 dispatch_sync(queue_, ^{ in Cancel()
146 dispatch_async(watcher->queue_, ^{ in FSEventsCallback()
234 FSEventStreamSetDispatchQueue(fsevent_stream_, queue_); in UpdateEventStream()
|
| /external/v8/src/libplatform/ |
| D | worker-thread.cc | 14 : Thread(Options("V8 WorkerThread")), queue_(queue) { in WorkerThread()
25 while (Task* task = queue_->GetNext()) { in Run()
|
| D | default-platform.cc | 58 queue_.Terminate(); in ~DefaultPlatform()
104 thread_pool_.push_back(new WorkerThread(&queue_)); in EnsureInitialized()
187 queue_.Append(task); in CallOnBackgroundThread()
|
| /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/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()
|