Eliminate a potential race in IPC::ChannelProxy

ipc/ipc_channel_nacl.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_NACL_H_
 #define IPC_IPC_CHANNEL_NACL_H_
 
 #include <deque>
 #include <string>
 
@@ skipping 22 matching lines @@
 // read or write without blocking.
 class Channel::ChannelImpl : public internal::ChannelReader {
  public:
   // Mirror methods of Channel, see ipc_channel.h for description.
   ChannelImpl(const IPC::ChannelHandle& channel_handle,
               Mode mode,
               Listener* listener);
   virtual ~ChannelImpl();
 
   // Channel implementation.
+  base::ProcessId peer_pid() const;
   bool Connect();
   void Close();
   bool Send(Message* message);
 
   // Posted to the main thread by ReaderThreadRunner.
   void DidRecvMsg(scoped_ptr<MessageContents> contents);
   void ReadDidFail();
 
  private:
   class ReaderThreadRunner;
 
   bool CreatePipe(const IPC::ChannelHandle& channel_handle);
   bool ProcessOutgoingMessages();
+  void CallOnChannelConnected();
 
   // ChannelReader implementation.
   virtual ReadState ReadData(char* buffer,
                              int buffer_len,
                              int* bytes_read) OVERRIDE;
   virtual bool WillDispatchInputMessage(Message* msg) OVERRIDE;
   virtual bool DidEmptyInputBuffers() OVERRIDE;
   virtual void HandleInternalMessage(const Message& msg) OVERRIDE;
 
   Mode mode_;
@@ skipping 43 matching lines @@
   std::deque<linked_ptr<Message> > output_queue_;
 
   base::WeakPtrFactory<ChannelImpl> weak_ptr_factory_;
 
   DISALLOW_IMPLICIT_CONSTRUCTORS(ChannelImpl);
 };
 
 }  // namespace IPC
 
 #endif  // IPC_IPC_CHANNEL_NACL_H_