Refactoring on Windows IPC channel.

ipc/ipc_channel_win.h

 // Copyright (c) 2011 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_
 #pragma once
 
 #include "ipc/ipc_channel.h"
 
@@ skipping 14 matching lines @@
  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();
   void set_listener(Listener* listener) { listener_ = listener; }
   bool Send(Message* message);
   static bool IsNamedServerInitialized(const std::string& channel_id);
+
  private:
+  enum ReadState { READ_SUCCEEDED, READ_FAILED, READ_PENDING };
+
+  // This will become the virtual interface implemented by this class to
+  // handle platform-specific reading.
+  // TODO(brettw) finish refactoring.
+  ReadState ReadData(char* buffer, int buffer_len, int* bytes_read);
+  bool WillDispatchInputMessage(Message* msg);
+  void HandleHelloMessage(const Message& msg);
+  bool DidEmptyInputBuffers();
+
+  bool DispatchInputData(const char* input_data, int input_data_len);
+
+  // Returns true if the given message is the hello message.
+  bool IsHelloMessage(const Message& m) const;
+
+  // Handles asynchronously read data.
+  //
+  // Optionally call this after returning READ_PENDING from ReadData to
+  // indicate that buffer was filled with the given number of bytes of
+  // data. See ReadData for more.
+  bool AsyncReadComplete(int bytes_read);
+
   static const std::wstring PipeName(const std::string& channel_id);
   bool CreatePipe(const IPC::ChannelHandle &channel_handle, Mode mode);
 
   bool ProcessConnection();
-  bool ProcessIncomingMessages(MessageLoopForIO::IOContext* context,
-                               DWORD bytes_read);
+  bool ProcessIncomingMessages();
   bool ProcessOutgoingMessages(MessageLoopForIO::IOContext* context,
                                DWORD bytes_written);
 
   // MessageLoop::IOHandler implementation.
   virtual void OnIOCompleted(MessageLoopForIO::IOContext* context,
                              DWORD bytes_transfered, DWORD error);
  private:
   struct State {
     explicit State(ChannelImpl* channel);
     ~State();
@@ skipping 31 matching lines @@
   base::WeakPtrFactory<ChannelImpl> weak_factory_;
 
   scoped_ptr<base::NonThreadSafe> thread_check_;
 
   DISALLOW_COPY_AND_ASSIGN(ChannelImpl);
 };
 
 }  // namespace IPC
 
 #endif  // IPC_IPC_CHANNEL_WIN_H_