Make IPC::Channel polymorphic

ipc/ipc_channel_win.h

 // 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.
 
 #ifndef IPC_IPC_CHANNEL_WIN_H_
 #define IPC_IPC_CHANNEL_WIN_H_
 
 #include "ipc/ipc_channel.h"
 
 #include <queue>
 #include <string>
 
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "ipc/ipc_channel_reader.h"
 
 namespace base {
 class ThreadChecker;
 }
 
 namespace IPC {
 
-class Channel::ChannelImpl : public internal::ChannelReader,
-                             public base::MessageLoopForIO::IOHandler {
+class ChannelWin : public Channel,
+                   public internal::ChannelReader,
+                   public base::MessageLoopForIO::IOHandler {
  public:
   // Mirror methods of Channel, see ipc_channel.h for description.
-  ChannelImpl(const IPC::ChannelHandle &channel_handle, Mode mode,
-              Listener* listener);
-  ~ChannelImpl();
-  bool Connect();
-  void Close();
-  bool Send(Message* message);
+  ChannelWin(const IPC::ChannelHandle &channel_handle, Mode mode,
+             Listener* listener);
+  ~ChannelWin();
+
+  // Channel implementation
+  virtual bool Connect() OVERRIDE;
+  virtual void Close() OVERRIDE;
+  virtual bool Send(Message* message) OVERRIDE;
+  virtual base::ProcessId GetPeerPID() const OVERRIDE;
+
   static bool IsNamedServerInitialized(const std::string& channel_id);
-  base::ProcessId peer_pid() const { return peer_pid_; }
+
 
  private:
   // ChannelReader implementation.
   virtual ReadState ReadData(char* buffer,
                              int buffer_len,
                              int* bytes_read) OVERRIDE;
   virtual bool WillDispatchInputMessage(Message* msg) OVERRIDE;
   bool DidEmptyInputBuffers() OVERRIDE;
   virtual void HandleInternalMessage(const Message& msg) OVERRIDE;
 
   static const base::string16 PipeName(const std::string& channel_id,
                                        int32* secret);
   bool CreatePipe(const IPC::ChannelHandle &channel_handle, Mode mode);
 
   bool ProcessConnection();
   bool ProcessOutgoingMessages(base::MessageLoopForIO::IOContext* context,
                                DWORD bytes_written);
 
   // MessageLoop::IOHandler implementation.
   virtual void OnIOCompleted(base::MessageLoopForIO::IOContext* context,
                              DWORD bytes_transfered,
                              DWORD error);
 
  private:
   struct State {
-    explicit State(ChannelImpl* channel);
+    explicit State(ChannelWin* channel);
     ~State();
     base::MessageLoopForIO::IOContext context;
     bool is_pending;
   };
 
   State input_state_;
   State output_state_;
 
   HANDLE pipe_;
 
@@ skipping 15 matching lines @@
   // Determines if we should validate a client's secret on connection.
   bool validate_client_;
 
   // This is a unique per-channel value used to authenticate the client end of
   // a connection. If the value is non-zero, the client passes it in the hello
   // and the host validates. (We don't send the zero value fto preserve IPC
   // compatability with existing clients that don't validate the channel.)
   int32 client_secret_;
 
 
-  base::WeakPtrFactory<ChannelImpl> weak_factory_;
+  base::WeakPtrFactory<ChannelWin> weak_factory_;
 
   scoped_ptr<base::ThreadChecker> thread_check_;
 
-  DISALLOW_COPY_AND_ASSIGN(ChannelImpl);
+  DISALLOW_COPY_AND_ASSIGN(ChannelWin);
 };
 
 }  // namespace IPC
 
 #endif  // IPC_IPC_CHANNEL_WIN_H_