Home
last modified time | relevance | path

Searched refs:queue_ (Results 1 – 25 of 72) sorted by relevance

123

/external/libchrome/base/message_loop/
Dincoming_task_queue.cc100 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 …]
/external/webrtc/webrtc/common_audio/
Dswap_queue.h83 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/
Dsequence.cc26 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/webrtc/webrtc/base/
Dbufferqueue.cc22 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/
Dthread_collision_warner_unittest.cc152 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/libchrome/mojo/public/cpp/bindings/tests/
Dmessage_queue.cc20 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()
Dmessage_queue.h30 size_t size() const { return queue_.size(); } in size()
35 base::queue<Message> queue_; variable
/external/webrtc/webrtc/modules/desktop_capture/
Dscreen_capturer_x11.cc108 ScreenCaptureFrameQueue queue_; member in webrtc::__anon97dfb73e0111::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/tensorflow/tensorflow/lite/delegates/gpu/cl/
Dcl_command_queue.cc34 : queue_(queue), has_ownership_(has_ownership) {} in CLCommandQueue()
37 : queue_(queue.queue_), has_ownership_(queue.has_ownership_) { in CLCommandQueue()
38 queue.queue_ = nullptr; in CLCommandQueue()
44 std::swap(queue_, queue.queue_); in operator =()
53 if (has_ownership_ && queue_) { in Release()
54 clReleaseCommandQueue(queue_); in Release()
55 queue_ = nullptr; in Release()
69 queue_, kernel.kernel(), 3, nullptr, global.data(), local.data(), 0, in DispatchImplicit()
88 const int error_code = clEnqueueMarker(queue_, &resulting_event); in EnqueueEvent()
103 auto error_code = clEnqueueWriteImage(queue_, memory, CL_TRUE, origin, r, 0, in EnqueueWriteImage()
[all …]
Dgl_interop.cc156 if (queue_ && !memory_.empty()) { in Release()
159 queue_, memory_.size(), memory_.data(), wait_events.size(), in Release()
168 clFlush(queue_); in Release()
169 queue_ = nullptr; in Release()
182 queue_(environment->queue()->queue()) {} in GlInteropFabric()
234 return AcquiredGlObjects::Acquire(memory_, queue_, make_acquire_wait(), in Start()
Dgl_interop.h97 : memory_(memory), queue_(queue) {} in AcquiredGlObjects()
100 cl_command_queue queue_; variable
133 cl_command_queue queue_; variable
/external/webrtc/webrtc/modules/audio_processing/transient/
Dmoving_moments.cc22 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/
Dscreen_capturer_win_gdi.cc76 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()
Dscreen_capturer_win_magnifier.cc87 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/
Dfile_scanner.cc49 queue_(std::move(root_directories)), in FileScanner()
80 std::string directory = std::move(queue_.back()); in NextDirectory()
81 queue_.pop_back(); in NextDirectory()
108 if (queue_.empty()) in Step()
133 queue_.emplace_back(filepath); in Step()
141 queue_.clear(); in Step()
152 return !current_dir_handle_ && queue_.empty(); in Done()
/external/v8/src/libplatform/
Ddefault-worker-threads-task-runner.cc14 : queue_(time_function), time_function_(time_function) { in DefaultWorkerThreadsTaskRunner()
29 queue_.Terminate(); in Terminate()
37 queue_.Append(std::move(task)); in PostTask()
44 queue_.AppendDelayed(std::move(task), delay_in_seconds); in PostDelayedTask()
59 return queue_.GetNext(); in GetNext()
Dworker-thread.cc14 : Thread(Options("V8 WorkerThread")), queue_(queue) { in WorkerThread()
23 while (std::unique_ptr<Task> task = queue_->GetNext()) { in Run()
/external/libgav1/libgav1/src/utils/
Dthreadpool.cc101 if (!queue_.GrowIfNeeded()) { in Schedule()
107 queue_.Push(std::move(closure)); in Schedule()
238 if (!queue_.Init()) return false; in StartWorkers()
254 if (queue_.Empty()) { in WorkerFunction()
270 if (!queue_.Empty()) { in WorkerFunction()
283 if (!queue_.Empty()) continue; in WorkerFunction()
292 std::function<void()> job = std::move(queue_.Front()); in WorkerFunction()
293 queue_.Pop(); in WorkerFunction()
/external/webrtc/webrtc/modules/utility/source/
Dprocess_thread_impl.cc54 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/wasm/
Dmodule-compiler.h80 auto it = queue_.begin(); in pop()
81 if (it != queue_.end()) { in pop()
83 queue_.erase(it); in pop()
91 bool insert(const Key& key) { return queue_.insert(key).second; } in insert()
95 return queue_.size(); in size()
100 std::unordered_set<Key, Hash> queue_; variable
/external/google-breakpad/src/client/ios/
DBreakpadController.mm110 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/tensorflow/tensorflow/lite/delegates/gpu/cl/kernels/
Dconverter.cc51 return queue_->DispatchImplicit(kernel_, grid, {16, 8, 1}); in DispatchKernel()
56 CLCommandQueue* queue_ = nullptr; member in tflite::gpu::cl::__anonbad17cc20111::OpenClConverterImpl
153 queue_ = environment->queue(); in Init()
257 queue_ = environment->queue(); in Init()
326 queue_ = environment->queue(); in Init()
351 queue_->queue(), input.memobj, output.memobj, 0, 0, in Copy()
362 clEnqueueCopyImage(queue_->queue(), input.memobj, output.memobj, origin, in Copy()
389 queue_ = environment->queue(); in Init()
400 return queue_->EnqueueWriteImage( in Convert()
406 return queue_->EnqueueWriteBuffer( in Convert()
[all …]
/external/v8/src/compiler/
Dcontrol-flow-optimizer.cc25 queue_(zone), in ControlFlowOptimizer()
32 while (!queue_.empty()) { in Optimize()
34 Node* node = queue_.front(); in Optimize()
35 queue_.pop(); in Optimize()
53 queue_.push(node); in Enqueue()
/external/tensorflow/tensorflow/core/summary/
Dsummary_file_writer.cc143 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/perfetto/include/perfetto/ext/base/
Dcircular_queue.h60 : queue_(queue), in Iterator()
72 PERFETTO_DCHECK(generation_ == queue_->generation());
74 return queue_->Get(pos_);
166 PERFETTO_DCHECK(pos_ <= queue_->end_); in Add()
169 CircularQueue* queue_; variable

123