Home
last modified time | relevance | path

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

123

/external/libweave/src/commands/
Dcommand_queue_unittest.cc36 bool Remove(const std::string& id) { return queue_.Remove(id); } in Remove()
39 return queue_.Cleanup(task_runner_.GetClock()->Now() + interval); in Cleanup()
43 return queue_.remove_queue_.top().second; in GetFirstCommandToBeRemoved()
47 CommandQueue queue_{&task_runner_, task_runner_.GetClock()}; member in weave::CommandQueueTest
87 EXPECT_TRUE(queue_.IsEmpty()); in TEST_F()
88 EXPECT_EQ(0u, queue_.GetCount()); in TEST_F()
92 queue_.Add(CreateDummyCommandInstance("base.reboot", "id1")); in TEST_F()
93 queue_.Add(CreateDummyCommandInstance("base.reboot", "id2")); in TEST_F()
94 queue_.Add(CreateDummyCommandInstance("base.reboot", "id3")); in TEST_F()
95 EXPECT_EQ(3u, queue_.GetCount()); in TEST_F()
[all …]
Dcommand_instance.h91 void AttachToQueue(CommandQueue* queue) { queue_ = queue; } in AttachToQueue()
92 void DetachFromQueue() { queue_ = nullptr; } in DetachFromQueue()
125 CommandQueue* queue_ = nullptr; variable
/external/libweave/src/states/
Dstate_change_queue_unittest.cc18 void SetUp() override { queue_.reset(new StateChangeQueue(100)); } in SetUp()
20 void TearDown() override { queue_.reset(); } in TearDown()
22 std::unique_ptr<StateChangeQueue> queue_; member in weave::StateChangeQueueTest
26 EXPECT_TRUE(queue_->GetAndClearRecordedStateChanges().empty()); in TEST_F()
31 ASSERT_TRUE(queue_->NotifyPropertiesUpdated( in TEST_F()
33 auto changes = queue_->GetAndClearRecordedStateChanges(); in TEST_F()
37 EXPECT_TRUE(queue_->GetAndClearRecordedStateChanges().empty()); in TEST_F()
46 ASSERT_TRUE(queue_->NotifyPropertiesUpdated(timestamp1, in TEST_F()
48 ASSERT_TRUE(queue_->NotifyPropertiesUpdated(timestamp2, in TEST_F()
51 auto changes = queue_->GetAndClearRecordedStateChanges(); in TEST_F()
[all …]
/external/libchrome/base/mac/
Dlibdispatch_task_runner.cc15 : queue_(dispatch_queue_create(name, NULL)), in LibDispatchTaskRunner()
17 dispatch_set_context(queue_, this); in LibDispatchTaskRunner()
18 dispatch_set_finalizer_f(queue_, &LibDispatchTaskRunner::Finalizer); in LibDispatchTaskRunner()
25 if (!queue_) in PostDelayedTask()
40 dispatch_after(time, queue_, run_task); in PostDelayedTask()
42 dispatch_async(queue_, run_task); in PostDelayedTask()
48 return queue_ == dispatch_get_current_queue(); in RunsTasksOnCurrentThread()
59 dispatch_release(queue_); in Shutdown()
60 queue_ = NULL; in Shutdown()
65 return queue_; in GetDispatchQueue()
[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/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.cc150 explicit QueueUser(NonThreadSafeQueue* queue) : queue_(queue) {} in TEST()
153 queue_->push(0); in TEST()
154 queue_->pop(); in TEST()
158 NonThreadSafeQueue* queue_; in TEST() member in TEST::QueueUser
207 explicit QueueUser(NonThreadSafeQueue* queue) : queue_(queue) {} in TEST()
210 queue_->push(0); in TEST()
211 queue_->pop(); in TEST()
215 NonThreadSafeQueue* queue_; in TEST() member in TEST::QueueUser
267 : queue_(queue), lock_(lock) {} in TEST()
272 queue_->push(0); in TEST()
[all …]
/external/webrtc/webrtc/modules/desktop_capture/
Dscreen_capturer_x11.cc108 ScreenCaptureFrameQueue queue_; member in webrtc::__anon20459e380111::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/libweave/examples/provider/
Devent_task_runner.cc21 if (queue_.empty() || new_time < queue_.top().first.first) { in PostDelayedTask()
24 queue_.emplace(std::make_pair(new_time, ++counter_), task); in PostDelayedTask()
82 while (!queue_.empty() && queue_.top().first.first <= base::Time::Now()) { in Process()
83 auto cb = queue_.top().second; in Process()
84 queue_.pop(); in Process()
87 if (!queue_.empty()) { in Process()
89 base::TimeDelta(), queue_.top().first.first - base::Time::Now()); in Process()
/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/libweave/src/test/
Dfake_task_runner.cc26 if (queue_.empty()) in RunOnce()
28 auto top = queue_.top(); in RunOnce()
29 queue_.pop(); in RunOnce()
52 queue_.emplace(std::make_pair(test_clock_->Now() + delay, ++counter_), task); in PostDelayedTask()
56 return queue_.size(); in GetTaskQueueSize()
/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/compiler/
Dliveness-analyzer.cc18 : zone_(zone), blocks_(zone), local_count_(local_count), queue_(zone) {} in LivenessAnalyzer()
49 queue_.push(block); in Queue()
61 DCHECK(queue_.empty()); in Run()
68 while (!queue_.empty()) { in Run()
69 LivenessAnalyzerBlock* block = queue_.front(); in Run()
70 queue_.pop(); in Run()
Dloop-analysis.cc56 queue_(zone), in LoopFinderImpl()
108 NodeDeque queue_; member in v8::internal::compiler::LoopFinderImpl
184 while (!queue_.empty()) { in PropagateBackward()
185 Node* node = queue_.front(); in PropagateBackward()
187 queue_.pop_front(); in PropagateBackward()
273 while (!queue_.empty()) { in PropagateForward()
274 Node* node = queue_.front(); in PropagateForward()
275 queue_.pop_front(); in PropagateForward()
305 queue_.push_back(node); in Queue()
Dcontrol-flow-optimizer.cc23 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()
Dgreedy-allocator.h66 explicit AllocationScheduler(Zone* zone) : queue_(zone) {} in AllocationScheduler()
70 bool empty() const { return queue_.empty(); } in empty()
74 ScheduleQueue queue_; variable
Dscheduler.cc222 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()
553 DCHECK(queue_.empty()); in ResetDataStructures()
561 ZoneQueue<Node*> queue_; // Queue used for breadth-first traversal. member in v8::internal::compiler::CFGBuilder
[all …]
/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/v8/test/unittests/libplatform/
Dtask-queue-unittest.cc27 : Thread(Options("libplatform TaskQueueThread")), queue_(queue) {} in TaskQueueThread()
29 void Run() override { EXPECT_THAT(queue_->GetNext(), IsNull()); } in Run()
32 TaskQueue* queue_; member in v8::platform::__anon7f23d7b50111::TaskQueueThread
/external/v8/src/libplatform/
Dworker-thread.cc14 : Thread(Options("V8 WorkerThread")), queue_(queue) { in WorkerThread()
25 while (Task* task = queue_->GetNext()) { in Run()
Ddefault-platform.cc42 queue_.Terminate(); in ~DefaultPlatform()
82 thread_pool_.push_back(new WorkerThread(&queue_)); in EnsureInitialized()
139 queue_.Append(task); in CallOnBackgroundThread()
/external/webrtc/webrtc/modules/remote_bitrate_estimator/test/
Dpacket_sender.cc172 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/
Dpeer_channel.cc136 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()

123