Home
last modified time | relevance | path

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

12345

/external/libchrome/base/message_loop/
Dmessage_loop.cc48 LazyInstance<base::ThreadLocalPointer<MessageLoop> >::Leaky lazy_tls_ptr =
92 MessageLoop::MessagePumpFactory* message_pump_for_ui_factory_ = NULL;
116 MessageLoop::TaskObserver::TaskObserver() { in TaskObserver()
119 MessageLoop::TaskObserver::~TaskObserver() { in ~TaskObserver()
122 MessageLoop::DestructionObserver::~DestructionObserver() { in ~DestructionObserver()
125 MessageLoop::NestingObserver::~NestingObserver() {} in ~NestingObserver()
129 MessageLoop::MessageLoop(Type type) in MessageLoop() function in base::MessageLoop
130 : MessageLoop(type, MessagePumpFactoryCallback()) { in MessageLoop()
134 MessageLoop::MessageLoop(std::unique_ptr<MessagePump> pump) in MessageLoop() function in base::MessageLoop
135 : MessageLoop(TYPE_CUSTOM, Bind(&ReturnPump, Passed(&pump))) { in MessageLoop()
[all …]
Dmessage_loop_test.cc77 MessageLoop::current()->QuitWhenIdle(); in SlowFunc()
96 MessageLoop loop(std::move(pump)); in RunTest_PostTask()
100 MessageLoop::current()->task_runner()->PostTask(FROM_HERE, in RunTest_PostTask()
102 MessageLoop::current()->task_runner()->PostTask( in RunTest_PostTask()
104 MessageLoop::current()->task_runner()->PostTask( in RunTest_PostTask()
106 MessageLoop::current()->task_runner()->PostTask( in RunTest_PostTask()
108 MessageLoop::current()->task_runner()->PostTask( in RunTest_PostTask()
110 MessageLoop::current()->task_runner()->PostTask( in RunTest_PostTask()
113 MessageLoop::current()->task_runner()->PostTask( in RunTest_PostTask()
115 Bind(&MessageLoop::QuitWhenIdle, Unretained(MessageLoop::current()))); in RunTest_PostTask()
[all …]
Dmessage_loop_task_runner_unittest.cc27 : current_loop_(new MessageLoop()), in MessageLoopTaskRunnerTest()
59 LoopRecorder(MessageLoop** run_on, in LoopRecorder()
60 MessageLoop** deleted_on, in LoopRecorder()
66 void RecordRun() { *run_on_ = MessageLoop::current(); } in RecordRun()
71 *deleted_on_ = MessageLoop::current(); in ~LoopRecorder()
75 MessageLoop** run_on_;
76 MessageLoop** deleted_on_;
86 MessageLoop::current()->QuitWhenIdle(); in RecordLoopAndQuit()
95 std::unique_ptr<MessageLoop> current_loop_;
105 MessageLoop* task_run_on = NULL; in TEST_F()
[all …]
Dmessage_loop_unittest.cc46 return MessageLoop::CreateMessagePumpForType(MessageLoop::TYPE_DEFAULT); in TypeDefaultMessagePumpFactory()
50 return MessageLoop::CreateMessagePumpForType(MessageLoop::TYPE_IO); in TypeIOMessagePumpFactory()
54 return MessageLoop::CreateMessagePumpForType(MessageLoop::TYPE_UI); in TypeUIMessagePumpFactory()
85 MessageLoop::current()->QuitWhenIdle(); in SlowFunc()
100 MessageLoop::current()->SetNestableTasksAllowed(true); in SubPumpFunc()
106 MessageLoop::current()->QuitWhenIdle(); in SubPumpFunc()
110 MessageLoop loop(MessageLoop::TYPE_UI); in RunTest_PostDelayedTask_SharedTimer_SubPump()
240 MessageLoop::current()->SetNestableTasksAllowed(true); in MessageBoxFunc()
262 MessageLoop::current()->SetNestableTasksAllowed(true); in RecursiveFunc()
263 MessageLoop::current()->PostTask( in RecursiveFunc()
[all …]
Dmessage_loop.h78 class BASE_EXPORT MessageLoop : public MessagePump::Delegate {
115 explicit MessageLoop(Type type = TYPE_DEFAULT);
118 explicit MessageLoop(std::unique_ptr<MessagePump> pump);
120 ~MessageLoop() override;
123 static MessageLoop* current();
336 explicit ScopedNestableTaskAllower(MessageLoop* loop) in ScopedNestableTaskAllower()
346 MessageLoop* loop_;
414 MessageLoop(Type type, MessagePumpFactoryCallback pump_factory);
437 static std::unique_ptr<MessageLoop> CreateUnbound(
558 DISALLOW_COPY_AND_ASSIGN(MessageLoop);
[all …]
Dmessage_pump_glib_unittest.cc155 MessageLoop::current()->PostTask(from_here, task); in PostMessageLoopTask()
165 loop_ = new MessageLoop(MessageLoop::TYPE_UI); in SetUp()
175 MessageLoop* loop() const { return loop_; } in loop()
179 MessageLoop* loop_;
195 injector()->AddEvent(0, MessageLoop::QuitWhenIdleClosure()); in TEST_F()
215 injector()->AddEvent(0, MessageLoop::QuitWhenIdleClosure()); in TEST_F()
226 injector()->AddEvent(0, MessageLoop::QuitWhenIdleClosure()); in TEST_F()
243 MessageLoop::QuitWhenIdleClosure())); in TEST_F()
264 MessageLoop::QuitWhenIdleClosure()), in TEST_F()
287 injector()->AddEvent(10, MessageLoop::QuitWhenIdleClosure()); in TEST_F()
[all …]
/external/libbrillo/brillo/message_loops/
Dmessage_loop_unittest.cc31 using TaskId = MessageLoop::TaskId;
43 std::unique_ptr<MessageLoop> loop_;
71 EXPECT_FALSE(this->loop_->CancelTask(MessageLoop::kTaskIdNull)); in TYPED_TEST()
79 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TYPED_TEST()
102 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TYPED_TEST()
121 EXPECT_EQ(MessageLoop::kTaskIdNull, this->loop_->WatchFileDescriptor( in TYPED_TEST()
122 FROM_HERE, -1, MessageLoop::kWatchRead, true, in TYPED_TEST()
124 EXPECT_EQ(MessageLoop::kTaskIdNull, this->loop_->WatchFileDescriptor( in TYPED_TEST()
125 FROM_HERE, -1, MessageLoop::kWatchWrite, true, in TYPED_TEST()
135 FROM_HERE, pipe.reader, MessageLoop::kWatchRead, true, in TYPED_TEST()
[all …]
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()
Dbase_message_loop.h30 class BRILLO_EXPORT BaseMessageLoop : public MessageLoop {
45 using MessageLoop::PostDelayedTask;
51 using MessageLoop::WatchFileDescriptor;
74 void OnRanPostedTask(MessageLoop::TaskId task_id);
80 void OnFileReadyPostedTask(MessageLoop::TaskId task_id);
91 MessageLoop::TaskId task_id;
99 MessageLoop::TaskId task_id,
131 MessageLoop::TaskId task_id_;
162 std::map<MessageLoop::TaskId, DelayedTask> delayed_tasks_;
165 std::map<MessageLoop::TaskId, IOTask> io_tasks_;
[all …]
Dfake_message_loop.h32 class BRILLO_EXPORT FakeMessageLoop : public MessageLoop {
42 using MessageLoop::PostDelayedTask;
48 using MessageLoop::WatchFileDescriptor;
72 std::map<MessageLoop::TaskId, ScheduledTask> tasks_;
78 std::pair<base::Time, MessageLoop::TaskId>,
79 std::vector<std::pair<base::Time, MessageLoop::TaskId>>,
80 std::greater<std::pair<base::Time, MessageLoop::TaskId>>> fire_order_;
84 std::multimap<std::pair<int, WatchMode>, MessageLoop::TaskId> fds_watched_;
92 MessageLoop::TaskId last_id_ = kTaskIdNull;
Dglib_message_loop.cc31 MessageLoop::TaskId GlibMessageLoop::PostDelayedTask( in PostDelayedTask()
53 MessageLoop::TaskId GlibMessageLoop::WatchFileDescriptor( in WatchFileDescriptor()
61 return MessageLoop::kTaskIdNull; in WatchFileDescriptor()
65 case MessageLoop::kWatchRead: in WatchFileDescriptor()
68 case MessageLoop::kWatchWrite: in WatchFileDescriptor()
72 return MessageLoop::kTaskIdNull; in WatchFileDescriptor()
80 return MessageLoop::kTaskIdNull; in WatchFileDescriptor()
91 return MessageLoop::kTaskIdNull; in WatchFileDescriptor()
111 << (mode == MessageLoop::kWatchRead ? "reading" : "writing") in WatchFileDescriptor()
118 return MessageLoop::kTaskIdNull; in WatchFileDescriptor()
[all …]
Dbase_message_loop.cc49 CHECK(!base::MessageLoop::current()) in BaseMessageLoop()
83 MessageLoop::TaskId BaseMessageLoop::PostDelayedTask( in PostDelayedTask()
97 return MessageLoop::kTaskIdNull; in PostDelayedTask()
104 MessageLoop::TaskId BaseMessageLoop::WatchFileDescriptor( in WatchFileDescriptor()
112 return MessageLoop::kTaskIdNull; in WatchFileDescriptor()
116 case MessageLoop::kWatchRead: in WatchFileDescriptor()
119 case MessageLoop::kWatchWrite: in WatchFileDescriptor()
123 return MessageLoop::kTaskIdNull; in WatchFileDescriptor()
137 << (mode == MessageLoop::kWatchRead ? "reading" : "writing") in WatchFileDescriptor()
144 return MessageLoop::kTaskIdNull; in WatchFileDescriptor()
[all …]
Dglib_message_loop.h20 class BRILLO_EXPORT GlibMessageLoop : public MessageLoop {
29 using MessageLoop::PostDelayedTask;
35 using MessageLoop::WatchFileDescriptor;
68 MessageLoop::TaskId task_id;
74 std::map<MessageLoop::TaskId, ScheduledTask*> tasks_;
76 MessageLoop::TaskId last_id_ = kTaskIdNull;
Dglib_message_loop_unittest.cc25 using TaskId = MessageLoop::TaskId;
44 FROM_HERE, fd, MessageLoop::kWatchRead, true, in TEST_F()
46 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TEST_F()
57 FROM_HERE, fd, MessageLoop::kWatchRead, true, in TEST_F()
63 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TEST_F()
Dfake_message_loop_unittest.cc25 using TaskId = MessageLoop::TaskId;
42 EXPECT_FALSE(loop_->CancelTask(MessageLoop::kTaskIdNull)); in TEST_F()
94 FROM_HERE, fd, MessageLoop::kWatchRead, false, in TEST_F()
96 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TEST_F()
100 MessageLoop::kTaskIdNull, in TEST_F()
104 MessageLoop::kTaskIdNull, in TEST_F()
110 loop_->SetFileDescriptorReadiness(fd, MessageLoop::kWatchRead, true); in TEST_F()
Dmessage_loop.h17 class BRILLO_EXPORT MessageLoop {
19 virtual ~MessageLoop();
32 static MessageLoop* current();
123 MessageLoop() = default;
130 DISALLOW_COPY_AND_ASSIGN(MessageLoop);
/external/libchrome/base/timer/
Dtimer_unittest.cc25 const base::MessageLoop::Type testing_message_loops[] = {
26 base::MessageLoop::TYPE_DEFAULT,
27 base::MessageLoop::TYPE_IO,
29 base::MessageLoop::TYPE_UI,
57 base::MessageLoop::current()->QuitWhenIdle(); in Run()
81 base::MessageLoop::current()->QuitWhenIdle(); in Run()
103 base::MessageLoop::current()->QuitWhenIdle(); in Run()
113 void RunTest_OneShotTimer(base::MessageLoop::Type message_loop_type) { in RunTest_OneShotTimer()
114 base::MessageLoop loop(message_loop_type); in RunTest_OneShotTimer()
125 void RunTest_OneShotTimer_Cancel(base::MessageLoop::Type message_loop_type) { in RunTest_OneShotTimer_Cancel()
[all …]
/external/libmojo/mojo/android/system/
Dbase_run_loop.cc22 base::MessageLoop* message_loop = in CreateBaseRunLoop()
23 new base::MessageLoop(common::MessagePumpMojo::Create()); in CreateBaseRunLoop()
30 reinterpret_cast<base::MessageLoop*>(runLoopID)->Run(); in Run()
36 reinterpret_cast<base::MessageLoop*>(runLoopID)->RunUntilIdle(); in RunUntilIdle()
42 reinterpret_cast<base::MessageLoop*>(runLoopID)->QuitWhenIdle(); in Quit()
61 reinterpret_cast<base::MessageLoop*>(runLoopID)->PostDelayedTask( in PostDelayedTask()
69 base::MessageLoop* message_loop = in DeleteMessageLoop()
70 reinterpret_cast<base::MessageLoop*>(runLoopID); in DeleteMessageLoop()
/external/libchrome/base/threading/
Dthread.cc36 MessageLoop::current()->QuitWhenIdle(); in ThreadQuitHelper()
41 : message_loop_type(MessageLoop::TYPE_DEFAULT), in Options()
47 Thread::Options::Options(MessageLoop::Type type, in Options()
86 options.message_loop_type = MessageLoop::TYPE_UI; in Start()
95 (options.message_loop_type == MessageLoop::TYPE_UI)); in StartWithOptions()
104 MessageLoop::Type type = options.message_loop_type; in StartWithOptions()
106 type = MessageLoop::TYPE_CUSTOM; in StartWithOptions()
109 std::unique_ptr<MessageLoop> message_loop = in StartWithOptions()
110 MessageLoop::CreateUnbound(type, options.message_pump_factory); in StartWithOptions()
203 void Thread::Run(MessageLoop*) { in Run() argument
[all …]
Dthread.h47 Options(MessageLoop::Type type, size_t size);
53 MessageLoop::Type message_loop_type;
161 MessageLoop* message_loop() const { return message_loop_; } in message_loop()
194 virtual void Run(MessageLoop* message_loop);
202 void set_message_loop(MessageLoop* message_loop) { in set_message_loop()
243 MessageLoop* message_loop_;
/external/libbrillo/brillo/streams/
Dfile_stream.cc87 MessageLoop::current()->CancelTask(read_watcher_); in WaitForData()
88 read_watcher_ = MessageLoop::current()->WatchFileDescriptor( in WaitForData()
91 MessageLoop::WatchMode::kWatchRead, in WaitForData()
95 if (read_watcher_ == MessageLoop::kTaskIdNull) { in WaitForData()
105 MessageLoop::current()->CancelTask(write_watcher_); in WaitForData()
106 write_watcher_ = MessageLoop::current()->WatchFileDescriptor( in WaitForData()
109 MessageLoop::WatchMode::kWatchWrite, in WaitForData()
113 if (write_watcher_ == MessageLoop::kTaskIdNull) { in WaitForData()
158 if (read_watcher_ != MessageLoop::kTaskIdNull) { in CancelPendingAsyncOperations()
159 MessageLoop::current()->CancelTask(read_watcher_); in CancelPendingAsyncOperations()
[all …]
/external/libbrillo/brillo/
Dbinder_watcher.cc36 BinderWatcher::BinderWatcher(MessageLoop* message_loop) in BinderWatcher()
42 if (task_id_ != MessageLoop::kTaskIdNull) in ~BinderWatcher()
48 message_loop_ = MessageLoop::current(); in Init()
72 MessageLoop::kWatchRead, in Init()
75 if (task_id_ == MessageLoop::kTaskIdNull) { in Init()
Dbinder_watcher.h31 explicit BinderWatcher(MessageLoop* message_loop);
39 MessageLoop::TaskId task_id_{MessageLoop::kTaskIdNull};
40 MessageLoop* message_loop_;
Dasynchronous_signal_handler_unittest.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()
129 MessageLoop::current()->Run(); in TEST_F()
/external/libchrome/base/
Dobserver_list_unittest.cc110 loop_ = new MessageLoop(); // Fire up a message loop. in ThreadMain()
118 loop_ = reinterpret_cast<MessageLoop*>(0xdeadbeef); in ThreadMain()
148 MessageLoop::QuitWhenIdleClosure()); in Quit()
159 EXPECT_EQ(loop_, MessageLoop::current()); in Observe()
167 MessageLoop* loop_;
209 MessageLoop loop; in TEST()
239 MessageLoop loop; in TEST()
282 MessageLoop loop; in TEST()
311 MessageLoop loop; in TEST()
345 MessageLoop loop; in TEST()
[all …]

12345