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_win.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_win.cc')
| -rw-r--r-- | ipc/ipc_channel_win.cc | 24 |
1 files changed, 14 insertions, 10 deletions
diff --git a/ipc/ipc_channel_win.cc b/ipc/ipc_channel_win.cc index 5ae75c84..bde64124 100644 --- a/ipc/ipc_channel_win.cc +++ b/ipc/ipc_channel_win.cc @@ -70,7 +70,7 @@ void Channel::ChannelImpl::Close() { // Make sure all IO has completed. base::Time start = base::Time::Now(); while (input_state_.is_pending || output_state_.is_pending) { - MessageLoopForIO::current()->WaitForIOCompletion(INFINITE, this); + base::MessageLoopForIO::current()->WaitForIOCompletion(INFINITE, this); } while (!output_queue_.empty()) { @@ -294,7 +294,7 @@ bool Channel::ChannelImpl::Connect() { if (pipe_ == INVALID_HANDLE_VALUE) return false; - MessageLoopForIO::current()->RegisterIOHandler(pipe_, this); + base::MessageLoopForIO::current()->RegisterIOHandler(pipe_, this); // Check to see if there is a client connected to our pipe... if (waiting_connect_) @@ -304,10 +304,13 @@ bool Channel::ChannelImpl::Connect() { // Complete setup asynchronously. By not setting input_state_.is_pending // to true, we indicate to OnIOCompleted that this is the special // initialization signal. - MessageLoopForIO::current()->PostTask( - FROM_HERE, base::Bind(&Channel::ChannelImpl::OnIOCompleted, - weak_factory_.GetWeakPtr(), &input_state_.context, - 0, 0)); + base::MessageLoopForIO::current()->PostTask( + FROM_HERE, + base::Bind(&Channel::ChannelImpl::OnIOCompleted, + weak_factory_.GetWeakPtr(), + &input_state_.context, + 0, + 0)); } if (!waiting_connect_) @@ -353,7 +356,7 @@ bool Channel::ChannelImpl::ProcessConnection() { } bool Channel::ChannelImpl::ProcessOutgoingMessages( - MessageLoopForIO::IOContext* context, + base::MessageLoopForIO::IOContext* context, DWORD bytes_written) { DCHECK(!waiting_connect_); // Why are we trying to send messages if there's // no connection? @@ -409,9 +412,10 @@ bool Channel::ChannelImpl::ProcessOutgoingMessages( return true; } -void Channel::ChannelImpl::OnIOCompleted(MessageLoopForIO::IOContext* context, - DWORD bytes_transfered, - DWORD error) { +void Channel::ChannelImpl::OnIOCompleted( + base::MessageLoopForIO::IOContext* context, + DWORD bytes_transfered, + DWORD error) { bool ok = true; DCHECK(thread_check_->CalledOnValidThread()); if (context == &input_state_.context) { |