lib/mvfst
1
0
Fork 0
mirror of https://github.com/facebookincubator/mvfst.git synced 2025-08-08 09:42:06 +03:00
Code Activity

Clean up mvfstCheckIdleTimerOnWrites param

Browse Source 
Summary: Clean up mvfstCheckIdleTimerOnWrites param

Reviewed By: sharmafb

Differential Revision: D68972795

fbshipit-source-id: f19f9947fa8a8affe4c4411c22d893cb95d71fe0
This commit is contained in:
Konstantin Tsoy
2025-02-04 23:51:44 -08:00
committed by Facebook GitHub Bot
parent e87434bf71
commit 14d8a46842
4 changed files with 0 additions and 101 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
quic/api/test/QuicTransportBaseTest.cpp
View File

@@ -411,14 +411,6 @@ class TestQuicTransport
return readLooper_;
}
void runCheckIdleTimer(TimePoint now) {
checkIdleTimer(now);
}
const IdleTimeoutCheck& getIdleTimeoutCheck() {
return idleTimeoutCheck_;
}
void unbindConnection() {}
void onReadError(const folly::AsyncSocketException&) noexcept {}
@@ -5041,45 +5033,4 @@ TEST_P(
transport.reset();
}
TEST_P(QuicTransportImplTestBase, TestCheckIdleTimerTimerActiveConnNotExpired) {
auto transportSettings = transport->getTransportSettings();
transportSettings.checkIdleTimerOnWrite = true;
transport->setTransportSettings(transportSettings);
transport->getConnectionState().streamManager->refreshTransportSettings(
transportSettings);
transport->transportConn->oneRttWriteCipher = test::createNoOpAead();
EXPECT_FALSE(transport->isClosed());
transport->setIdleTimeout();
transport->runCheckIdleTimer(Clock::now());
qEvb->loopOnce();
EXPECT_FALSE(transport->isClosed());
transport.reset();
}
TEST_P(QuicTransportImplTestBase, TestCheckIdleTimerTimerActiveConnExpired) {
auto transportSettings = transport->getTransportSettings();
transportSettings.checkIdleTimerOnWrite = true;
transport->setTransportSettings(transportSettings);
transport->getConnectionState().streamManager->refreshTransportSettings(
transportSettings);
transport->transportConn->oneRttWriteCipher = test::createNoOpAead();
EXPECT_FALSE(transport->isClosed());
transport->setIdleTimeout();
const auto& idleTimerCheck = transport->getIdleTimeoutCheck();
TimePoint fakeFutureTs = Clock::now() +
std::chrono::milliseconds(idleTimerCheck.idleTimeoutMs.count() + 1000);
transport->runCheckIdleTimer(fakeFutureTs);
qEvb->loopOnce();
EXPECT_TRUE(transport->isClosed());
transport.reset();
}
} // namespace quic::test