Home
last modified time | relevance | path

Searched refs:MessageLoopForIO (Results 1 – 25 of 43) sorted by relevance

12

/external/chromium/net/websockets/
Dwebsocket_throttle_unittest.cc216 MessageLoopForIO::current()->RunAllPending(); in TEST_F()
231 MessageLoopForIO::current()->RunAllPending(); in TEST_F()
244 MessageLoopForIO::current()->RunAllPending(); in TEST_F()
255 MessageLoopForIO::current()->RunAllPending(); in TEST_F()
265 MessageLoopForIO::current()->RunAllPending(); in TEST_F()
275 MessageLoopForIO::current()->RunAllPending(); in TEST_F()
280 MessageLoopForIO::current()->RunAllPending(); in TEST_F()
305 MessageLoopForIO::current()->RunAllPending(); in TEST_F()
/external/chromium/net/disk_cache/
Dfile_win.cc24 MessageLoopForIO::IOContext context_;
32 class CompletionHandler : public MessageLoopForIO::IOHandler {
33 virtual void OnIOCompleted(MessageLoopForIO::IOContext* context,
40 void CompletionHandler::OnIOCompleted(MessageLoopForIO::IOContext* context, in OnIOCompleted()
87 MessageLoopForIO::current()->RegisterIOHandler( in Init()
262 MessageLoopForIO::IOHandler* handler = g_completion_handler.Pointer(); in WaitForPendingIO()
263 MessageLoopForIO::current()->WaitForIOCompletion(100, handler); in WaitForPendingIO()
/external/chromium/net/base/
Dnetwork_change_notifier_linux.cc26 : public base::Thread, public MessageLoopForIO::Watcher {
56 MessageLoopForIO::FileDescriptorWatcher netlink_watcher_;
124 rv = MessageLoopForIO::current()->WatchFileDescriptor(netlink_fd_, false, in ListenForNotifications()
125 MessageLoopForIO::WATCH_READ, &netlink_watcher_, this); in ListenForNotifications()
Dfile_stream_win.cc53 class FileStream::AsyncContext : public MessageLoopForIO::IOHandler {
67 virtual void OnIOCompleted(MessageLoopForIO::IOContext* context,
71 MessageLoopForIO::IOContext context_;
82 MessageLoopForIO::current()->WaitForIOCompletion(INFINITE, this); in ~AsyncContext()
98 MessageLoopForIO::IOContext* context, DWORD bytes_read, DWORD error) { in OnIOCompleted()
135 MessageLoopForIO::current()->RegisterIOHandler(file_, in FileStream()
172 MessageLoopForIO::current()->RegisterIOHandler(file_, in Open()
Dlisten_socket.h40 public MessageLoopForIO::Watcher
119 MessageLoopForIO::FileDescriptorWatcher watcher_;
Dnet_test_suite.cc45 message_loop_.reset(new MessageLoopForIO()); in InitializeTestThread()
/external/chromium/net/udp/
Dudp_socket_libevent.h99 class ReadWatcher : public MessageLoopForIO::Watcher {
118 class WriteWatcher : public MessageLoopForIO::Watcher {
164 MessageLoopForIO::FileDescriptorWatcher read_socket_watcher_;
165 MessageLoopForIO::FileDescriptorWatcher write_socket_watcher_;
Dudp_socket_libevent.cc146 if (!MessageLoopForIO::current()->WatchFileDescriptor( in RecvFrom()
147 socket_, true, MessageLoopForIO::WATCH_READ, in RecvFrom()
192 if (!MessageLoopForIO::current()->WatchFileDescriptor( in SendToOrWrite()
193 socket_, true, MessageLoopForIO::WATCH_WRITE, in SendToOrWrite()
/external/chromium/net/socket/
Dtcp_client_socket_libevent.h78 class ReadWatcher : public MessageLoopForIO::Watcher {
97 class WriteWatcher : public MessageLoopForIO::Watcher {
160 MessageLoopForIO::FileDescriptorWatcher read_socket_watcher_;
161 MessageLoopForIO::FileDescriptorWatcher write_socket_watcher_;
Dtcp_server_socket_libevent.h21 public MessageLoopForIO::Watcher {
43 MessageLoopForIO::FileDescriptorWatcher accept_socket_watcher_;
Dtcp_client_socket_libevent.cc277 if (!MessageLoopForIO::current()->WatchFileDescriptor( in DoConnect()
278 socket_, true, MessageLoopForIO::WATCH_WRITE, &write_socket_watcher_, in DoConnect()
406 if (!MessageLoopForIO::current()->WatchFileDescriptor( in Read()
407 socket_, true, MessageLoopForIO::WATCH_READ, in Read()
443 if (!MessageLoopForIO::current()->WatchFileDescriptor( in Write()
444 socket_, true, MessageLoopForIO::WATCH_WRITE, in Write()
Dtcp_server_socket_libevent.cc125 if (!MessageLoopForIO::current()->WatchFileDescriptor( in Accept()
126 socket_, true, MessageLoopForIO::WATCH_READ, in Accept()
/external/chromium/base/files/
Dfile_path_watcher_mac.cc44 public MessageLoopForIO::Watcher,
130 MessageLoopForIO::FileDescriptorWatcher kqueue_watcher_;
146 DCHECK(MessageLoopForIO::current()); in EventsForPath()
339 DCHECK(MessageLoopForIO::current()); in OnFileCanReadWithoutBlocking()
421 DCHECK(MessageLoopForIO::current()); in Watch()
454 return MessageLoopForIO::current()->WatchFileDescriptor( in Watch()
455 kqueue_, true, MessageLoopForIO::WATCH_READ, &kqueue_watcher_, this); in Watch()
473 DCHECK(MessageLoopForIO::current()); in CancelOnMessageLoopThread()
/external/chromium/net/proxy/
Dproxy_config_service_linux.h48 MessageLoopForIO* file_loop) = 0;
135 MessageLoopForIO* file_loop);
231 MessageLoopForIO* file_loop) { in SetupAndFetchInitialConfig()
/external/chromium/chrome/browser/importer/
Dfirefox_importer_unittest_utils.h18 class MessageLoopForIO; variable
55 scoped_ptr<MessageLoopForIO> message_loop_;
Dfirefox_importer_unittest_utils_mac.cc127 message_loop_.reset(new MessageLoopForIO()); in Setup()
257 MessageLoopForIO main_message_loop; in MULTIPROCESS_TEST_MAIN()
/external/chromium/base/
Dmessage_loop.h572 class BASE_API MessageLoopForIO : public MessageLoop {
592 MessageLoopForIO() : MessageLoop(TYPE_IO) { in MessageLoopForIO() function
596 static MessageLoopForIO* current() { in current()
604 return static_cast<MessageLoopForIO*>(loop); in current()
644 COMPILE_ASSERT(sizeof(MessageLoop) == sizeof(MessageLoopForIO),
Dmessage_loop_unittest.cc1222 class TestIOHandler : public MessageLoopForIO::IOHandler {
1226 virtual void OnIOCompleted(MessageLoopForIO::IOContext* context,
1236 MessageLoopForIO::IOContext context_;
1254 MessageLoopForIO::current()->RegisterIOHandler(file_, this); in Init()
1263 void TestIOHandler::OnIOCompleted(MessageLoopForIO::IOContext* context, in OnIOCompleted()
1270 EXPECT_TRUE(MessageLoopForIO::current()->WaitForIOCompletion(300, this)); in WaitForIO()
1271 EXPECT_TRUE(MessageLoopForIO::current()->WaitForIOCompletion(400, this)); in WaitForIO()
1665 MessageLoopForIO message_loop; in TEST()
1669 true, MessageLoopForIO::WATCH_WRITE, &controller, &delegate); in TEST()
1688 MessageLoopForIO message_loop; in TEST()
[all …]
/external/chromium/net/ocsp/
Dnss_ocsp.cc82 MessageLoopForIO* io_loop_; // Protected by |lock_|.
255 DCHECK_EQ(MessageLoopForIO::current(), io_loop_); in OnReceivedRedirect()
266 DCHECK_EQ(MessageLoopForIO::current(), io_loop_); in OnResponseStarted()
280 DCHECK_EQ(MessageLoopForIO::current(), io_loop_); in OnReadCompleted()
308 DCHECK_EQ(MessageLoopForIO::current(), io_loop_); in CancelURLRequest()
361 io_loop_ = MessageLoopForIO::current(); in StartURLRequest()
457 io_loop_(MessageLoopForIO::current()) { in OCSPIOLoop()
504 DCHECK_EQ(MessageLoopForIO::current(), io_loop_); in EnsureIOLoop()
882 DCHECK(MessageLoopForIO::current()); in SetMessageLoopForOCSP()
/external/chromium/chrome/browser/
Dprocess_singleton_linux.cc455 : public MessageLoopForIO::Watcher,
460 class SocketReader : public MessageLoopForIO::Watcher {
470 MessageLoopForIO::current()->WatchFileDescriptor( in SocketReader()
471 fd, true, MessageLoopForIO::WATCH_READ, &fd_reader_, this); in SocketReader()
498 MessageLoopForIO::FileDescriptorWatcher fd_reader_;
560 MessageLoopForIO::FileDescriptorWatcher fd_watcher_;
595 MessageLoopForIO* ml = MessageLoopForIO::current(); in StartListening()
597 ml->WatchFileDescriptor(socket, true, MessageLoopForIO::WATCH_READ, in StartListening()
Dcrash_handler_host_linux.h37 class CrashHandlerHostLinux : public MessageLoopForIO::Watcher,
90 MessageLoopForIO::FileDescriptorWatcher file_descriptor_watcher_;
Djankometer.cc214 public MessageLoopForIO::IOObserver,
229 MessageLoopForIO::current()->AddIOObserver(this); in AttachToCurrentThread()
234 MessageLoopForIO::current()->RemoveIOObserver(this); in DetachFromCurrentThread()
Dcrash_handler_host_linux.cc93 MessageLoopForIO* ml = MessageLoopForIO::current(); in Init()
96 MessageLoopForIO::WATCH_READ, in Init()
/external/chromium/net/tools/dump_cache/
Dupgrade.cc116 class BaseSM : public MessageLoopForIO::IOHandler {
127 MessageLoopForIO::IOContext in_context_;
128 MessageLoopForIO::IOContext out_context_;
154 MessageLoopForIO::current()->RegisterIOHandler(channel_, this); in BaseSM()
226 virtual void OnIOCompleted(MessageLoopForIO::IOContext* context,
273 void MasterSM::OnIOCompleted(MessageLoopForIO::IOContext* context, in OnIOCompleted()
569 virtual void OnIOCompleted(MessageLoopForIO::IOContext* context,
626 void SlaveSM::OnIOCompleted(MessageLoopForIO::IOContext* context, in OnIOCompleted()
/external/chromium/chrome/common/
Dservice_process_util_posix.cc66 *success = MessageLoopForIO::current()->WatchFileDescriptor( in SignalReady()
67 sockets_[0], true, MessageLoopForIO::WATCH_READ, in SignalReady()

12