| /external/libchrome/base/message_loop/ |
| message_loop_unittest.cc | 39 // TODO(darin): Platform-specific MessageLoop tests should be grouped together
45 return MessageLoop::CreateMessagePumpForType(MessageLoop::TYPE_DEFAULT);
49 return MessageLoop::CreateMessagePumpForType(MessageLoop::TYPE_IO);
53 return MessageLoop::CreateMessagePumpForType(MessageLoop::TYPE_UI);
84 MessageLoop::current()->QuitWhenIdle();
88 // useful for building a variety of MessageLoop tests.
99 MessageLoop::current()->SetNestableTasksAllowed(true)
[all...] |
| message_pump_glib_unittest.cc | 155 MessageLoop::current()->PostTask(from_here, task);
165 loop_ = new MessageLoop(MessageLoop::TYPE_UI);
175 MessageLoop* loop() const { return loop_; }
179 MessageLoop* loop_;
195 injector()->AddEvent(0, MessageLoop::QuitWhenIdleClosure());
203 // MessageLoop doesn't make strong guarantees that it is the case, but the
215 injector()->AddEvent(0, MessageLoop::QuitWhenIdleClosure());
226 injector()->AddEvent(0, MessageLoop::QuitWhenIdleClosure());
243 MessageLoop::QuitWhenIdleClosure()))
[all...] |
| incoming_task_queue.cc | 29 // time for every task that is added to the MessageLoop incoming queue.
31 bool AlwaysNotifyPump(MessageLoop::Type type) {
34 return type == MessageLoop::TYPE_UI || type == MessageLoop::TYPE_JAVA;
37 bool AlwaysNotifyPump(MessageLoop::Type /* type */) {
44 IncomingTaskQueue::IncomingTaskQueue(MessageLoop* message_loop)
156 message_loop_->task_annotator()->DidQueueTask("MessageLoop::PostTask",
|
| /external/libchrome/base/threading/ |
| thread.cc | 26 // MessageLoop::QuitWhenIdle() is called directly, which is unexpected when
27 // using a Thread to setup and run a MessageLoop.
35 MessageLoop::current()->QuitWhenIdle();
40 : message_loop_type(MessageLoop::TYPE_DEFAULT),
46 Thread::Options::Options(MessageLoop::Type type,
81 options.message_loop_type = MessageLoop::TYPE_UI;
90 (options.message_loop_type == MessageLoop::TYPE_UI));
99 MessageLoop::Type type = options.message_loop_type;
101 type = MessageLoop::TYPE_CUSTOM;
104 scoped_ptr<MessageLoop> message_loop = MessageLoop::CreateUnbound
[all...] |
| thread.h | 28 // A simple thread abstraction that establishes a MessageLoop on a new thread.
29 // The consumer uses the MessageLoop of the thread to cause code to execute on
39 // (2) MessageLoop::~MessageLoop
40 // (3.b) MessageLoop::DestructionObserver::WillDestroyCurrentMessageLoop
47 Options(MessageLoop::Type type, size_t size);
52 MessageLoop::Type message_loop_type;
57 // Used to create the MessagePump for the MessageLoop. The callback is Run()
60 // MessageLoop::Type to TYPE_CUSTOM.
152 // Returns the message loop for this thread. Use the MessageLoop'
[all...] |
| /external/libchrome/base/ |
| run_loop.h | 28 // Helper class to Run a nested MessageLoop. Please do not use nested
30 // calling MessageLoop::Run/Quit directly. RunLoop::Run can only be called once
32 // a nested MessageLoop.
41 // Run the current MessageLoop. This blocks until Quit is called. Before
43 // stop the MessageLoop asynchronously. MessageLoop::QuitWhenIdle and QuitNow
47 // Run the current MessageLoop until it doesn't find any tasks or messages in
55 // the same task queue (MessageLoop); Quitting one RunLoop has no bearing on
76 friend class MessageLoop;
78 // Android doesn't support the blocking MessageLoop::Run, so it call
[all...] |
| task_runner_util_unittest.cc | 73 MessageLoop message_loop;
86 MessageLoop message_loop;
100 MessageLoop message_loop;
114 MessageLoop message_loop;
|
| /external/libchrome/base/test/ |
| sequenced_worker_pool_owner.h | 23 class MessageLoop;
58 MessageLoop* const constructor_message_loop_;
|
| /external/libbrillo/brillo/message_loops/ |
| glib_message_loop.cc | 31 MessageLoop::TaskId GlibMessageLoop::PostDelayedTask(
53 MessageLoop::TaskId GlibMessageLoop::WatchFileDescriptor(
61 return MessageLoop::kTaskIdNull;
65 case MessageLoop::kWatchRead:
68 case MessageLoop::kWatchWrite:
72 return MessageLoop::kTaskIdNull;
80 return MessageLoop::kTaskIdNull;
91 return MessageLoop::kTaskIdNull;
111 << (mode == MessageLoop::kWatchRead ? "reading" : "writing")
118 return MessageLoop::kTaskIdNull
[all...] |
| fake_message_loop_unittest.cc | 25 using TaskId = MessageLoop::TaskId;
42 EXPECT_FALSE(loop_->CancelTask(MessageLoop::kTaskIdNull));
91 FROM_HERE, fd, MessageLoop::kWatchRead, false,
93 EXPECT_NE(MessageLoop::kTaskIdNull, task_id);
95 EXPECT_NE(MessageLoop::kTaskIdNull,
98 EXPECT_NE(MessageLoop::kTaskIdNull,
104 loop_->SetFileDescriptorReadiness(fd, MessageLoop::kWatchRead, true);
|
| base_message_loop.cc | 72 MessageLoop::TaskId BaseMessageLoop::PostDelayedTask(
86 return MessageLoop::kTaskIdNull;
93 MessageLoop::TaskId BaseMessageLoop::WatchFileDescriptor(
101 return MessageLoop::kTaskIdNull;
105 case MessageLoop::kWatchRead:
108 case MessageLoop::kWatchWrite:
112 return MessageLoop::kTaskIdNull;
126 << (mode == MessageLoop::kWatchRead ? "reading" : "writing")
133 return MessageLoop::kTaskIdNull;
223 MessageLoop::TaskId BaseMessageLoop::NextTaskId()
[all...] |
| fake_message_loop.cc | 16 MessageLoop::TaskId FakeMessageLoop::PostDelayedTask(
25 MessageLoop::TaskId current_id = ++last_id_;
36 MessageLoop::TaskId FakeMessageLoop::WatchFileDescriptor(
42 MessageLoop::TaskId current_id = ++last_id_;
51 if (task_id == MessageLoop::kTaskIdNull)
76 << (fd_mode.second == MessageLoop::kWatchRead ? "reading" : "writing")
|
| mock_message_loop.h | 20 // The MockMessageLoop is a mockable MessageLoop that will by default act as a
26 class BRILLO_EXPORT MockMessageLoop : public MessageLoop {
64 using MessageLoop::PostDelayedTask;
71 using MessageLoop::WatchFileDescriptor;
|
| /system/bt/service/ |
| daemon.h | 58 virtual base::MessageLoop* GetMessageLoop() const = 0;
|
| /system/bt/service/test/ |
| mock_daemon.h | 32 MOCK_CONST_METHOD0(GetMessageLoop, base::MessageLoop*());
|
| /external/libbrillo/brillo/ |
| asynchronous_signal_handler.h | 47 MessageLoop::TaskId fd_watcher_task_{MessageLoop::kTaskIdNull};
|
| asynchronous_signal_handler_unittest.cc | 60 MessageLoop::current()->Run();
76 MessageLoop::current()->Run();
85 base::Bind(&MessageLoop::BreakLoop,
88 MessageLoop::current()->Run();
107 MessageLoop::current()->Run();
129 MessageLoop::current()->Run();
|
| asynchronous_signal_handler.cc | 32 MessageLoop::current()->CancelTask(fd_watcher_task_);
48 fd_watcher_task_ = MessageLoop::current()->WatchFileDescriptor(
51 MessageLoop::WatchMode::kWatchRead,
55 CHECK(fd_watcher_task_ != MessageLoop::kTaskIdNull)
|
| /external/libchrome/base/synchronization/ |
| waitable_event_watcher.h | 30 // MessageLoop. This callback can be deleted by deleting the waiter.
65 : public MessageLoop::DestructionObserver {
98 // Implementation of MessageLoop::DestructionObserver
101 MessageLoop* message_loop_;
|
| /external/libchrome/base/timer/ |
| hi_res_timer_manager_unittest.cc | 24 base::MessageLoop loop(base::MessageLoop::TYPE_UI);
|
| /system/update_engine/ |
| proxy_resolver.h | 74 brillo::MessageLoop::TaskId idle_callback_id_{
75 brillo::MessageLoop::kTaskIdNull};
|
| chrome_browser_proxy_resolver.cc | 34 using brillo::MessageLoop;
68 MessageLoop::current()->CancelTask(timer.second);
69 timer.second = MessageLoop::kTaskIdNull;
88 MessageLoop::TaskId timer = MessageLoop::current()->PostDelayedTask(
115 MessageLoop::current()->CancelTask(it->second);
|
| /system/core/metricsd/uploader/ |
| metricsd_service_runner.h | 43 std::unique_ptr<brillo::MessageLoop> message_loop_;
|
| /system/connectivity/shill/ |
| event_dispatcher.cc | 40 base::MessageLoop::current()->Run();
48 base::MessageLoop::current()->PostTask(FROM_HERE, task);
52 base::MessageLoop::current()->PostDelayedTask(
|
| /system/update_engine/update_manager/ |
| generic_variables_unittest.cc | 29 using brillo::MessageLoop;
175 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
183 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
203 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
208 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
213 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
218 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
|
