172   base::SyncSocket pair[2];  in TEST_F()  local
173   base::SyncSocket::CreatePair(&pair[0], &pair[1]);  in TEST_F()
175   EXPECT_EQ(0U, pair[0].Peek());  in TEST_F()
176   EXPECT_EQ(0U, pair[1].Peek());  in TEST_F()
180   listener.Init(&pair[0], channel());  in TEST_F()
183   BOOL retval = DuplicateHandle(GetCurrentProcess(), pair[1].handle(),  in TEST_F()
190   target_handle = pair[1].handle();  in TEST_F()
199   pair[0].Close();  in TEST_F()
200   pair[1].Close();  in TEST_F()
218   base::CancelableSyncSocket pair[2];  in TEST_F()  local
219   ASSERT_TRUE(base::CancelableSyncSocket::CreatePair(&pair[0], &pair[1]));  in TEST_F()
229       base::Bind(&BlockingRead, &pair[0], &buf[0], arraysize(buf), &received));  in TEST_F()
233   pair[1].Receive(&hello[0], sizeof(hello));  in TEST_F()
240   pair[0].Shutdown();  in TEST_F()
249   base::CancelableSyncSocket pair[2];  in TEST_F()  local
250   ASSERT_TRUE(base::CancelableSyncSocket::CreatePair(&pair[0], &pair[1]));  in TEST_F()
259                                  base::Bind(&BlockingRead, &pair[0], &buf[0],  in TEST_F()
264   pair[1].Receive(&hello[0], sizeof(hello));  in TEST_F()
271   pair[1].Send(kHelloString, kHelloStringLength);  in TEST_F()
282   base::CancelableSyncSocket pair[2];  in TEST_F()  local
283   ASSERT_TRUE(base::CancelableSyncSocket::CreatePair(&pair[0], &pair[1]));  in TEST_F()
287   while (pair[0].Send(kHelloString, kHelloStringLength) != 0) {}  in TEST_F()
290   size_t bytes_in_buffer = pair[1].Peek();  in TEST_F()
295   EXPECT_EQ(0U, pair[0].Send(kHelloString, kHelloStringLength));  in TEST_F()
296   EXPECT_EQ(bytes_in_buffer, pair[1].Peek());  in TEST_F()
300   pair[1].Receive(&hello[0], sizeof(hello));  in TEST_F()
303   EXPECT_EQ(kHelloStringLength, pair[0].Send(kHelloString, kHelloStringLength));  in TEST_F()