Searched refs:socketDriver_ (Results 1 – 5 of 5) sorted by relevance
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/test/ |
H A D | HQDownstreamSessionTest.cpp | 98 socketDriver_->addReadEvent( in sendRequestLater() 217 socketDriver_->addReadEvent( in flushRequests() 226 socketDriver_->addReadEvent( in flushRequests() 1335 socketDriver_->addReadEOF(id); in TEST_P() 1346 socketDriver_->addReadEOF(id); in TEST_P() 1367 socketDriver_->addReadEOF(id); in TEST_P() 1956 socketDriver_->addReadError(id, in TEST_P() 2080 socketDriver_->addReadEvent( in TEST_P() 2091 socketDriver_->addReadEvent( in TEST_P() 2127 socketDriver_->addReadEvent( in TEST_P() [all …]
|
H A D | HQSessionTestCommon.h | 143 hqSession_->setSocket(socketDriver_->getSocket()); in direction_() 160 socketDriver_->setLocalAppCallback(this); in direction_() 180 EXPECT_CALL(*socketDriver_->getSocket(), getTransportInfo()) in direction_() 194 createControlStream(socketDriver_.get(), in createControlStreams() 199 createControlStream(socketDriver_.get(), in createControlStreams() 204 socketDriver_.get(), in createControlStreams() 208 socketDriver_.get(), in createControlStreams() 225 socketDriver_->addReadEvent( in sendSettings() 280 socketDriver_->sock_->setControlStream(id); in unidirectionalReadCallback() 341 return socketDriver_.get(); in getSocketDriver() [all …]
|
H A D | HQUpstreamSessionTest.cpp | 124 if (!socketDriver_->isClosed()) { in TearDown() 187 socketDriver_->addReadEvent( in flush() 195 socketDriver_->addReadEvent( in flush() 354 socketDriver_->sockGood_ = false; in TEST_P() 371 socketDriver_->deliverConnectionError( in TEST_P() 452 auto sock = socketDriver_->getSocket(); in TEST_P() 475 auto sock = socketDriver_->getSocket(); in TEST_P() 649 socketDriver_->deliverConnectionError( in TEST_P() 1042 EXPECT_CALL(*socketDriver_->getSocket(), in TEST_P() 1139 socketDriver_->addReadEvent( in TEST_P() [all …]
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/transport/test/ |
H A D | H3DatagramAsyncSocketTest.cpp | 42 socketDriver_ = std::make_unique<MockQuicSocketDriver>( in SetUp() 47 socketDriver_->setMaxUniStreams(3); in SetUp() 49 session_->setSocket(socketDriver_->getSocket()); in SetUp() 62 EXPECT_CALL(*socketDriver_->getSocket(), getTransportInfo()) in SetUp() 282 EXPECT_EQ(socketDriver_->outDatagrams_.size(), 0); in TEST_F() 285 EXPECT_EQ(socketDriver_->outDatagrams_.size(), 1); in TEST_F() 298 EXPECT_EQ(socketDriver_->outDatagrams_.size(), 0); in TEST_F() 306 EXPECT_CALL(*socketDriver_->getSocket(), writeDatagram(testing::_)) in TEST_F() 317 EXPECT_EQ(socketDriver_->outDatagrams_.size(), 0); in TEST_F() 321 EXPECT_CALL(*socketDriver_->getSocket(), getDatagramSizeLimit()) in TEST_F() [all …]
|
H A D | H3DatagramAsyncSocketTest.h | 86 std::unique_ptr<quic::MockQuicSocketDriver> socketDriver_; variable
|