/external/chromium/base/ |
D | timer_unittest.cc | 28 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 …]
|
D | message_loop_unittest.cc | 81 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 …]
|
D | waitable_event_watcher_unittest.cc | 19 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 …]
|
D | object_watcher_unittest.cc | 16 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 …]
|
D | message_loop.cc | 32 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 …]
|
D | message_loop.h | 59 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 …]
|
D | message_pump_glib_unittest.cc | 142 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 …]
|
D | thread.h | 24 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_;
|
D | observer_list_threadsafe.h | 66 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;
|
D | object_watcher.cc | 17 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()
|
D | observer_list_unittest.cc | 109 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()
|
D | directory_watcher_mac.cc | 31 MessageLoop* backend_loop, bool recursive); 75 MessageLoop* backend_loop, in Watch() 79 DCHECK(MessageLoop::current()->type() == MessageLoop::TYPE_UI); in Watch()
|
D | directory_watcher_unittest.cc | 31 : 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_;
|
D | directory_watcher.h | 14 class MessageLoop; variable 42 MessageLoop* backend_loop, bool recursive) { in Watch() 50 MessageLoop* backend_loop, bool recursive) = 0;
|
/external/chromium/net/url_request/ |
D | url_request_unittest.cc | 138 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 …]
|
D | url_request_unittest.h | 69 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/ |
D | network_change_notifier_mac.cc | 45 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/ |
D | proxy_config_service_linux.h | 45 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()
|
D | proxy_config_service_linux.cc | 190 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 …]
|
D | proxy_resolver_js_bindings.cc | 27 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()
|
D | proxy_service.h | 21 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/ |
D | socket_stream.cc | 67 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/ |
D | nss_ocsp.cc | 66 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/ |
D | stress_cache.cc | 127 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/ |
D | websocket.cc | 39 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()
|