Home
last modified time | relevance | path

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 DHQDownstreamSessionTest.cpp98 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 DHQSessionTestCommon.h143 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 DHQUpstreamSessionTest.cpp124 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 DH3DatagramAsyncSocketTest.cpp42 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 DH3DatagramAsyncSocketTest.h86 std::unique_ptr<quic::MockQuicSocketDriver> socketDriver_; variable