ShellClient -> Service

ipc/ipc_channel_posix.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "ipc/ipc_channel_posix.h"
 
 #include <errno.h>
 #include <fcntl.h>
 #include <stddef.h>
 #include <stdint.h>
@@ skipping 346 matching lines @@
     // Watch the pipe for connections, and turn any connections into
     // active sockets.
     base::MessageLoopForIO::current()->WatchFileDescriptor(
         server_listen_pipe_.get(),
         true,
         base::MessageLoopForIO::WATCH_READ,
         &server_listen_connection_watcher_,
         this);
 #endif
   } else {
-    did_connect = AcceptConnection();
+    did_connect = OnConnect();
   }
   return did_connect;
 }
 
 void ChannelPosix::CloseFileDescriptors(Message* msg) {
 #if defined(OS_MACOSX)
   // There is a bug on OSX which makes it dangerous to close
   // a file descriptor while it is in transit. So instead we
   // store the file descriptor in a set and send a message to
   // the recipient, which is queued AFTER the message that
@@ skipping 247 matching lines @@
 #endif  // OS_LINUX
 
 // Called by libevent when we can read from the pipe without blocking.
 void ChannelPosix::OnFileCanReadWithoutBlocking(int fd) {
   if (fd == server_listen_pipe_.get()) {
 #if defined(OS_NACL_NONSFI)
     LOG(FATAL)
         << "IPC channels in nacl_helper_nonsfi should not be SERVER mode.";
 #else
     int new_pipe = 0;
-    if (!ServerAcceptConnection(server_listen_pipe_.get(), &new_pipe) ||
+    if (!ServerOnConnect(server_listen_pipe_.get(), &new_pipe) ||
         new_pipe < 0) {
       Close();
       listener()->OnChannelListenError();
     }
 
     if (pipe_.is_valid()) {
       // We already have a connection. We only handle one at a time.
       // close our new descriptor.
       if (HANDLE_EINTR(shutdown(new_pipe, SHUT_RDWR)) < 0)
         DPLOG(ERROR) << "shutdown " << pipe_name_;
@@ skipping 12 matching lines @@
         ResetToAcceptingConnectionState();
         return;
       }
       if (client_euid != geteuid()) {
         DLOG(WARNING) << "Client euid is not authorised";
         ResetToAcceptingConnectionState();
         return;
       }
     }
 
-    if (!AcceptConnection()) {
+    if (!OnConnect()) {
       NOTREACHED() << "AcceptConnection should not fail on server";
     }
     waiting_connect_ = false;
 #endif
   } else if (fd == pipe_) {
     if (waiting_connect_ && (mode_ & MODE_SERVER_FLAG)) {
       waiting_connect_ = false;
     }
     if (ProcessIncomingMessages() == DISPATCH_ERROR) {
       // ClosePipeOnError may delete this object, so we mustn't call
@@ skipping 82 matching lines @@
   // Delete any unprocessed messages.
   while (!prelim_queue.empty()) {
     Message* m = prelim_queue.front();
     delete m;
     prelim_queue.pop();
   }
 
   return !processing_error;
 }
 
-bool ChannelPosix::AcceptConnection() {
+bool ChannelPosix::OnConnect() {
   base::MessageLoopForIO::current()->WatchFileDescriptor(
       pipe_.get(),
       true,
       base::MessageLoopForIO::WATCH_READ,
       &read_watcher_,
       this);
   QueueHelloMessage();
 
   if (mode_ & MODE_CLIENT_FLAG) {
     // If we are a client we want to send a hello message out immediately.
@@ skipping 357 matching lines @@
 // static
 void Channel::SetGlobalPid(int pid) {
   ChannelPosix::SetGlobalPid(pid);
 }
 int Channel::GetGlobalPid() {
   return ChannelPosix::GetGlobalPid();
 }
 #endif  // OS_LINUX
 
 }  // namespace IPC