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

Add unit test for sending RetireConnectionIdFrame

Browse Source 
Reviewed By: sharma95

Differential Revision: D15267820

fbshipit-source-id: b885ca6b5dfa7262338168a796caedf391189d85
This commit is contained in:
Viktor Chynarov
2019-09-30 17:38:20 -07:00
committed by Facebook Github Bot
parent 0ab06b6fc9
commit d0c61cd8c7
1 changed files with 27 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
quic/api/test/QuicTransportTest.cpp
View File

@@ -1483,6 +1483,33 @@ TEST_F(QuicTransportTest, ResendNewConnectionIdOnLoss) {
[&](auto&) { return false; })); [&](auto&) { return false; }));
} }
TEST_F(QuicTransportTest, SendRetireConnectionIdFrame) {
EXPECT_CALL(*socket_, write(_, _)).WillOnce(Invoke(bufLength));
auto& conn = transport_->getConnectionState();
RetireConnectionIdFrame retireConnId(1);
sendSimpleFrame(conn, retireConnId);
transport_->updateWriteLooper(true);
loopForWrites();
EXPECT_TRUE(conn.pendingEvents.frames.empty());
EXPECT_EQ(1, transport_->getConnectionState().outstandingPackets.size());
auto packet =
getLastOutstandingPacket(
transport_->getConnectionState(), PacketNumberSpace::AppData)
->packet;
bool foundRetireConnectionId = false;
for (auto& simpleFrame : all_frames<QuicSimpleFrame>(packet.frames)) {
folly::variant_match(
simpleFrame,
[&](const RetireConnectionIdFrame& frame) {
EXPECT_EQ(frame, retireConnId);
foundRetireConnectionId = true;
},
[&](auto&) {});
}
EXPECT_TRUE(foundRetireConnectionId);
}
TEST_F(QuicTransportTest, NonWritableStreamAPI) { TEST_F(QuicTransportTest, NonWritableStreamAPI) {
auto streamId = transport_->createBidirectionalStream().value(); auto streamId = transport_->createBidirectionalStream().value();
auto buf = buildRandomInputData(20); auto buf = buildRandomInputData(20);