Searched refs:MessageLoopCurrent (Results 1 – 18 of 18) sorted by relevance
29 MessageLoopCurrent MessageLoopCurrent::Get() { in Get()30 return MessageLoopCurrent(GetTLSMessageLoop()->Get()); in Get()34 bool MessageLoopCurrent::IsSet() { in IsSet()38 void MessageLoopCurrent::AddDestructionObserver( in AddDestructionObserver()44 void MessageLoopCurrent::RemoveDestructionObserver( in RemoveDestructionObserver()50 const scoped_refptr<SingleThreadTaskRunner>& MessageLoopCurrent::task_runner() in task_runner()56 void MessageLoopCurrent::SetTaskRunner( in SetTaskRunner()62 bool MessageLoopCurrent::IsIdleForTesting() { in IsIdleForTesting()67 void MessageLoopCurrent::AddTaskObserver(TaskObserver* task_observer) { in AddTaskObserver()72 void MessageLoopCurrent::RemoveTaskObserver(TaskObserver* task_observer) { in RemoveTaskObserver()[all …]
38 class BASE_EXPORT MessageLoopCurrent {42 MessageLoopCurrent(const MessageLoopCurrent& other) = default;43 MessageLoopCurrent& operator=(const MessageLoopCurrent& other) = default;47 static MessageLoopCurrent Get();57 MessageLoopCurrent* operator->() { return this; }188 explicit MessageLoopCurrent(MessageLoop* current) : current_(current) {} in MessageLoopCurrent() function196 class BASE_EXPORT MessageLoopCurrentForUI : public MessageLoopCurrent {237 : MessageLoopCurrent(current), pump_(pump) { in MessageLoopCurrentForUI()247 class BASE_EXPORT MessageLoopCurrentForIO : public MessageLoopCurrent {288 : MessageLoopCurrent(current), pump_(pump) { in MessageLoopCurrentForIO()
178 DCHECK((pump_ && MessageLoopCurrent::IsBoundToCurrentThreadInternal(this)) || in ~MessageLoop()179 (!pump_ && !MessageLoopCurrent::IsBoundToCurrentThreadInternal(this))); in ~MessageLoop()188 (!pump_ && !MessageLoopCurrent::IsBoundToCurrentThreadInternal(this)) || in ~MessageLoop()226 if (MessageLoopCurrent::IsBoundToCurrentThreadInternal(this)) in ~MessageLoop()227 MessageLoopCurrent::UnbindFromCurrentThreadInternal(this); in ~MessageLoop()231 MessageLoopCurrent MessageLoop::current() { in current()232 return MessageLoopCurrent::Get(); in current()322 : MessageLoopCurrent(this), in MessageLoop()347 DCHECK(!MessageLoopCurrent::IsSet()) in BindToCurrentThread()349 MessageLoopCurrent::BindToCurrentThreadInternal(this); in BindToCurrentThread()
88 public MessageLoopCurrent {92 using DestructionObserver = MessageLoopCurrent::DestructionObserver;137 static MessageLoopCurrent current();186 using TaskObserver = MessageLoopCurrent::TaskObserver;225 friend class MessageLoopCurrent; variable
241 MessageLoopCurrent::Get()->SetNestableTasksAllowed(true); in RecursiveFunc()404 MessageLoopCurrent::Get()->SetNestableTasksAllowed(true); in SubPumpFunc()462 MessageLoopCurrent::Get()->SetNestableTasksAllowed(true); in MessageBoxFunc()1116 MessageLoopCurrent::Get()->SetNestableTasksAllowed(true); in NestingFunc()1137 EXPECT_TRUE(MessageLoopCurrent::Get()->NestableTasksAllowed()); in TEST_P()1186 EXPECT_TRUE(MessageLoopCurrent::Get()->NestableTasksAllowed()); in TEST_P()1335 MessageLoopCurrent::ScopedNestableTaskAllower allow; in FuncThatRuns()1687 EXPECT_TRUE(MessageLoopCurrent::Get()->NestableTasksAllowed()); in TEST_P()1699 EXPECT_FALSE(MessageLoopCurrent::Get()->NestableTasksAllowed()); in TEST_P()1727 MessageLoopCurrent::Get()->NestableTasksAllowed()); in TEST_P()[all …]
456 MessageLoopCurrent::Get()->SetNestableTasksAllowed(true); in TestGLibLoopInternal()489 MessageLoopCurrent::Get()->SetNestableTasksAllowed(true); in TestGtkLoopInternal()
71 public base::MessageLoopCurrent::DestructionObserver {75 base::MessageLoopCurrent::Get()->AddDestructionObserver(this); in RunLoopNestingObserver()89 base::MessageLoopCurrent::Get()->RemoveDestructionObserver(this); in WillDestroyCurrentMessageLoop()96 if (!base::MessageLoopCurrent::Get()) in GetForThread()
33 public base::MessageLoopCurrent::DestructionObserver,139 base::MessageLoopCurrent::Get()->AddDestructionObserver(this); in StartOnIOThread()182 base::MessageLoopCurrent::Get()->RemoveDestructionObserver(this); in ShutDownOnIOThread()
36 base::MessageLoopCurrent::Get()->AddDestructionObserver(this); in BrokerHost()45 base::MessageLoopCurrent::Get()->RemoveDestructionObserver(this); in ~BrokerHost()
192 public base::MessageLoopCurrent::DestructionObserver,292 base::MessageLoopCurrent::Get()->AddDestructionObserver(this); in StartOnIOThread()302 base::MessageLoopCurrent::Get()->RemoveDestructionObserver(this); in ShutDownOnIOThread()
29 public base::MessageLoopCurrent::DestructionObserver {
98 public base::MessageLoopCurrent::DestructionObserver,297 base::MessageLoopCurrent::Get()->AddDestructionObserver(this); in StartOnIOThread()336 base::MessageLoopCurrent::Get()->RemoveDestructionObserver(this); in ShutDownOnIOThread()428 base::MessageLoopCurrent::Get()->RemoveDestructionObserver(this); in OnFileCanReadWithoutBlocking()
114 : public base::MessageLoopCurrent::DestructionObserver {130 base::MessageLoopCurrent::Get()->AddDestructionObserver(this); in ThreadDestructionObserver()134 base::MessageLoopCurrent::Get()->RemoveDestructionObserver(this); in ~ThreadDestructionObserver()
22 friend class MessageLoopCurrent;
104 : public base::MessageLoopCurrent::DestructionObserver {125 base::MessageLoopCurrent::DestructionObserver* observer) { in RegisterDestructionObserver()126 base::MessageLoopCurrent::Get()->AddDestructionObserver(observer); in RegisterDestructionObserver()
47 public MessageLoopCurrent::DestructionObserver {
796 base::MessageLoopCurrent::Get()->task_runner()->PostTask( in RunSingleThreadPostTaskPingPongServer()807 base::MessageLoopCurrent::Get()->task_runner()->PostTask( in SingleThreadPingPostTask()831 base::MessageLoopCurrent::Get()->task_runner()->PostTask( in SingleThreadPongPostTask()
86 base::MessageLoopCurrent::Get()->SetNestableTasksAllowed(true); in RunTest()