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

Remove unused fields in OutstandingPacketMetadata [3/n]

Summary: Neither QUIC nor TransportMonitor uses the `finObserved` field in the `StreamDetails`

Reviewed By: hanidamlaj

Differential Revision: D55936040

fbshipit-source-id: 0902bf7c30f85ada63cd3e9234f6a059b425cce5
This commit is contained in:
Aman Sharma
2024-04-15 15:44:35 -07:00
committed by Facebook GitHub Bot
parent c4d9f16bc8
commit d0270692a7
2 changed files with 6 additions and 28 deletions

View File

@@ -1756,7 +1756,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsSingleStream) {
const auto streamMatcher = testing::Pair( const auto streamMatcher = testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field(&PacketStreamDetails::streamBytesSent, frameLen), testing::Field(&PacketStreamDetails::streamBytesSent, frameLen),
testing::Field(&PacketStreamDetails::newStreamBytesSent, frameLen), testing::Field(&PacketStreamDetails::newStreamBytesSent, frameLen),
testing::Field( testing::Field(
@@ -1801,7 +1800,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsSingleStreamMultipleFrames) {
const auto streamMatcher = testing::Pair( const auto streamMatcher = testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, true),
testing::Field(&PacketStreamDetails::streamBytesSent, 15), testing::Field(&PacketStreamDetails::streamBytesSent, 15),
testing::Field(&PacketStreamDetails::newStreamBytesSent, 15), testing::Field(&PacketStreamDetails::newStreamBytesSent, 15),
testing::Field( testing::Field(
@@ -1848,7 +1846,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsSingleStreamRetransmit) {
const auto streamMatcher = testing::Pair( const auto streamMatcher = testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field(&PacketStreamDetails::streamBytesSent, frame1Len), testing::Field(&PacketStreamDetails::streamBytesSent, frame1Len),
testing::Field(&PacketStreamDetails::newStreamBytesSent, frame1Len), testing::Field(&PacketStreamDetails::newStreamBytesSent, frame1Len),
testing::Field( testing::Field(
@@ -1888,7 +1885,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsSingleStreamRetransmit) {
const auto streamMatcher = testing::Pair( const auto streamMatcher = testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field(&PacketStreamDetails::streamBytesSent, frame1Len), testing::Field(&PacketStreamDetails::streamBytesSent, frame1Len),
testing::Field(&PacketStreamDetails::newStreamBytesSent, 0), testing::Field(&PacketStreamDetails::newStreamBytesSent, 0),
testing::Field( testing::Field(
@@ -1934,7 +1930,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsSingleStreamRetransmit) {
const auto streamMatcher = testing::Pair( const auto streamMatcher = testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field( testing::Field(
&PacketStreamDetails::streamBytesSent, frame1Len + frame2Len), &PacketStreamDetails::streamBytesSent, frame1Len + frame2Len),
testing::Field(&PacketStreamDetails::newStreamBytesSent, frame2Len), testing::Field(&PacketStreamDetails::newStreamBytesSent, frame2Len),
@@ -1976,7 +1971,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsSingleStreamRetransmit) {
const auto streamMatcher = testing::Pair( const auto streamMatcher = testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field( testing::Field(
&PacketStreamDetails::streamBytesSent, frame1Len + frame2Len), &PacketStreamDetails::streamBytesSent, frame1Len + frame2Len),
testing::Field(&PacketStreamDetails::newStreamBytesSent, 0), testing::Field(&PacketStreamDetails::newStreamBytesSent, 0),
@@ -2038,12 +2032,10 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsSingleStreamFinWithRetransmit) {
// Should be two packets at this point, each with 1 frame of data // Should be two packets at this point, each with 1 frame of data
EXPECT_THAT(conn->outstandings.packets, SizeIs(2)); EXPECT_THAT(conn->outstandings.packets, SizeIs(2));
{ {
auto getStreamDetailsMatcher = [&stream, &frameLen]( auto getStreamDetailsMatcher = [&stream, &frameLen](auto frameOffset) {
auto frameOffset, bool finObserved) {
return testing::Pair( return testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, finObserved),
testing::Field(&PacketStreamDetails::streamBytesSent, frameLen), testing::Field(&PacketStreamDetails::streamBytesSent, frameLen),
testing::Field( testing::Field(
&PacketStreamDetails::newStreamBytesSent, frameLen), &PacketStreamDetails::newStreamBytesSent, frameLen),
@@ -2063,8 +2055,8 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsSingleStreamFinWithRetransmit) {
&OutstandingPacketMetadata::totalPacketsSent, testing::Eq(1)), &OutstandingPacketMetadata::totalPacketsSent, testing::Eq(1)),
testing::Field( testing::Field(
&OutstandingPacketMetadata::detailsPerStream, &OutstandingPacketMetadata::detailsPerStream,
testing::UnorderedElementsAre(getStreamDetailsMatcher( testing::UnorderedElementsAre(
frame1Offset, false /* finObserved */))))); getStreamDetailsMatcher(frame1Offset)))));
const auto pkt2Matcher = testing::Field( const auto pkt2Matcher = testing::Field(
&OutstandingPacketWrapper::metadata, &OutstandingPacketWrapper::metadata,
testing::AllOf( testing::AllOf(
@@ -2072,8 +2064,8 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsSingleStreamFinWithRetransmit) {
&OutstandingPacketMetadata::totalPacketsSent, testing::Eq(2)), &OutstandingPacketMetadata::totalPacketsSent, testing::Eq(2)),
testing::Field( testing::Field(
&OutstandingPacketMetadata::detailsPerStream, &OutstandingPacketMetadata::detailsPerStream,
testing::UnorderedElementsAre(getStreamDetailsMatcher( testing::UnorderedElementsAre(
frame2Offset, true /* finObserved */))))); getStreamDetailsMatcher(frame2Offset)))));
EXPECT_THAT( EXPECT_THAT(
conn->outstandings.packets, ElementsAre(pkt1Matcher, pkt2Matcher)); conn->outstandings.packets, ElementsAre(pkt1Matcher, pkt2Matcher));
} }
@@ -2099,7 +2091,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsSingleStreamFinWithRetransmit) {
auto streamDetailsMatcher = testing::Pair( auto streamDetailsMatcher = testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, true),
testing::Field(&PacketStreamDetails::streamBytesSent, frameLen * 2), testing::Field(&PacketStreamDetails::streamBytesSent, frameLen * 2),
testing::Field(&PacketStreamDetails::newStreamBytesSent, 0), testing::Field(&PacketStreamDetails::newStreamBytesSent, 0),
testing::Field( testing::Field(
@@ -2183,7 +2174,6 @@ TEST_F(
return testing::Pair( return testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field(&PacketStreamDetails::streamBytesSent, frameLen), testing::Field(&PacketStreamDetails::streamBytesSent, frameLen),
testing::Field( testing::Field(
&PacketStreamDetails::newStreamBytesSent, frameLen), &PacketStreamDetails::newStreamBytesSent, frameLen),
@@ -2248,7 +2238,6 @@ TEST_F(
auto streamDetailsMatcher = testing::Pair( auto streamDetailsMatcher = testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field(&PacketStreamDetails::streamBytesSent, frameLen * 2), testing::Field(&PacketStreamDetails::streamBytesSent, frameLen * 2),
testing::Field(&PacketStreamDetails::newStreamBytesSent, 0), testing::Field(&PacketStreamDetails::newStreamBytesSent, 0),
testing::Field( testing::Field(
@@ -2337,7 +2326,6 @@ TEST_F(
return testing::Pair( return testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field(&PacketStreamDetails::streamBytesSent, frameLen), testing::Field(&PacketStreamDetails::streamBytesSent, frameLen),
testing::Field( testing::Field(
&PacketStreamDetails::newStreamBytesSent, frameLen), &PacketStreamDetails::newStreamBytesSent, frameLen),
@@ -2402,7 +2390,6 @@ TEST_F(
auto streamDetailsMatcher = testing::Pair( auto streamDetailsMatcher = testing::Pair(
stream->id, stream->id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field(&PacketStreamDetails::streamBytesSent, frameLen * 2), testing::Field(&PacketStreamDetails::streamBytesSent, frameLen * 2),
testing::Field(&PacketStreamDetails::newStreamBytesSent, 0), testing::Field(&PacketStreamDetails::newStreamBytesSent, 0),
testing::Field( testing::Field(
@@ -2481,7 +2468,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsMultipleStreams) {
auto stream1DetailsMatcher = testing::Pair( auto stream1DetailsMatcher = testing::Pair(
stream1Id, stream1Id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field(&PacketStreamDetails::streamBytesSent, stream1Len), testing::Field(&PacketStreamDetails::streamBytesSent, stream1Len),
testing::Field( testing::Field(
&PacketStreamDetails::newStreamBytesSent, stream1Len), &PacketStreamDetails::newStreamBytesSent, stream1Len),
@@ -2495,7 +2481,7 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsMultipleStreams) {
auto stream2DetailsMatcher = testing::Pair( auto stream2DetailsMatcher = testing::Pair(
stream2Id, stream2Id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, true),
testing::Field(&PacketStreamDetails::streamBytesSent, stream2Len), testing::Field(&PacketStreamDetails::streamBytesSent, stream2Len),
testing::Field( testing::Field(
&PacketStreamDetails::newStreamBytesSent, stream2Len), &PacketStreamDetails::newStreamBytesSent, stream2Len),
@@ -2509,7 +2495,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsMultipleStreams) {
auto stream3DetailsMatcher = testing::Pair( auto stream3DetailsMatcher = testing::Pair(
stream3Id, stream3Id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, true),
testing::Field(&PacketStreamDetails::streamBytesSent, stream3Len), testing::Field(&PacketStreamDetails::streamBytesSent, stream3Len),
testing::Field( testing::Field(
&PacketStreamDetails::newStreamBytesSent, stream3Len), &PacketStreamDetails::newStreamBytesSent, stream3Len),
@@ -2556,7 +2541,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsMultipleStreams) {
auto stream1DetailsMatcher = testing::Pair( auto stream1DetailsMatcher = testing::Pair(
stream1Id, stream1Id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, false),
testing::Field(&PacketStreamDetails::streamBytesSent, stream1Len), testing::Field(&PacketStreamDetails::streamBytesSent, stream1Len),
testing::Field(&PacketStreamDetails::newStreamBytesSent, 0), testing::Field(&PacketStreamDetails::newStreamBytesSent, 0),
testing::Field( testing::Field(
@@ -2569,7 +2553,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsMultipleStreams) {
auto stream2DetailsMatcher = testing::Pair( auto stream2DetailsMatcher = testing::Pair(
stream2Id, stream2Id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, true),
testing::Field(&PacketStreamDetails::streamBytesSent, stream2Len), testing::Field(&PacketStreamDetails::streamBytesSent, stream2Len),
testing::Field(&PacketStreamDetails::newStreamBytesSent, 0), testing::Field(&PacketStreamDetails::newStreamBytesSent, 0),
testing::Field( testing::Field(
@@ -2582,7 +2565,6 @@ TEST_F(QuicTransportFunctionsTest, StreamDetailsMultipleStreams) {
auto stream3DetailsMatcher = testing::Pair( auto stream3DetailsMatcher = testing::Pair(
stream3Id, stream3Id,
testing::AllOf( testing::AllOf(
testing::Field(&PacketStreamDetails::finObserved, true),
testing::Field(&PacketStreamDetails::streamBytesSent, stream3Len), testing::Field(&PacketStreamDetails::streamBytesSent, stream3Len),
testing::Field(&PacketStreamDetails::newStreamBytesSent, 0), testing::Field(&PacketStreamDetails::newStreamBytesSent, 0),
testing::Field( testing::Field(

View File

@@ -55,7 +55,6 @@ struct OutstandingPacketMetadata {
using StreamIntervals = IntervalSet<uint64_t, 1, IntervalSetVec>; using StreamIntervals = IntervalSet<uint64_t, 1, IntervalSetVec>;
StreamIntervals streamIntervals; StreamIntervals streamIntervals;
bool finObserved{false};
uint64_t streamBytesSent{0}; uint64_t streamBytesSent{0};
uint64_t newStreamBytesSent{0}; uint64_t newStreamBytesSent{0};
folly::Optional<uint64_t> maybeFirstNewStreamByteOffset; folly::Optional<uint64_t> maybeFirstNewStreamByteOffset;
@@ -76,9 +75,6 @@ struct OutstandingPacketMetadata {
StreamDetails::StreamIntervals::interval_type( StreamDetails::StreamIntervals::interval_type(
frame.offset, frame.offset + frame.len - 1)); frame.offset, frame.offset + frame.len - 1));
} }
if (frame.fin) {
streamDetails.finObserved = true;
}
streamDetails.streamBytesSent += frame.len; streamDetails.streamBytesSent += frame.len;
if (newData) { if (newData) {
streamDetails.newStreamBytesSent += frame.len; streamDetails.newStreamBytesSent += frame.len;