Home
last modified time | relevance | path

Searched refs:MessageLoop (Results 1 – 25 of 132) sorted by relevance

123456

/external/libchrome/base/message_loop/
Dmessage_loop.cc33 MessageLoop::MessagePumpFactory* message_pump_for_ui_factory_ = nullptr;
72 class MessageLoop::Controller : public internal::IncomingTaskQueue::Observer {
78 Controller(MessageLoop* message_loop);
110 MessageLoop* message_loop_;
122 MessageLoop::Controller::Controller(MessageLoop* message_loop) in Controller()
125 MessageLoop::Controller::~Controller() { in ~Controller()
130 void MessageLoop::Controller::WillQueueTask(PendingTask* task) { in WillQueueTask()
134 void MessageLoop::Controller::DidQueueTask(bool was_empty) { in DidQueueTask()
147 void MessageLoop::Controller::StartScheduling() { in StartScheduling()
156 void MessageLoop::Controller::DisconnectFromParent() { in DisconnectFromParent()
[all …]
Dmessage_loop_task_runner_unittest.cc26 : current_loop_(new MessageLoop()), in MessageLoopTaskRunnerTest()
58 LoopRecorder(MessageLoop** run_on, in LoopRecorder()
59 MessageLoop** deleted_on, in LoopRecorder()
65 void RecordRun() { *run_on_ = MessageLoop::current(); } in RecordRun()
70 *deleted_on_ = MessageLoop::current(); in ~LoopRecorder()
74 MessageLoop** run_on_;
75 MessageLoop** deleted_on_;
94 std::unique_ptr<MessageLoop> current_loop_;
104 MessageLoop* task_run_on = nullptr; in TEST_F()
105 MessageLoop* task_deleted_on = nullptr; in TEST_F()
[all …]
Dmessage_pump_perftest.cc73 void ScheduleWork(MessageLoop::Type target_type, int num_scheduling_threads) { in ScheduleWork()
75 if (target_type == MessageLoop::TYPE_JAVA) { in ScheduleWork()
113 if (target_type == MessageLoop::TYPE_JAVA) { in ScheduleWork()
135 target_type == MessageLoop::TYPE_IO in ScheduleWork()
137 : (target_type == MessageLoop::TYPE_UI ? "ui" : "default")); in ScheduleWork()
170 MessageLoop* target_message_loop() { in target_message_loop()
194 ScheduleWork(MessageLoop::TYPE_IO, 1); in TEST_F()
198 ScheduleWork(MessageLoop::TYPE_IO, 2); in TEST_F()
202 ScheduleWork(MessageLoop::TYPE_IO, 4); in TEST_F()
206 ScheduleWork(MessageLoop::TYPE_UI, 1); in TEST_F()
[all …]
Dmessage_loop_current.cc18 base::ThreadLocalPointer<MessageLoop>* GetTLSMessageLoop() { in GetTLSMessageLoop()
19 static NoDestructor<ThreadLocalPointer<MessageLoop>> lazy_tls_ptr; in GetTLSMessageLoop()
103 void MessageLoopCurrent::BindToCurrentThreadInternal(MessageLoop* current) { in BindToCurrentThreadInternal()
110 void MessageLoopCurrent::UnbindFromCurrentThreadInternal(MessageLoop* current) { in UnbindFromCurrentThreadInternal()
116 MessageLoop* message_loop) { in IsBoundToCurrentThreadInternal()
127 MessageLoop* loop = GetTLSMessageLoop()->Get(); in Get()
130 DCHECK(loop->IsType(MessageLoop::TYPE_UI) || in Get()
131 loop->IsType(MessageLoop::TYPE_JAVA)); in Get()
133 DCHECK(loop->IsType(MessageLoop::TYPE_UI)); in Get()
142 MessageLoop* loop = GetTLSMessageLoop()->Get(); in IsSet()
[all …]
Dmessage_loop.h86 class BASE_EXPORT MessageLoop : public MessagePump::Delegate,
129 explicit MessageLoop(Type type = TYPE_DEFAULT);
132 explicit MessageLoop(std::unique_ptr<MessagePump> pump);
134 ~MessageLoop() override;
216 MessageLoop(Type type, MessagePumpFactoryCallback pump_factory);
245 static std::unique_ptr<MessageLoop> CreateUnbound(
344 DISALLOW_COPY_AND_ASSIGN(MessageLoop);
362 class BASE_EXPORT MessageLoopForUI : public MessageLoop {
401 static_assert(sizeof(MessageLoop) == sizeof(MessageLoopForUI),
416 class BASE_EXPORT MessageLoopForIO : public MessageLoop {
[all …]
Dmessage_loop_current.h19 class MessageLoop; variable
62 operator MessageLoop*() const { return current_; }
162 MessageLoop* const loop_;
176 static void BindToCurrentThreadInternal(MessageLoop* current);
181 static void UnbindFromCurrentThreadInternal(MessageLoop* current);
185 static bool IsBoundToCurrentThreadInternal(MessageLoop* message_loop);
188 explicit MessageLoopCurrent(MessageLoop* current) : current_(current) {} in MessageLoopCurrent()
190 MessageLoop* const current_;
236 MessageLoopCurrentForUI(MessageLoop* current, MessagePumpForUI* pump) in MessageLoopCurrentForUI()
287 MessageLoopCurrentForIO(MessageLoop* current, MessagePumpForIO* pump) in MessageLoopCurrentForIO()
Dmessage_loop_unittest.cc201 class DummyTaskObserver : public MessageLoop::TaskObserver {
414 MessageLoop message_loop(MessageLoop::TYPE_UI); in RunTest_PostDelayedTask_SharedTimer_SubPump()
526 void RunTest_RecursiveDenial2(MessageLoop::Type message_loop_type) { in RunTest_RecursiveDenial2()
527 MessageLoop loop(message_loop_type); in RunTest_RecursiveDenial2()
566 void RunTest_RecursiveSupport2(MessageLoop::Type message_loop_type) { in RunTest_RecursiveSupport2()
567 MessageLoop loop(message_loop_type); in RunTest_RecursiveSupport2()
685 options.message_loop_type = MessageLoop::TYPE_IO; in RunTest_IOHandler()
723 options.message_loop_type = MessageLoop::TYPE_IO; in RunTest_WaitForIO()
771 MessageLoop::Type type_in, in MessageLoopTypedTestParams()
777 MessageLoop::Type type;
[all …]
Dmessage_pump_libevent_unittest.cc35 : ui_loop_(new MessageLoop(MessageLoop::TYPE_UI)), in MessagePumpLibeventTest()
40 Thread::Options options(MessageLoop::TYPE_IO, 0); in SetUp()
42 ASSERT_EQ(MessageLoop::TYPE_IO, io_thread_.message_loop()->type()); in SetUp()
69 std::unique_ptr<MessageLoop> ui_loop_;
228 MessageLoop loop(WrapUnique(pump)); in TEST_F()
/external/libbrillo/brillo/message_loops/
Dmessage_loop.cc17 base::LazyInstance<base::ThreadLocalPointer<MessageLoop> >::Leaky lazy_tls_ptr =
22 const MessageLoop::TaskId MessageLoop::kTaskIdNull = 0;
24 MessageLoop* MessageLoop::current() { in current()
31 bool MessageLoop::ThreadHasCurrent() { in ThreadHasCurrent()
35 void MessageLoop::SetAsCurrent() { in SetAsCurrent()
41 void MessageLoop::ReleaseFromCurrent() { in ReleaseFromCurrent()
47 MessageLoop::~MessageLoop() { in ~MessageLoop()
52 void MessageLoop::Run() { in Run()
59 void MessageLoop::BreakLoop() { in BreakLoop()
Dfake_message_loop.h32 class BRILLO_EXPORT FakeMessageLoop : public MessageLoop {
42 using MessageLoop::PostDelayedTask;
59 std::map<MessageLoop::TaskId, ScheduledTask> tasks_;
65 std::pair<base::Time, MessageLoop::TaskId>,
66 std::vector<std::pair<base::Time, MessageLoop::TaskId>>,
67 std::greater<std::pair<base::Time, MessageLoop::TaskId>>> fire_order_;
72 MessageLoop::TaskId last_id_ = kTaskIdNull;
Dbase_message_loop.h32 class BRILLO_EXPORT BaseMessageLoop : public MessageLoop {
47 using MessageLoop::PostDelayedTask;
70 void OnRanPostedTask(MessageLoop::TaskId task_id);
81 MessageLoop::TaskId task_id;
90 std::map<MessageLoop::TaskId, DelayedTask> delayed_tasks_;
98 MessageLoop::TaskId last_id_{kTaskIdNull};
Dmessage_loop.h18 class BRILLO_EXPORT MessageLoop {
20 virtual ~MessageLoop();
33 static MessageLoop* current();
95 MessageLoop() = default;
102 DISALLOW_COPY_AND_ASSIGN(MessageLoop);
Dmessage_loop_test.cc44 using TaskId = MessageLoop::TaskId;
56 std::unique_ptr<MessageLoop> loop_;
78 EXPECT_FALSE(this->loop_->CancelTask(MessageLoop::kTaskIdNull)); in TYPED_TEST()
86 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TYPED_TEST()
108 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TYPED_TEST()
131 [](bool* cancel_result, MessageLoop* loop, TaskId* task_id) { in TYPED_TEST()
Dmessage_loop_utils.cc12 void MessageLoopRunUntil(MessageLoop* loop, in MessageLoopRunUntil()
16 MessageLoop::TaskId task_id = loop->PostDelayedTask( in MessageLoopRunUntil()
28 int MessageLoopRunMaxIterations(MessageLoop* loop, int iterations) { in MessageLoopRunMaxIterations()
/external/libchrome/base/synchronization/
Dwaitable_event_watcher_unittest.cc24 const MessageLoop::Type testing_message_loops[] = {
25 MessageLoop::TYPE_DEFAULT,
26 MessageLoop::TYPE_IO,
28 MessageLoop::TYPE_UI,
51 : public testing::TestWithParam<MessageLoop::Type> {};
54 MessageLoop message_loop(GetParam()); in TEST_P()
72 MessageLoop message_loop(GetParam()); in TEST_P()
90 MessageLoop message_loop(GetParam()); in TEST_P()
105 MessageLoop message_loop(GetParam()); in TEST_P()
142 MessageLoop message_loop(GetParam()); in TEST_P()
[all …]
/external/libchrome/base/timer/
Dtimer_unittest.cc37 const MessageLoop::Type testing_message_loops[] = {
38 MessageLoop::TYPE_DEFAULT, MessageLoop::TYPE_IO,
40 MessageLoop::TYPE_UI,
202 void RunTest_OneShotTimers(MessageLoop::Type message_loop_type) { in RunTest_OneShotTimers()
203 MessageLoop loop(message_loop_type); in RunTest_OneShotTimers()
218 void RunTest_OneShotTimers_Cancel(MessageLoop::Type message_loop_type) { in RunTest_OneShotTimers_Cancel()
219 MessageLoop loop(message_loop_type); in RunTest_OneShotTimers_Cancel()
239 void RunTest_OneShotSelfDeletingTimer(MessageLoop::Type message_loop_type) { in RunTest_OneShotSelfDeletingTimer()
240 MessageLoop loop(message_loop_type); in RunTest_OneShotSelfDeletingTimer()
247 void RunTest_RepeatingTimer(MessageLoop::Type message_loop_type, in RunTest_RepeatingTimer()
[all …]
/external/libchrome/base/threading/
Dthread.cc43 Thread::Options::Options(MessageLoop::Type type, size_t size) in Options()
73 options.message_loop_type = MessageLoop::TYPE_UI; in Start()
86 (options.message_loop_type == MessageLoop::TYPE_UI)); in StartWithOptions()
95 MessageLoop::Type type = options.message_loop_type; in StartWithOptions()
97 type = MessageLoop::TYPE_CUSTOM; in StartWithOptions()
100 std::unique_ptr<MessageLoop> message_loop_owned = in StartWithOptions()
101 MessageLoop::CreateUnbound(type, options.message_pump_factory); in StartWithOptions()
272 void Thread::SetMessageLoop(MessageLoop* message_loop) { in SetMessageLoop()
303 std::unique_ptr<MessageLoop> message_loop(message_loop_); in ThreadMain()
351 if (message_loop->type() != MessageLoop::TYPE_CUSTOM) { in ThreadMain()
Dthread.h65 Options(MessageLoop::Type type, size_t size);
71 MessageLoop::Type message_loop_type = MessageLoop::TYPE_DEFAULT;
202 MessageLoop* message_loop() const { in message_loop()
277 void SetMessageLoop(MessageLoop* message_loop);
327 MessageLoop* message_loop_ = nullptr;
/external/libchrome/mojo/public/java/system/
Dbase_run_loop.cc24 base::MessageLoop* message_loop = new base::MessageLoop; in JNI_BaseRunLoop_CreateBaseRunLoop()
60 reinterpret_cast<base::MessageLoop*>(runLoopID) in JNI_BaseRunLoop_PostDelayedTask()
71 base::MessageLoop* message_loop = in JNI_BaseRunLoop_DeleteMessageLoop()
72 reinterpret_cast<base::MessageLoop*>(runLoopID); in JNI_BaseRunLoop_DeleteMessageLoop()
/external/libbrillo/brillo/
Dasynchronous_signal_handler_test.cc60 MessageLoop::current()->Run(); in TEST_F()
76 MessageLoop::current()->Run(); in TEST_F()
85 base::Bind(&MessageLoop::BreakLoop, in TEST_F()
88 MessageLoop::current()->Run(); in TEST_F()
107 MessageLoop::current()->Run(); in TEST_F()
131 MessageLoop::current()->Run();
Dprocess_reaper_test.cc77 [](MessageLoop* loop, const siginfo_t& info) { in TEST_F()
94 [](MessageLoop* loop, int exit_value, int* running_children, in TEST_F()
113 [](MessageLoop* loop, const siginfo_t& info) { in TEST_F()
124 [](MessageLoop* loop, const siginfo_t& /* info */) { in TEST_F()
135 base::Bind(&MessageLoop::BreakLoop, in TEST_F()
/external/libchrome/base/test/
Dscoped_task_environment.cc32 std::unique_ptr<MessageLoop> CreateMessageLoopForMainThreadType( in CreateMessageLoopForMainThreadType()
36 return std::make_unique<MessageLoop>(MessageLoop::TYPE_DEFAULT); in CreateMessageLoopForMainThreadType()
40 return std::make_unique<MessageLoop>(MessageLoop::TYPE_UI); in CreateMessageLoopForMainThreadType()
42 return std::make_unique<MessageLoop>(MessageLoop::TYPE_IO); in CreateMessageLoopForMainThreadType()
/external/libchrome/base/task/sequence_manager/test/
Dlazy_thread_controller_for_test.cc14 : ThreadControllerImpl(MessageLoop::current(), in LazyThreadControllerForTest()
28 message_loop_ = MessageLoop::current(); in EnsureMessageLoop()
87 if (MessageLoop::current() != message_loop_) in RemoveNestingObserver()
118 if (HasMessageLoop() && MessageLoop::current() == message_loop_) in RestoreDefaultTaskRunner()
/external/libchrome/base/task/sequence_manager/
Dthread_controller_impl.h21 class MessageLoop; variable
33 MessageLoop* message_loop,
54 ThreadControllerImpl(MessageLoop* message_loop,
60 MessageLoop* message_loop_;
/external/libchrome/base/
Dtask_runner_util_unittest.cc74 MessageLoop message_loop; in TEST()
87 MessageLoop message_loop; in TEST()
101 MessageLoop message_loop; in TEST()
115 MessageLoop message_loop; in TEST()

123456