lib/mvfst
1
0
Fork 0
mirror of https://github.com/facebookincubator/mvfst.git synced 2025-11-25 15:43:13 +03:00
Code Activity

Move QuicStreamManager::writableContains to TestUtil

Browse Source 
Summary: This is a test only API

Reviewed By: lnicco

Differential Revision: D25981669

fbshipit-source-id: 37163f6792ea6fa261bf9ab586cc335c7c95d6bd
This commit is contained in:
Yang Chi
2021-01-20 18:48:22 -08:00
committed by Facebook GitHub Bot
parent 12f2854060
commit 79bdfab8c5
7 changed files with 32 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
quic/state/test/QuicStreamFunctionsTest.cpp
View File

@@ -1552,7 +1552,7 @@ TEST_F(QuicStreamFunctionsTest, RemovedClosedState) {
EXPECT_FALSE(conn.streamManager->streamExists(streamId));
EXPECT_TRUE(conn.streamManager->readableStreams().empty());
EXPECT_TRUE(conn.streamManager->peekableStreams().empty());
EXPECT_FALSE(conn.streamManager->writableContains(streamId));
EXPECT_FALSE(writableContains(*conn.streamManager, streamId));
EXPECT_FALSE(conn.streamManager->hasBlocked());
EXPECT_FALSE(conn.streamManager->deliverableContains(streamId));
EXPECT_FALSE(conn.streamManager->hasLoss());
@@ -1970,18 +1970,18 @@ TEST_F(QuicStreamFunctionsTest, WritableList) {
stream.flowControlState.peerAdvertisedMaxOffset = 200;
conn.streamManager->updateWritableStreams(stream);
EXPECT_FALSE(stream.conn.streamManager->writableContains(id));
EXPECT_FALSE(writableContains(*stream.conn.streamManager, id));
auto buf = IOBuf::create(100);
buf->append(100);
writeDataToQuicStream(stream, std::move(buf), false);
conn.streamManager->updateWritableStreams(stream);
EXPECT_TRUE(stream.conn.streamManager->writableContains(id));
EXPECT_TRUE(writableContains(*stream.conn.streamManager, id));
// Flow control
stream.flowControlState.peerAdvertisedMaxOffset = stream.currentWriteOffset;
conn.streamManager->updateWritableStreams(stream);
EXPECT_FALSE(stream.conn.streamManager->writableContains(id));
EXPECT_FALSE(writableContains(*stream.conn.streamManager, id));
// Fin
writeDataToQuicStream(stream, nullptr, true);
@@ -1989,12 +1989,12 @@ TEST_F(QuicStreamFunctionsTest, WritableList) {
stream.currentWriteOffset += 100;
stream.flowControlState.peerAdvertisedMaxOffset = stream.currentWriteOffset;
conn.streamManager->updateWritableStreams(stream);
EXPECT_TRUE(stream.conn.streamManager->writableContains(id));
EXPECT_TRUE(writableContains(*stream.conn.streamManager, id));
// After Fin
stream.currentWriteOffset++;
conn.streamManager->updateWritableStreams(stream);
EXPECT_FALSE(stream.conn.streamManager->writableContains(id));
EXPECT_FALSE(writableContains(*stream.conn.streamManager, id));
}
TEST_F(QuicStreamFunctionsTest, AckCryptoStream) {