Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(309)

Unified Diff: ipc/ipc_channel_posix.cc

Issue 14383024: ipc: Use base::MessageLoop. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « ipc/ipc_channel_posix.h ('k') | ipc/ipc_channel_posix_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: ipc/ipc_channel_posix.cc
diff --git a/ipc/ipc_channel_posix.cc b/ipc/ipc_channel_posix.cc
index 7f38a489ce86ba0439a042caa427a6078df7dcf5..a945c6724bc65d8d6fb15cb12a4569ca8fffa5db 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) {
« no previous file with comments | « ipc/ipc_channel_posix.h ('k') | ipc/ipc_channel_posix_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698