Lines Matching refs:sink
193 testing::StreamSink sink; in ConnectInternal() local
199 sink.Monitor(client.get()); in ConnectInternal()
206 sink.Monitor(server.get()); in ConnectInternal()
212 EXPECT_FALSE(sink.Check(server.get(), testing::SSE_READ)); in ConnectInternal()
223 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN)); in ConnectInternal()
224 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in ConnectInternal()
227 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout); in ConnectInternal()
240 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN)); in ConnectInternal()
241 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in ConnectInternal()
248 testing::StreamSink sink; in ConnectWithDnsLookupInternal() local
254 sink.Monitor(client.get()); in ConnectWithDnsLookupInternal()
259 sink.Monitor(server.get()); in ConnectWithDnsLookupInternal()
272 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN)); in ConnectWithDnsLookupInternal()
273 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in ConnectWithDnsLookupInternal()
276 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout); in ConnectWithDnsLookupInternal()
289 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN)); in ConnectWithDnsLookupInternal()
290 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in ConnectWithDnsLookupInternal()
296 testing::StreamSink sink; in ConnectFailInternal() local
302 sink.Monitor(client.get()); in ConnectFailInternal()
307 sink.Monitor(server.get()); in ConnectFailInternal()
318 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN)); in ConnectFailInternal()
319 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_ERROR)); in ConnectFailInternal()
323 EXPECT_FALSE(sink.Check(server.get(), testing::SSE_READ)); in ConnectFailInternal()
329 testing::StreamSink sink; in ConnectWithDnsLookupFailInternal() local
335 sink.Monitor(client.get()); in ConnectWithDnsLookupFailInternal()
340 sink.Monitor(server.get()); in ConnectWithDnsLookupFailInternal()
360 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN)); in ConnectWithDnsLookupFailInternal()
361 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_ERROR)); in ConnectWithDnsLookupFailInternal()
364 EXPECT_FALSE(sink.Check(server.get(), testing::SSE_READ)); in ConnectWithDnsLookupFailInternal()
389 testing::StreamSink sink; in ConnectWhileNotClosedInternal() local
392 sink.Monitor(server.get()); in ConnectWhileNotClosedInternal()
406 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout); in ConnectWhileNotClosedInternal()
431 testing::StreamSink sink; in ServerCloseDuringConnectInternal() local
436 sink.Monitor(client.get()); in ServerCloseDuringConnectInternal()
441 sink.Monitor(server.get()); in ServerCloseDuringConnectInternal()
449 EXPECT_TRUE_WAIT(sink.Check(server.get(), testing::SSE_READ), kTimeout); in ServerCloseDuringConnectInternal()
454 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_ERROR)); in ServerCloseDuringConnectInternal()
459 testing::StreamSink sink; in ClientCloseDuringConnectInternal() local
465 sink.Monitor(client.get()); in ClientCloseDuringConnectInternal()
470 sink.Monitor(server.get()); in ClientCloseDuringConnectInternal()
478 EXPECT_TRUE_WAIT(sink.Check(server.get(), testing::SSE_READ), kTimeout); in ClientCloseDuringConnectInternal()
484 sink.Monitor(accepted.get()); in ClientCloseDuringConnectInternal()
489 EXPECT_TRUE(sink.Check(accepted.get(), testing::SSE_CLOSE) || in ClientCloseDuringConnectInternal()
490 sink.Check(accepted.get(), testing::SSE_ERROR)); in ClientCloseDuringConnectInternal()
493 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in ClientCloseDuringConnectInternal()
497 testing::StreamSink sink; in ServerCloseInternal() local
503 sink.Monitor(client.get()); in ServerCloseInternal()
508 sink.Monitor(server.get()); in ServerCloseInternal()
516 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout); in ServerCloseInternal()
519 sink.Monitor(accepted.get()); in ServerCloseInternal()
523 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN)); in ServerCloseInternal()
533 EXPECT_TRUE_WAIT(sink.Check(client.get(), testing::SSE_READ), kTimeout); in ServerCloseInternal()
534 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in ServerCloseInternal()
544 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_CLOSE)); in ServerCloseInternal()
548 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_CLOSE)); in ServerCloseInternal()
553 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in ServerCloseInternal()
557 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in ServerCloseInternal()
570 testing::StreamSink sink; in CloseInClosedCallbackInternal() local
577 sink.Monitor(client.get()); in CloseInClosedCallbackInternal()
583 sink.Monitor(server.get()); in CloseInClosedCallbackInternal()
591 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout); in CloseInClosedCallbackInternal()
594 sink.Monitor(accepted.get()); in CloseInClosedCallbackInternal()
598 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN)); in CloseInClosedCallbackInternal()
607 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in CloseInClosedCallbackInternal()
612 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_CLOSE)); in CloseInClosedCallbackInternal()
625 testing::StreamSink sink; in SocketServerWaitInternal() local
633 sink.Monitor(client.get()); in SocketServerWaitInternal()
634 sink.Monitor(server.get()); in SocketServerWaitInternal()
639 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout); in SocketServerWaitInternal()
643 sink.Monitor(accepted.get()); in SocketServerWaitInternal()
649 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN)); in SocketServerWaitInternal()
650 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE)); in SocketServerWaitInternal()
655 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_READ)); in SocketServerWaitInternal()
659 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_READ)); in SocketServerWaitInternal()
667 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_READ)); in SocketServerWaitInternal()
670 EXPECT_TRUE_WAIT((sink.Check(accepted.get(), testing::SSE_READ)), kTimeout); in SocketServerWaitInternal()
675 testing::StreamSink sink; in TcpInternal() local
691 sink.Monitor(client.get()); in TcpInternal()
696 sink.Monitor(server.get()); in TcpInternal()
704 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout); in TcpInternal()
707 sink.Monitor(accepted.get()); in TcpInternal()
711 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN)); in TcpInternal()
746 EXPECT_TRUE_WAIT(sink.Check(client.get(), testing::SSE_READ), kTimeout); in TcpInternal()
775 EXPECT_TRUE_WAIT(sink.Check(accepted.get(), testing::SSE_WRITE), in TcpInternal()
790 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_CLOSE)); in TcpInternal()
795 testing::StreamSink sink; in SingleFlowControlCallbackInternal() local
801 sink.Monitor(client.get()); in SingleFlowControlCallbackInternal()
806 sink.Monitor(server.get()); in SingleFlowControlCallbackInternal()
814 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout); in SingleFlowControlCallbackInternal()
817 sink.Monitor(accepted.get()); in SingleFlowControlCallbackInternal()
821 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN)); in SingleFlowControlCallbackInternal()
826 EXPECT_TRUE_WAIT(sink.Check(accepted.get(), testing::SSE_WRITE), kTimeout); in SingleFlowControlCallbackInternal()
835 EXPECT_TRUE_WAIT(sink.Check(client.get(), testing::SSE_READ), kTimeout); in SingleFlowControlCallbackInternal()
843 EXPECT_TRUE_WAIT(sink.Check(accepted.get(), testing::SSE_WRITE), kTimeout); in SingleFlowControlCallbackInternal()
851 if (sink.Check(accepted.get(), testing::SSE_WRITE)) { in SingleFlowControlCallbackInternal()