Home
last modified time | relevance | path

Searched refs:incoming_queue_ (Results 1 – 20 of 20) sorted by relevance

/dports/www/chromium-legacy/chromium-88.0.4324.182/base/message_loop/
H A Dmessage_loop_task_runner.cc94 incoming_queue_.swap(outgoing_queue_); in HasTasks()
161 was_empty = outgoing_queue_empty_ && incoming_queue_.empty(); in AddToIncomingQueue()
162 incoming_queue_.push(std::move(pending_task)); in AddToIncomingQueue()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/media/capture/video/linux/
H A Dfake_v4l2_impl.cc188 incoming_queue_ = std::queue<FakeV4L2Buffer*>(); in reqbufs()
228 incoming_queue_.push(&buffer); in qbuf()
282 incoming_queue_ = std::queue<FakeV4L2Buffer*>(); in streamoff()
303 if (incoming_queue_.empty()) { in MaybeProduceOneFrame()
307 auto* buffer = incoming_queue_.front(); in MaybeProduceOneFrame()
311 incoming_queue_.pop(); in MaybeProduceOneFrame()
321 std::queue<FakeV4L2Buffer*> incoming_queue_; member in media::FakeV4L2Impl::OpenedDevice
/dports/www/chromium-legacy/chromium-88.0.4324.182/media/capture/video/linux/
H A Dfake_v4l2_impl.cc213 incoming_queue_ = std::queue<FakeV4L2Buffer*>(); in reqbufs()
253 incoming_queue_.push(&buffer); in qbuf()
307 incoming_queue_ = std::queue<FakeV4L2Buffer*>(); in streamoff()
350 if (incoming_queue_.empty()) { in MaybeProduceOneFrame()
354 auto* buffer = incoming_queue_.front(); in MaybeProduceOneFrame()
358 incoming_queue_.pop(); in MaybeProduceOneFrame()
368 std::queue<FakeV4L2Buffer*> incoming_queue_; member in media::FakeV4L2Impl::OpenedDevice
/dports/www/firefox-legacy/firefox-52.8.0esr/ipc/chromium/src/base/
H A Dmessage_loop.cc308 incoming_queue_.push(Move(pending_task)); in PostTask_Helper()
387 if (incoming_queue_.empty()) in ReloadWorkQueue()
389 std::swap(incoming_queue_, work_queue_); in ReloadWorkQueue()
390 DCHECK(incoming_queue_.empty()); in ReloadWorkQueue()
H A Dmessage_loop.h418 TaskQueue incoming_queue_; variable
/dports/www/firefox-esr/firefox-91.8.0/ipc/chromium/src/base/
H A Dmessage_loop.cc413 incoming_queue_.push(std::move(pending_task)); in PostTask_Helper()
498 if (incoming_queue_.empty()) return; in ReloadWorkQueue()
499 std::swap(incoming_queue_, work_queue_); in ReloadWorkQueue()
500 DCHECK(incoming_queue_.empty()); in ReloadWorkQueue()
H A Dmessage_loop.h424 TaskQueue incoming_queue_; variable
/dports/lang/spidermonkey78/firefox-78.9.0/ipc/chromium/src/base/
H A Dmessage_loop.cc405 incoming_queue_.push(std::move(pending_task)); in PostTask_Helper()
483 if (incoming_queue_.empty()) return; in ReloadWorkQueue()
484 std::swap(incoming_queue_, work_queue_); in ReloadWorkQueue()
485 DCHECK(incoming_queue_.empty()); in ReloadWorkQueue()
H A Dmessage_loop.h424 TaskQueue incoming_queue_; variable
/dports/www/firefox/firefox-99.0/ipc/chromium/src/base/
H A Dmessage_loop.cc413 incoming_queue_.push(std::move(pending_task)); in PostTask_Helper()
498 if (incoming_queue_.empty()) return; in ReloadWorkQueue()
499 std::swap(incoming_queue_, work_queue_); in ReloadWorkQueue()
500 DCHECK(incoming_queue_.empty()); in ReloadWorkQueue()
H A Dmessage_loop.h424 TaskQueue incoming_queue_; variable
/dports/mail/thunderbird/thunderbird-91.8.0/ipc/chromium/src/base/
H A Dmessage_loop.cc413 incoming_queue_.push(std::move(pending_task)); in PostTask_Helper()
498 if (incoming_queue_.empty()) return; in ReloadWorkQueue()
499 std::swap(incoming_queue_, work_queue_); in ReloadWorkQueue()
500 DCHECK(incoming_queue_.empty()); in ReloadWorkQueue()
H A Dmessage_loop.h424 TaskQueue incoming_queue_; variable
/dports/lang/spidermonkey60/firefox-60.9.0/ipc/chromium/src/base/
H A Dmessage_loop.cc405 incoming_queue_.push(Move(pending_task)); in PostTask_Helper()
483 if (incoming_queue_.empty()) return; in ReloadWorkQueue()
484 std::swap(incoming_queue_, work_queue_); in ReloadWorkQueue()
485 DCHECK(incoming_queue_.empty()); in ReloadWorkQueue()
H A Dmessage_loop.h424 TaskQueue incoming_queue_; variable
/dports/net/yami4/yami4-gpl-1.11.0/src/cpp/
H A Dagent_impl.h225 incoming_message_queue incoming_queue_; variable
H A Dagent_impl.cpp610 incoming_queue_.push(empty_msg_info); in stop_dispatcher_threads()
1282 incoming_queue_.push(incoming); in queue_incoming()
1314 std::unique_ptr<incoming_message_info> im_info(incoming_queue_.pop()); in do_message_dispatching()
/dports/devel/android-tools-fastboot/platform_system_core-platform-tools-29.0.5/adb/
H A Dtransport_fd.cpp232 IOVector incoming_queue_; member
/dports/www/chromium-legacy/chromium-88.0.4324.182/base/task/sequence_manager/
H A Dwork_queue_unittest.cc103 std::unique_ptr<TaskQueueImpl::TaskDeque> incoming_queue_; member in base::sequence_manager::internal::WorkQueueTest
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/task/sequence_manager/
H A Dwork_queue_unittest.cc103 std::unique_ptr<TaskQueueImpl::TaskDeque> incoming_queue_; member in base::sequence_manager::internal::WorkQueueTest