diff options
| author | xhwang@chromium.org <xhwang@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2013-04-30 20:55:03 +0000 |
|---|---|---|
| committer | xhwang@chromium.org <xhwang@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2013-04-30 20:55:03 +0000 |
| commit | fd0a773a19c92b94a59b9207f4cc9b154f54a144 (patch) | |
| tree | d10fc47c74d613100cbd4408137194a55573dd6d /ipc/ipc_channel_posix.cc | |
| parent | fb4d0a34d327edf6f7abc03eec53e87243396cf0 (diff) | |
| download | chromium_src-fd0a773a19c92b94a59b9207f4cc9b154f54a144.zip chromium_src-fd0a773a19c92b94a59b9207f4cc9b154f54a144.tar.gz chromium_src-fd0a773a19c92b94a59b9207f4cc9b154f54a144.tar.bz2 | |
ipc: Use base::MessageLoop.
BUG=236029
R=agl@chromium.org
Review URL: https://chromiumcodereview.appspot.com/14383024
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@197465 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'ipc/ipc_channel_posix.cc')
| -rw-r--r-- | ipc/ipc_channel_posix.cc | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/ipc/ipc_channel_posix.cc b/ipc/ipc_channel_posix.cc index 7f38a48..a945c67 100644 --- a/ipc/ipc_channel_posix.cc +++ b/ipc/ipc_channel_posix.cc @@ -335,10 +335,10 @@ bool Channel::ChannelImpl::Connect() { if (server_listen_pipe_ != -1) { // Watch the pipe for connections, and turn any connections into // active sockets. - MessageLoopForIO::current()->WatchFileDescriptor( + base::MessageLoopForIO::current()->WatchFileDescriptor( server_listen_pipe_, true, - MessageLoopForIO::WATCH_READ, + base::MessageLoopForIO::WATCH_READ, &server_listen_connection_watcher_, this); } else { @@ -469,10 +469,10 @@ bool Channel::ChannelImpl::ProcessOutgoingMessages() { // Tell libevent to call us back once things are unblocked. is_blocked_on_write_ = true; - MessageLoopForIO::current()->WatchFileDescriptor( + base::MessageLoopForIO::current()->WatchFileDescriptor( pipe_, false, // One shot - MessageLoopForIO::WATCH_WRITE, + base::MessageLoopForIO::WATCH_WRITE, &write_watcher_, this); return true; @@ -667,11 +667,8 @@ void Channel::ChannelImpl::OnFileCanWriteWithoutBlocking(int fd) { } bool Channel::ChannelImpl::AcceptConnection() { - MessageLoopForIO::current()->WatchFileDescriptor(pipe_, - true, - MessageLoopForIO::WATCH_READ, - &read_watcher_, - this); + base::MessageLoopForIO::current()->WatchFileDescriptor( + pipe_, true, base::MessageLoopForIO::WATCH_READ, &read_watcher_, this); QueueHelloMessage(); if (mode_ & MODE_CLIENT_FLAG) { |