| /third_party/flutter/engine/flutter/fml/ |
| D | message_loop.cc | 17 FML_THREAD_LOCAL ThreadLocalUniquePtr<MessageLoop> tls_message_loop;
19 MessageLoop& MessageLoop::GetCurrent() { in GetCurrent()
27 void MessageLoop::EnsureInitializedForCurrentThread() { in EnsureInitializedForCurrentThread()
32 tls_message_loop.reset(new MessageLoop()); in EnsureInitializedForCurrentThread()
35 bool MessageLoop::IsInitializedForCurrentThread() { in IsInitializedForCurrentThread()
39 MessageLoop::MessageLoop() in MessageLoop() function in fml::MessageLoop
46 MessageLoop::~MessageLoop() = default;
48 void MessageLoop::Run() { in Run()
52 void MessageLoop::Terminate() { in Terminate()
56 fml::RefPtr<fml::TaskRunner> MessageLoop::GetTaskRunner() const { in GetTaskRunner()
[all …]
|
| D | message_loop_unittests.cc | 24 TEST(MessageLoop, GetCurrent) { in TEST() argument
26 fml::MessageLoop::EnsureInitializedForCurrentThread(); in TEST()
27 ASSERT_TRUE(fml::MessageLoop::GetCurrent().GetTaskRunner()); in TEST()
32 TEST(MessageLoop, DifferentThreadsHaveDifferentLoops) { in TEST() argument
33 fml::MessageLoop* loop1 = nullptr; in TEST()
37 fml::MessageLoop::EnsureInitializedForCurrentThread(); in TEST()
38 loop1 = &fml::MessageLoop::GetCurrent(); in TEST()
43 fml::MessageLoop* loop2 = nullptr; in TEST()
47 fml::MessageLoop::EnsureInitializedForCurrentThread(); in TEST()
48 loop2 = &fml::MessageLoop::GetCurrent(); in TEST()
[all …]
|
| D | gpu_thread_merger_unittests.cc | 18 fml::MessageLoop* loop1 = nullptr; in TEST()
22 fml::MessageLoop::EnsureInitializedForCurrentThread(); in TEST()
23 loop1 = &fml::MessageLoop::GetCurrent(); in TEST()
28 fml::MessageLoop* loop2 = nullptr; in TEST()
32 fml::MessageLoop::EnsureInitializedForCurrentThread(); in TEST()
33 loop2 = &fml::MessageLoop::GetCurrent(); in TEST()
65 fml::MessageLoop* loop1 = nullptr; in TEST()
68 fml::MessageLoop::EnsureInitializedForCurrentThread(); in TEST()
69 loop1 = &fml::MessageLoop::GetCurrent(); in TEST()
74 fml::MessageLoop* loop2 = nullptr; in TEST()
[all …]
|
| D | message_loop.h | 16 class MessageLoop {
19 static MessageLoop& GetCurrent();
41 ~MessageLoop();
52 MessageLoop();
56 FML_DISALLOW_COPY_AND_ASSIGN(MessageLoop);
|
| D | thread.cc | 31 fml::MessageLoop::EnsureInitializedForCurrentThread(); in Thread()
32 auto& loop = MessageLoop::GetCurrent(); in Thread()
54 task_runner_->PostTask([]() { MessageLoop::GetCurrent().Terminate(); }); in Join()
|
| D | task_runner.cc | 42 if (!fml::MessageLoop::IsInitializedForCurrentThread()) { in RunsTasksOnCurrentThread()
46 const auto current_queue_id = MessageLoop::GetCurrentTaskQueueId(); in RunsTasksOnCurrentThread()
|
| D | message_loop_impl.cc | 70 FML_DCHECK(MessageLoop::GetCurrent().GetLoopImpl().get() == this) in AddTaskObserver()
81 FML_DCHECK(MessageLoop::GetCurrent().GetLoopImpl().get() == this) in RemoveTaskObserver()
|
| D | message_loop_impl.h | 53 friend class MessageLoop;
|
| D | gpu_thread_merger.cc | 32 const auto current_queue_id = MessageLoop::GetCurrentTaskQueueId(); in IsOnRasterizingThread()
|
| /third_party/flutter/engine/flutter/shell/testing/ |
| D | tester_main.cc | 60 []() { fml::MessageLoop::GetCurrent().Terminate(); }); in DidProcessTask()
77 fml::MessageLoop::EnsureInitializedForCurrentThread(); in RunTester()
79 auto current_task_runner = fml::MessageLoop::GetCurrent().GetTaskRunner(); in RunTester()
157 fml::MessageLoop::GetCurrent() in RunTester()
164 fml::MessageLoop::GetCurrent().AddTaskObserver( in RunTester()
182 fml::MessageLoop::GetCurrent().Run(); in RunTester()
186 fml::MessageLoop::GetCurrent().RemoveTaskObserver( in RunTester()
231 fml::MessageLoop::GetCurrent().AddTaskObserver(key, std::move(callback)); in main()
235 fml::MessageLoop::GetCurrent().RemoveTaskObserver(key); in main()
|
| /third_party/flutter/engine/flutter/shell/platform/android/ |
| D | flutter_main.cc | 97 fml::MessageLoop::GetCurrent().AddTaskObserver(key, std::move(callback)); in Init()
101 fml::MessageLoop::GetCurrent().RemoveTaskObserver(key); in Init()
143 fml::MessageLoop::EnsureInitializedForCurrentThread(); in SetupObservatoryUriCallback()
145 fml::MessageLoop::GetCurrent().GetTaskRunner(); in SetupObservatoryUriCallback()
|
| D | android_shell_holder.cc | 81 fml::MessageLoop::EnsureInitializedForCurrentThread(); in AndroidShellHolder()
86 fml::MessageLoop::GetCurrent().GetTaskRunner(); in AndroidShellHolder()
|
| /third_party/flutter/engine/flutter/testing/ |
| D | thread_test.cc | 17 fml::MessageLoop::EnsureInitializedForCurrentThread(); in SetUp()
18 current_task_runner_ = fml::MessageLoop::GetCurrent().GetTaskRunner(); in SetUp()
|
| /third_party/flutter/engine/flutter/shell/platform/embedder/ |
| D | embedder_thread_host.cc | 106 fml::MessageLoop::EnsureInitializedForCurrentThread(); in GetCurrentThreadTaskRunner()
107 return fml::MessageLoop::GetCurrent().GetTaskRunner(); in GetCurrentThreadTaskRunner()
|
| D | ace_embedder.cc | 559 fml::MessageLoop::GetCurrent().AddTaskObserver(key, std::move(callback)); in FlutterEngineInitialize()
562 fml::MessageLoop::GetCurrent().RemoveTaskObserver(key); in FlutterEngineInitialize()
1013 fml::MessageLoop::GetCurrent().RunExpiredTasksNow(); in __FlutterEngineFlushPendingTasksNow()
|
| D | embedder.cc | 646 fml::MessageLoop::GetCurrent().AddTaskObserver(key, std::move(callback)); in FlutterEngineInitialize()
649 fml::MessageLoop::GetCurrent().RemoveTaskObserver(key); in FlutterEngineInitialize()
1210 fml::MessageLoop::GetCurrent().RunExpiredTasksNow(); in __FlutterEngineFlushPendingTasksNow()
|
| /third_party/flutter/engine/flutter/shell/common/ |
| D | shell_test.cc | 151 fml::MessageLoop::GetCurrent().AddTaskObserver(key, handler); in CreateSettingsForFixture()
154 fml::MessageLoop::GetCurrent().RemoveTaskObserver(key); in CreateSettingsForFixture()
|
| D | shell_unittests.cc | 98 fml::MessageLoop::EnsureInitializedForCurrentThread(); in TEST_F()
99 auto task_runner = fml::MessageLoop::GetCurrent().GetTaskRunner(); in TEST_F()
116 fml::MessageLoop::EnsureInitializedForCurrentThread(); in TEST_F()
118 fml::MessageLoop::GetCurrent().GetTaskRunner(), in TEST_F()
|
| /third_party/flutter/engine/flutter/shell/platform/darwin/ios/framework/Source/ |
| D | FlutterObservatoryPublisher.mm | 60 fml::MessageLoop::EnsureInitializedForCurrentThread();
64 runner = fml::MessageLoop::GetCurrent().GetTaskRunner()](const std::string& uri) {
|
| D | FlutterDartProject.mm | 50 fml::MessageLoop::GetCurrent().AddTaskObserver(key, std::move(callback));
54 fml::MessageLoop::GetCurrent().RemoveTaskObserver(key);
|
| D | FlutterEngine.mm | 282 fml::MessageLoop::EnsureInitializedForCurrentThread();
311 fml::MessageLoop::GetCurrent().GetTaskRunner(), // platform
312 fml::MessageLoop::GetCurrent().GetTaskRunner(), // gpu
324 fml::MessageLoop::GetCurrent().GetTaskRunner(), // platform
|
| /third_party/flutter/engine/flutter/shell/platform/ohos/ |
| D | ohos_shell_holder.cc | 69 fml::MessageLoop::EnsureInitializedForCurrentThread(); in OhosShellHolder()
|
| /third_party/flutter/engine/flutter/shell/platform/embedder/tests/ |
| D | embedder_a11y_unittests.cc | 155 fml::MessageLoop::GetCurrent().RunExpiredTasksNow(); in TEST_F()
|
| D | embedder_unittests.cc | 183 fml::MessageLoop::GetCurrent().GetTaskRunner()); in TEST_F()
239 fml::MessageLoop::GetCurrent().GetTaskRunner()); in TEST_F()
|
| /third_party/cef/patch/ |
| D | patch.cfg | 50 # Revert change on Windows that removes MessageLoop::os_modal_loop().
56 # Add MessageLoop::ReleasePump to fix crashes during shutdown with multi-
|