Home
last modified time | relevance | path

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

1234

/external/chromium/base/
Dtimer_unittest.cc28 MessageLoop::current()->Quit(); in Run()
49 MessageLoop::current()->Quit(); in Run()
69 MessageLoop::current()->Quit(); in Run()
77 void RunTest_OneShotTimer(MessageLoop::Type message_loop_type) { in RunTest_OneShotTimer()
78 MessageLoop loop(message_loop_type); in RunTest_OneShotTimer()
84 MessageLoop::current()->Run(); in RunTest_OneShotTimer()
89 void RunTest_OneShotTimer_Cancel(MessageLoop::Type message_loop_type) { in RunTest_OneShotTimer_Cancel()
90 MessageLoop loop(message_loop_type); in RunTest_OneShotTimer_Cancel()
96 MessageLoop::current()->DeleteSoon(FROM_HERE, a); in RunTest_OneShotTimer_Cancel()
105 MessageLoop::current()->Run(); in RunTest_OneShotTimer_Cancel()
[all …]
Dmessage_loop_unittest.cc81 MessageLoop::current()->Quit(); in QuitNow()
90 void RunTest_PostTask(MessageLoop::Type message_loop_type) { in RunTest_PostTask()
91 MessageLoop loop(message_loop_type); in RunTest_PostTask()
96 MessageLoop::current()->PostTask(FROM_HERE, NewRunnableMethod( in RunTest_PostTask()
98 MessageLoop::current()->PostTask(FROM_HERE, NewRunnableMethod( in RunTest_PostTask()
100 MessageLoop::current()->PostTask(FROM_HERE, NewRunnableMethod( in RunTest_PostTask()
102 MessageLoop::current()->PostTask(FROM_HERE, NewRunnableMethod( in RunTest_PostTask()
104 MessageLoop::current()->PostTask(FROM_HERE, NewRunnableMethod( in RunTest_PostTask()
106 MessageLoop::current()->PostTask(FROM_HERE, NewRunnableMethod( in RunTest_PostTask()
111 MessageLoop::current()->PostTask(FROM_HERE, NewRunnableMethod( in RunTest_PostTask()
[all …]
Dwaitable_event_watcher_unittest.cc19 MessageLoop::current()->Quit(); in OnWaitableEventSignaled()
34 void RunTest_BasicSignal(MessageLoop::Type message_loop_type) { in RunTest_BasicSignal()
35 MessageLoop message_loop(message_loop_type); in RunTest_BasicSignal()
49 MessageLoop::current()->Run(); in RunTest_BasicSignal()
54 void RunTest_BasicCancel(MessageLoop::Type message_loop_type) { in RunTest_BasicCancel()
55 MessageLoop message_loop(message_loop_type); in RunTest_BasicCancel()
68 void RunTest_CancelAfterSet(MessageLoop::Type message_loop_type) { in RunTest_CancelAfterSet()
69 MessageLoop message_loop(message_loop_type); in RunTest_CancelAfterSet()
88 MessageLoop::current()->RunAllPending(); in RunTest_CancelAfterSet()
94 void RunTest_OutlivesMessageLoop(MessageLoop::Type message_loop_type) { in RunTest_OutlivesMessageLoop()
[all …]
Dobject_watcher_unittest.cc16 MessageLoop::current()->Quit(); in OnObjectSignaled()
33 void RunTest_BasicSignal(MessageLoop::Type message_loop_type) { in RunTest_BasicSignal()
34 MessageLoop message_loop(message_loop_type); in RunTest_BasicSignal()
49 MessageLoop::current()->Run(); in RunTest_BasicSignal()
55 void RunTest_BasicCancel(MessageLoop::Type message_loop_type) { in RunTest_BasicCancel()
56 MessageLoop message_loop(message_loop_type); in RunTest_BasicCancel()
73 void RunTest_CancelAfterSet(MessageLoop::Type message_loop_type) { in RunTest_CancelAfterSet()
74 MessageLoop message_loop(message_loop_type); in RunTest_CancelAfterSet()
94 MessageLoop::current()->RunAllPending(); in RunTest_CancelAfterSet()
102 void RunTest_OutlivesMessageLoop(MessageLoop::Type message_loop_type) { in RunTest_OutlivesMessageLoop()
[all …]
Dmessage_loop.cc32 static base::LazyInstance<base::ThreadLocalPointer<MessageLoop> > lazy_tls_ptr(
72 MessageLoop* MessageLoop::current() { in current()
79 MessageLoop::MessageLoop(Type type) in MessageLoop() function in MessageLoop
113 MessageLoop::~MessageLoop() { in ~MessageLoop()
143 void MessageLoop::AddDestructionObserver(DestructionObserver *obs) { in AddDestructionObserver()
148 void MessageLoop::RemoveDestructionObserver(DestructionObserver *obs) { in RemoveDestructionObserver()
153 void MessageLoop::Run() { in Run()
158 void MessageLoop::RunAllPending() { in RunAllPending()
169 void MessageLoop::RunHandler() { in RunHandler()
181 __declspec(noinline) void MessageLoop::RunInternalInSEHFrame() { in RunInternalInSEHFrame()
[all …]
Dmessage_loop.h59 class MessageLoop : public base::MessagePump::Delegate {
166 MessageLoop::current()->Quit(); in Run()
192 explicit MessageLoop(Type type = TYPE_DEFAULT);
193 ~MessageLoop();
206 static MessageLoop* current();
229 explicit ScopedNestableTaskAllower(MessageLoop* loop) in ScopedNestableTaskAllower()
239 MessageLoop* loop_;
279 explicit AutoRunState(MessageLoop* loop);
282 MessageLoop* loop_;
432 DISALLOW_COPY_AND_ASSIGN(MessageLoop);
[all …]
Dmessage_pump_glib_unittest.cc142 MessageLoop::current()->Quit(); in QuitMessageLoop()
153 MessageLoop::current()->PostTask(from_here, task); in PostMessageLoopTask()
162 loop_ = new MessageLoop(MessageLoop::TYPE_UI); in SetUp()
173 MessageLoop* loop() const { return loop_; } in loop()
177 MessageLoop* loop_;
310 MessageLoop::current()->Quit(); in FromTask()
312 MessageLoop::current()->PostTask( in FromTask()
322 MessageLoop::current()->Quit(); in FromEvent()
383 MessageLoop::current()->PostTask(FROM_HERE, NewRunnableFunction(DoNothing)); in AddEventsAndDrainGLib()
384 MessageLoop::current()->PostTask(FROM_HERE, NewRunnableFunction(DoNothing)); in AddEventsAndDrainGLib()
[all …]
Dthread.h24 MessageLoop::Type message_loop_type;
31 Options() : message_loop_type(MessageLoop::TYPE_DEFAULT), stack_size(0) {} in Options()
32 Options(MessageLoop::Type type, size_t size) in Options()
98 MessageLoop* message_loop() const { return message_loop_; } in message_loop()
118 virtual void Run(MessageLoop* message_loop);
126 void set_message_loop(MessageLoop* message_loop) { in set_message_loop()
151 MessageLoop* message_loop_;
Dobserver_list_threadsafe.h66 MessageLoop* loop = MessageLoop::current(); in AddObserver()
88 MessageLoop* loop = MessageLoop::current(); in RemoveObserver()
138 MessageLoop* loop = (*it).first; in Notify()
158 observer_lists_.find(MessageLoop::current()); in NotifyWrapper()
182 observer_lists_.find(MessageLoop::current()); in NotifyWrapper()
190 typedef std::map<MessageLoop*, ObserverList<ObserverType>*> ObserversListMap;
Dobject_watcher.cc17 MessageLoop* origin_loop; // Used to get back to the origin thread
52 watch->origin_loop = MessageLoop::current(); in StartWatching()
71 MessageLoop::current()->AddDestructionObserver(this); in StartWatching()
80 DCHECK(watch_->origin_loop == MessageLoop::current()); in StopWatching()
106 MessageLoop::current()->RemoveDestructionObserver(this); in StopWatching()
Dobserver_list_unittest.cc109 loop_ = new MessageLoop(); // Fire up a message loop. in ThreadMain()
116 loop_ = reinterpret_cast<MessageLoop*>(0xdeadbeef); in ThreadMain()
144 loop_->PostTask(FROM_HERE, new MessageLoop::QuitTask()); in Quit()
155 EXPECT_EQ(loop_, MessageLoop::current()); in Observe()
163 MessageLoop* loop_;
200 MessageLoop loop; in TEST()
237 MessageLoop loop; in ThreadSafeObserverHarness()
Ddirectory_watcher_mac.cc31 MessageLoop* backend_loop, bool recursive);
75 MessageLoop* backend_loop, in Watch()
79 DCHECK(MessageLoop::current()->type() == MessageLoop::TYPE_UI); in Watch()
Ddirectory_watcher_unittest.cc31 : loop_(MessageLoop::TYPE_UI), in DirectoryWatcherTest()
39 MessageLoop::current()->Quit(); in OnTestDelegateFirstNotification()
94 loop_.PostDelayedTask(FROM_HERE, new MessageLoop::QuitTask, in VerifyNoExtraNotifications()
110 MessageLoop loop_;
264 Deleter(DirectoryWatcher* watcher, MessageLoop* loop) in Deleter()
271 loop_->PostTask(FROM_HERE, new MessageLoop::QuitTask()); in OnDirectoryChanged()
275 MessageLoop* loop_;
Ddirectory_watcher.h14 class MessageLoop; variable
42 MessageLoop* backend_loop, bool recursive) { in Watch()
50 MessageLoop* backend_loop, bool recursive) = 0;
/external/chromium/net/url_request/
Durl_request_unittest.cc138 MessageLoop::current()->Run(); in HTTPUploadDataOperationTest()
173 MessageLoop::current()->Run(); in TEST_F()
198 MessageLoop::current()->Run(); in TEST_F()
214 MessageLoop::current()->Run(); in TEST_F()
242 MessageLoop::current()->Run(); in TEST_F()
265 MessageLoop::current()->Run(); in TEST_F()
337 MessageLoop::current()->Run(); in TEST_F()
360 MessageLoop::current()->Run(); in TEST_F()
390 MessageLoop::current()->Run(); in TEST_F()
413 MessageLoop::current()->Run(); in TEST_F()
[all …]
Durl_request_unittest.h69 MessageLoop::current()->PostTask(FROM_HERE, in CanGetCookies()
86 MessageLoop::current()->PostTask(FROM_HERE, in CanSetCookie()
208 MessageLoop::current()->Quit(); in OnReceivedRedirect()
275 MessageLoop::current()->Quit(); in OnResponseCompleted()
441 MessageLoop::current()->DeleteSoon(FROM_HERE, request); in OnResponseCompleted()
483 MessageLoop* loop) { in CreateServer()
489 MessageLoop* loop, in CreateServer()
500 MessageLoop* loop) { in CreateServerWithFileRootURL()
522 MessageLoop* loop, in CreateServerWithFileRootURL()
553 MessageLoop* loop = loop_; in MakeGETRequest()
[all …]
/external/chromium/net/base/
Dnetwork_change_notifier_mac.cc45 NetworkChangeNotifierImpl(MessageLoop* notifier_loop,
66 MessageLoop* const notifier_loop_;
75 MessageLoop* notifier_loop, NetworkChangeNotifierMac* notifier) in NetworkChangeNotifierImpl()
78 DCHECK_EQ(MessageLoop::TYPE_UI, MessageLoop::current()->type()); in NetworkChangeNotifierImpl()
183 NetworkChangeNotifierThread(MessageLoop* notifier_loop,
191 MessageLoop* const notifier_loop_;
199 MessageLoop* notifier_loop, NetworkChangeNotifierMac* notifier) in NetworkChangeNotifierThread()
222 new NetworkChangeNotifierThread(MessageLoop::current(), this)) { in NetworkChangeNotifierMac()
224 thread_options.message_loop_type = MessageLoop::TYPE_UI; in NetworkChangeNotifierMac()
/external/chromium/net/proxy/
Dproxy_config_service_linux.h45 virtual bool Init(MessageLoop* glib_default_loop,
59 virtual MessageLoop* GetNotificationLoop() = 0;
121 void SetupAndFetchInitialConfig(MessageLoop* glib_default_loop,
122 MessageLoop* io_loop,
193 MessageLoop* glib_default_loop_;
196 MessageLoop* io_loop_;
215 void SetupAndFetchInitialConfig(MessageLoop* glib_default_loop, in SetupAndFetchInitialConfig()
216 MessageLoop* io_loop, in SetupAndFetchInitialConfig()
Dproxy_config_service_linux.cc190 if (MessageLoop::current() == loop_) { in ~GConfSettingGetterImplGConf()
204 virtual bool Init(MessageLoop* glib_default_loop, in Init()
206 DCHECK(MessageLoop::current() == glib_default_loop); in Init()
237 DCHECK(MessageLoop::current() == loop_); in Shutdown()
247 DCHECK(MessageLoop::current() == loop_); in SetupNotification()
269 virtual MessageLoop* GetNotificationLoop() { in GetNotificationLoop()
279 DCHECK(MessageLoop::current() == loop_); in GetString()
292 DCHECK(MessageLoop::current() == loop_); in GetBoolean()
315 DCHECK(MessageLoop::current() == loop_); in GetInt()
328 DCHECK(MessageLoop::current() == loop_); in GetStringList()
[all …]
Dproxy_resolver_js_bindings.cc27 MessageLoop* host_resolver_loop) in SyncHostResolverBridge()
64 DCHECK_EQ(host_resolver_loop_, MessageLoop::current()); in StartResolve()
73 DCHECK_EQ(host_resolver_loop_, MessageLoop::current()); in OnResolveCompletion()
79 MessageLoop* host_resolver_loop_;
95 MessageLoop* host_resolver_loop) in DefaultJSBindings()
182 HostResolver* host_resolver, MessageLoop* host_resolver_loop) { in CreateDefault()
Dproxy_service.h21 class MessageLoop; variable
164 MessageLoop* io_loop);
177 MessageLoop* io_loop, MessageLoop* file_loop);
318 SyncProxyServiceHelper(MessageLoop* io_message_loop,
335 MessageLoop* io_message_loop_;
/external/chromium/net/socket_stream/
Dsocket_stream.cc67 DCHECK(MessageLoop::current()) << in SocketStream()
69 DCHECK_EQ(MessageLoop::TYPE_IO, MessageLoop::current()->type()) << in SocketStream()
116 DCHECK(MessageLoop::current()) << in Connect()
118 DCHECK_EQ(MessageLoop::TYPE_IO, MessageLoop::current()->type()) << in Connect()
129 MessageLoop::current()->PostTask( in Connect()
135 DCHECK(MessageLoop::current()) << in SendData()
137 DCHECK_EQ(MessageLoop::TYPE_IO, MessageLoop::current()->type()) << in SendData()
163 MessageLoop::current()->PostTask( in SendData()
170 DCHECK(MessageLoop::current()) << in Close()
172 DCHECK_EQ(MessageLoop::TYPE_IO, MessageLoop::current()->type()) << in Close()
[all …]
/external/chromium/net/ocsp/
Dnss_ocsp.cc66 class OCSPInitSingleton : public MessageLoop::DestructionObserver {
130 MessageLoop* io_loop_; // I/O thread
147 public MessageLoop::DestructionObserver {
404 MessageLoop* io_loop_; // Message loop of the IO thread
455 DCHECK(!MessageLoop::current()); in OCSPCreateSession()
467 DCHECK(!MessageLoop::current()); in OCSPKeepAliveSession()
475 DCHECK(!MessageLoop::current()); in OCSPFreeSession()
490 DCHECK(!MessageLoop::current()); in OCSPCreate()
512 DCHECK(!MessageLoop::current()); in OCSPSetPostData()
524 DCHECK(!MessageLoop::current()); in OCSPAddHeader()
[all …]
/external/chromium/net/disk_cache/
Dstress_cache.cc127 MessageLoop::current()->RunAllPending(); in StressTheCache()
142 RunSoon(MessageLoop::current()); in Run()
160 static void RunSoon(MessageLoop* target_loop) { in RunSoon()
195 MessageLoop message_loop(MessageLoop::TYPE_IO); in main()
/external/chromium/net/websockets/
Dwebsocket.cc39 origin_loop_(MessageLoop::current()), in WebSocket()
61 DCHECK(MessageLoop::current() == origin_loop_); in Connect()
78 DCHECK(MessageLoop::current() == origin_loop_); in Send()
90 DCHECK(MessageLoop::current() == origin_loop_); in Close()
337 DCHECK(MessageLoop::current() == origin_loop_); in SendPending()
354 DCHECK(MessageLoop::current() == origin_loop_); in DoReceivedData()
477 DCHECK(MessageLoop::current() == origin_loop_); in DoClose()
490 DCHECK(MessageLoop::current() == origin_loop_); in DoError()

1234