Add non-blocking peek for the syncsocket...

ipc/sync_socket_unittest.cc

 // Copyright (c) 2009 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 <stdio.h>
 #include <iostream>
 #include <string>
 #include <sstream>
 
 #include "base/message_loop.h"
@@ skipping 171 matching lines @@
         IPC_MESSAGE_HANDLER(MsgClassResponse, OnMsgClassResponse)
       IPC_END_MESSAGE_MAP()
     }
   }
 
  private:
   // When a response is received from the server, it sends the same
   // string as was written on the SyncSocket.  These are compared
   // and a shutdown message is sent back to the server.
   void OnMsgClassResponse(const std::string& str) {
+#if defined(OS_WIN)
+    // We rely on the order of sync_socket.Send() and chan_->Send() in
+    // the SyncSocketServerListener object.
+    EXPECT_EQ(kHelloStringLength, socket_->Peek());
+#endif
     char buf[kHelloStringLength];
     socket_->Receive(static_cast<void*>(buf), kHelloStringLength);
     EXPECT_EQ(strcmp(str.c_str(), buf), 0);
     IPC::Message* msg = new MsgClassShutdown();
     EXPECT_NE(msg, reinterpret_cast<IPC::Message*>(NULL));
     EXPECT_TRUE(chan_->Send(msg));
     MessageLoop::current()->Quit();
   }
 
   base::SyncSocket* socket_;
@@ skipping 35 matching lines @@
   EXPECT_NE(msg, reinterpret_cast<IPC::Message*>(NULL));
   EXPECT_TRUE(chan.Send(msg));
   // Use the current thread as the I/O thread.
   MessageLoop::current()->Run();
   // Shut down.
   delete pair[0];
   delete pair[1];
   EXPECT_TRUE(base::WaitForSingleProcess(server_process, 5000));
   base::CloseProcessHandle(server_process);
 }