| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| message_queue.cc | 17 while (!queue_.empty())
22 return queue_.empty();
26 queue_.push(new Message());
27 message->MoveTo(queue_.back());
31 DCHECK(!queue_.empty());
32 queue_.front()->MoveTo(message);
37 DCHECK(!queue_.empty());
38 delete queue_.front();
39 queue_.pop();
|
| message_queue.h | 32 size_t size() const { return queue_.size(); }
37 std::queue<Message*> queue_; member in class:mojo::test::MessageQueue
|
| /external/libchrome/base/task_scheduler/ |
| sequence.cc | 23 queue_.push(std::move(task));
26 return queue_.size() == 1;
32 if (queue_.empty())
35 return queue_.front().get();
40 DCHECK(!queue_.empty());
43 static_cast<int>(queue_.front()->traits.priority());
47 queue_.pop();
48 return queue_.empty();
57 DCHECK(!queue_.empty());
70 next_task_sequenced_time = queue_.front()->sequenced_time
[all...] |
| sequence.h | 67 std::queue<std::unique_ptr<Task>> queue_; member in class:base::internal::Sequence
|
| /external/webrtc/webrtc/base/ |
| bufferqueue.cc | 22 for (Buffer* buffer : queue_) {
32 return queue_.size();
37 if (queue_.empty()) {
41 bool was_writable = queue_.size() < capacity_;
42 Buffer* packet = queue_.front();
43 queue_.pop_front();
60 if (queue_.size() == capacity_) {
64 bool was_readable = !queue_.empty();
77 queue_.push_back(packet);
|
| bufferqueue.h | 49 std::deque<Buffer*> queue_ GUARDED_BY(crit_);
|
| /external/webrtc/webrtc/common_audio/ |
| swap_queue.h | 83 explicit SwapQueue(size_t size) : queue_(size) {
89 : queue_item_verifier_(queue_item_verifier), queue_(size) {
94 SwapQueue(size_t size, const T& prototype) : queue_(size, prototype) {
102 : queue_item_verifier_(queue_item_verifier), queue_(size, prototype) {
127 if (num_elements_ == queue_.size()) {
132 swap(*input, queue_[next_write_index_]);
135 if (next_write_index_ == queue_.size()) {
141 RTC_DCHECK_LT(next_write_index_, queue_.size());
142 RTC_DCHECK_LE(num_elements_, queue_.size());
165 swap(*output, queue_[next_read_index_])
[all...] |
| /external/v8/src/libplatform/ |
| worker-thread.cc | 14 : Thread(Options("V8 WorkerThread")), queue_(queue) {
25 while (Task* task = queue_->GetNext()) {
|
| worker-thread.h | 32 TaskQueue* queue_; member in class:v8::platform::WorkerThread
|
| /system/bt/osi/include/ |
| leaky_bonded_queue.h | 82 // when queue_ is freed
83 std::queue<std::unique_ptr<T>> queue_; member in class:system_bt_osi::LeakyBondedQueue
103 if ((queue_.size() + 1) > capacity_) {
104 queue_.pop();
107 queue_.push(std::move(item_ptr));
114 if ((queue_.size() + 1) > capacity_) {
115 std::unique_ptr<T> item = std::move(queue_.front());
116 queue_.pop();
120 queue_.push(std::move(item_ptr));
127 std::unique_ptr<T> item = std::move(queue_.front())
[all...] |
| /external/webrtc/webrtc/modules/audio_processing/transient/ |
| moving_moments.cc | 22 queue_(),
27 queue_.push(0.0);
38 const float old_value = queue_.front();
39 queue_.pop();
40 queue_.push(in[i]);
|
| moving_moments.h | 42 std::queue<float> queue_; member in class:webrtc::MovingMoments
|
| /frameworks/base/tools/aapt2/compile/ |
| InlineXmlFormatParser.h | 53 return queue_;
59 std::vector<std::unique_ptr<xml::XmlResource>> queue_; member in class:aapt::InlineXmlFormatParser
|
| /external/drm_hwcomposer/ |
| queue_worker.h | 43 return !queue_.empty();
80 std::queue<std::unique_ptr<T>> queue_; member in class:android::QueueWorker
114 auto wait_func = [&] { return !queue_.empty(); };
129 if (!queue_.empty()) {
130 workitem = std::move(queue_.front());
131 queue_.pop();
144 auto wait_func = [&] { return queue_.size() < max_queue_size_; };
149 queue_.push(std::move(workitem));
|
| /external/libchrome/base/threading/ |
| thread_collision_warner_unittest.cc | 152 explicit QueueUser(NonThreadSafeQueue* queue) : queue_(queue) {}
155 queue_->push(0);
156 queue_->pop();
160 NonThreadSafeQueue* queue_; member in class:QueueUser
209 explicit QueueUser(NonThreadSafeQueue* queue) : queue_(queue) {}
212 queue_->push(0);
213 queue_->pop();
217 NonThreadSafeQueue* queue_; member in class:QueueUser
269 : queue_(queue), lock_(lock) {}
274 queue_->push(0)
282 NonThreadSafeQueue* queue_; member in class:QueueUser
359 NonThreadSafeQueue* queue_; member in class:QueueUser
[all...] |
| /external/webrtc/webrtc/modules/desktop_capture/ |
| screen_capturer_x11.cc | 108 ScreenCaptureFrameQueue queue_; member in class:webrtc::__anon39018::ScreenCapturerLinux
238 queue_.MoveToNextFrame();
255 if (!queue_.current_frame()) {
258 queue_.ReplaceCurrentFrame(frame.release());
262 DesktopFrame* frame = queue_.current_frame();
310 DesktopFrame* frame = queue_.current_frame()->Share();
321 if (use_damage_ && queue_.previous_frame())
327 if (use_damage_ && queue_.previous_frame()) {
360 if (queue_.previous_frame()) {
364 RTC_DCHECK(queue_.previous_frame()->data())
[all...] |
| /external/webrtc/webrtc/modules/utility/source/ |
| process_thread_impl.cc | 54 while (!queue_.empty()) {
55 delete queue_.front();
56 queue_.pop();
126 queue_.push(task.release());
220 while (!queue_.empty()) {
221 ProcessTask* task = queue_.front();
222 queue_.pop();
|
| /external/webrtc/webrtc/modules/desktop_capture/win/ |
| screen_capturer_win_gdi.cc | 76 queue_.MoveToNextFrame();
95 const DesktopFrame* current_frame = queue_.current_frame();
96 const DesktopFrame* last_frame = queue_.previous_frame();
124 DesktopFrame* frame = queue_.current_frame()->Share();
219 queue_.Reset();
235 if (!queue_.current_frame() ||
236 !queue_.current_frame()->size().equals(screen_rect.size())) {
248 queue_.ReplaceCurrentFrame(buffer.release());
254 queue_.current_frame()->GetUnderlyingFrame());
|
| screen_capturer_win_gdi.h | 69 ScreenCaptureFrameQueue queue_; member in class:webrtc::ScreenCapturerWinGdi
|
| screen_capturer_win_magnifier.cc | 87 queue_.MoveToNextFrame();
132 const DesktopFrame* current_frame = queue_.current_frame();
133 const DesktopFrame* last_frame = queue_.previous_frame();
160 DesktopFrame* frame = queue_.current_frame()->Share();
390 DesktopFrame* current_frame = queue_.current_frame();
424 if (!queue_.current_frame() || !queue_.current_frame()->size().equals(size)) {
436 queue_.ReplaceCurrentFrame(buffer.release());
|
| /external/v8/src/compiler/ |
| control-flow-optimizer.cc | 23 queue_(zone),
30 while (!queue_.empty()) {
31 Node* node = queue_.front();
32 queue_.pop();
50 queue_.push(node);
|
| control-flow-optimizer.h | 45 ZoneQueue<Node*> queue_; member in class:v8::internal::compiler::final
|
| /external/google-breakpad/src/client/ios/ |
| BreakpadController.h | 44 dispatch_queue_t queue_; variable
|
| /external/libchrome/base/files/ |
| file_path_watcher_fsevents.h | 81 ScopedDispatchObject<dispatch_queue_t> queue_; member in class:base::FilePathWatcherFSEvents
|
| /frameworks/native/libs/vr/libbufferhubqueue/ |
| buffer_hub_queue_producer.cpp | 17 producer->queue_ = ProducerQueue::Create(config, UsagePolicy{});
32 producer->queue_ = queue;
148 if (static_cast<int32_t>(queue_->capacity()) <
150 // Lazy allocation. When the capacity of |queue_| has not reached
164 auto buffer_status = queue_->Dequeue(dequeue_timeout_ms_, &slot, &fence);
197 // from |queue_->Dequeue| may not be the new buffer we just reallocated.
205 // |queue_->Dequeue| is guaranteed to avaiable for producer's use.
387 queue_->Enqueue(buffer_producer, slot, 0ULL);
417 value = queue_->default_width();
420 value = queue_->default_height()
[all...] |
