1
0
mirror of https://github.com/facebookincubator/mvfst.git synced 2025-08-01 01:44:22 +03:00

remove isHandshake

Summary: This is effectively an unused field encoding duplicated information, but it was widespread.

Reviewed By: kvtsoy

Differential Revision: D57289922

fbshipit-source-id: ca1499e2576e5ae28e3880b865a29c2b8d9a3d1b
This commit is contained in:
Matt Joras
2024-06-11 11:02:02 -07:00
committed by Facebook GitHub Bot
parent 4e477f20af
commit 6ce29d58ff
20 changed files with 3 additions and 141 deletions

View File

@ -623,7 +623,6 @@ void updateConnection(
auto packetNum = packet.header.getPacketSequenceNum(); auto packetNum = packet.header.getPacketSequenceNum();
// AckFrame, PaddingFrame and Datagrams are not retx-able. // AckFrame, PaddingFrame and Datagrams are not retx-able.
bool retransmittable = false; bool retransmittable = false;
bool isHandshake = false;
bool isPing = false; bool isPing = false;
uint32_t connWindowUpdateSent = 0; uint32_t connWindowUpdateSent = 0;
uint32_t ackFrameCounter = 0; uint32_t ackFrameCounter = 0;
@ -683,9 +682,6 @@ void updateConnection(
auto protectionType = packet.header.getProtectionType(); auto protectionType = packet.header.getProtectionType();
// NewSessionTicket is sent in crypto frame encrypted with 1-rtt key, // NewSessionTicket is sent in crypto frame encrypted with 1-rtt key,
// however, it is not part of handshake // however, it is not part of handshake
isHandshake =
(protectionType == ProtectionType::Initial ||
protectionType == ProtectionType::Handshake);
auto encryptionLevel = protectionTypeToEncryptionLevel(protectionType); auto encryptionLevel = protectionTypeToEncryptionLevel(protectionType);
handleStreamWritten( handleStreamWritten(
conn, conn,
@ -877,7 +873,6 @@ void updateConnection(
sentTime, sentTime,
encodedSize, encodedSize,
encodedBodySize, encodedBodySize,
isHandshake,
// these numbers should all _include_ the current packet // these numbers should all _include_ the current packet
// conn.lossState.inflightBytes isn't updated until below // conn.lossState.inflightBytes isn't updated until below
// conn.outstandings.numOutstanding() + 1 since we're emplacing here // conn.outstandings.numOutstanding() + 1 since we're emplacing here

View File

@ -45,7 +45,6 @@ PacketNum addInitialOutstandingPacket(QuicConnectionStateBase& conn) {
Clock::now(), Clock::now(),
0, 0,
0, 0,
true,
0, 0,
0, 0,
LossState(), LossState(),
@ -73,7 +72,6 @@ PacketNum addHandshakeOutstandingPacket(QuicConnectionStateBase& conn) {
Clock::now(), Clock::now(),
0, 0,
0, 0,
true,
0, 0,
0, 0,
LossState(), LossState(),
@ -96,7 +94,6 @@ PacketNum addOutstandingPacket(QuicConnectionStateBase& conn) {
Clock::now(), Clock::now(),
0, 0,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),

View File

@ -3288,36 +3288,6 @@ TEST_F(QuicTransportFunctionsTest, ProbingFallbackToImmediateAck) {
EXPECT_EQ(1, conn->outstandings.packets.size()); EXPECT_EQ(1, conn->outstandings.packets.size());
} }
TEST_F(QuicTransportFunctionsTest, TestCryptoWritingIsHandshakeInOutstanding) {
auto conn = createConn();
auto cryptoStream = &conn->cryptoState->initialStream;
auto buf = buildRandomInputData(200);
writeDataToQuicStream(*cryptoStream, buf->clone());
EventBase evb;
std::shared_ptr<FollyQuicEventBase> qEvb =
std::make_shared<FollyQuicEventBase>(&evb);
auto socket =
std::make_unique<NiceMock<quic::test::MockAsyncUDPSocket>>(qEvb);
auto rawSocket = socket.get();
auto res = writeCryptoAndAckDataToSocket(
*rawSocket,
*conn,
*conn->clientConnectionId,
*conn->serverConnectionId,
LongHeader::Types::Initial,
*conn->initialWriteCipher,
*conn->initialHeaderCipher,
getVersion(*conn),
conn->transportSettings.writeConnectionDataPacketsLimit);
EXPECT_EQ(1, res.packetsWritten);
EXPECT_EQ(0, res.probesWritten);
EXPECT_GE(res.bytesWritten, buf->computeChainDataLength());
ASSERT_EQ(1, conn->outstandings.packets.size());
EXPECT_TRUE(getFirstOutstandingPacket(*conn, PacketNumberSpace::Initial)
->metadata.isHandshake);
}
TEST_F(QuicTransportFunctionsTest, NoCryptoProbeWriteIfNoProbeCredit) { TEST_F(QuicTransportFunctionsTest, NoCryptoProbeWriteIfNoProbeCredit) {
auto conn = createConn(); auto conn = createConn();
auto cryptoStream = &conn->cryptoState->initialStream; auto cryptoStream = &conn->cryptoState->initialStream;
@ -3345,8 +3315,6 @@ TEST_F(QuicTransportFunctionsTest, NoCryptoProbeWriteIfNoProbeCredit) {
EXPECT_EQ(0, res.probesWritten); EXPECT_EQ(0, res.probesWritten);
EXPECT_EQ(conn->udpSendPacketLen, res.bytesWritten); EXPECT_EQ(conn->udpSendPacketLen, res.bytesWritten);
ASSERT_EQ(1, conn->outstandings.packets.size()); ASSERT_EQ(1, conn->outstandings.packets.size());
EXPECT_TRUE(getFirstOutstandingPacket(*conn, PacketNumberSpace::Initial)
->metadata.isHandshake);
ASSERT_EQ(1, cryptoStream->retransmissionBuffer.size()); ASSERT_EQ(1, cryptoStream->retransmissionBuffer.size());
ASSERT_TRUE(cryptoStream->writeBuffer.empty()); ASSERT_TRUE(cryptoStream->writeBuffer.empty());

View File

@ -33,7 +33,6 @@ OutstandingPacketWrapper makeDummyOutstandingPacket(
Clock::now(), Clock::now(),
1000, 1000,
0, 0,
false,
totalBytesSentOnConnection, totalBytesSentOnConnection,
0, 0,
LossState(), LossState(),

View File

@ -173,12 +173,6 @@ OutstandingPacketBuilder&& OutstandingPacketBuilder::setEncodedBodySize(
return std::move(*this); return std::move(*this);
} }
OutstandingPacketBuilder&& OutstandingPacketBuilder::setIsHandshake(
const bool& isHandshakeIn) {
maybeIsHandshake = isHandshakeIn;
return std::move(*this);
}
OutstandingPacketBuilder&& OutstandingPacketBuilder::setTotalBytesSent( OutstandingPacketBuilder&& OutstandingPacketBuilder::setTotalBytesSent(
const uint64_t& totalBytesSentIn) { const uint64_t& totalBytesSentIn) {
maybeTotalBytesSent = totalBytesSentIn; maybeTotalBytesSent = totalBytesSentIn;
@ -235,7 +229,6 @@ OutstandingPacketWrapper OutstandingPacketBuilder::build() && {
*CHECK_NOTNULL(maybeTime.get_pointer()), *CHECK_NOTNULL(maybeTime.get_pointer()),
*CHECK_NOTNULL(maybeEncodedSize.get_pointer()), *CHECK_NOTNULL(maybeEncodedSize.get_pointer()),
*CHECK_NOTNULL(maybeEncodedBodySize.get_pointer()), *CHECK_NOTNULL(maybeEncodedBodySize.get_pointer()),
*CHECK_NOTNULL(maybeIsHandshake.get_pointer()),
*CHECK_NOTNULL(maybeTotalBytesSent.get_pointer()), *CHECK_NOTNULL(maybeTotalBytesSent.get_pointer()),
*CHECK_NOTNULL(maybeInflightBytes.get_pointer()), *CHECK_NOTNULL(maybeInflightBytes.get_pointer()),
CHECK_NOTNULL(maybeLossState.get_pointer())->get(), CHECK_NOTNULL(maybeLossState.get_pointer())->get(),

View File

@ -54,7 +54,6 @@ struct OutstandingPacketBuilderFields {
folly::Optional<TimePoint> maybeTime; folly::Optional<TimePoint> maybeTime;
folly::Optional<uint32_t> maybeEncodedSize; folly::Optional<uint32_t> maybeEncodedSize;
folly::Optional<uint32_t> maybeEncodedBodySize; folly::Optional<uint32_t> maybeEncodedBodySize;
folly::Optional<bool> maybeIsHandshake;
folly::Optional<uint64_t> maybeTotalBytesSent; folly::Optional<uint64_t> maybeTotalBytesSent;
folly::Optional<uint64_t> maybeTotalBodyBytesSent; folly::Optional<uint64_t> maybeTotalBodyBytesSent;
folly::Optional<uint64_t> maybeInflightBytes; folly::Optional<uint64_t> maybeInflightBytes;
@ -73,7 +72,6 @@ struct OutstandingPacketBuilder : public OutstandingPacketBuilderFields {
Builder&& setTime(const TimePoint& timeIn); Builder&& setTime(const TimePoint& timeIn);
Builder&& setEncodedSize(const uint32_t& encodedSizeIn); Builder&& setEncodedSize(const uint32_t& encodedSizeIn);
Builder&& setEncodedBodySize(const uint32_t& encodedBodySizeIn); Builder&& setEncodedBodySize(const uint32_t& encodedBodySizeIn);
Builder&& setIsHandshake(const bool& isHandshakeIn);
Builder&& setTotalBytesSent(const uint64_t& totalBytesSentIn); Builder&& setTotalBytesSent(const uint64_t& totalBytesSentIn);
Builder&& setTotalBodyBytesSent(const uint64_t& totalBodyBytesSentIn); Builder&& setTotalBodyBytesSent(const uint64_t& totalBodyBytesSentIn);
Builder&& setInflightBytes(const uint64_t& inflightBytesIn); Builder&& setInflightBytes(const uint64_t& inflightBytesIn);

View File

@ -549,7 +549,6 @@ OutstandingPacketWrapper makeTestingWritePacket(
sentTime, sentTime,
desiredSize, desiredSize,
0, 0,
false,
totalBytesSent, totalBytesSent,
inflightBytes, inflightBytes,
LossState(), LossState(),
@ -579,7 +578,6 @@ CongestionController::AckEvent makeAck(
sentTime, sentTime,
ackedSize /* encodedSize */, ackedSize /* encodedSize */,
ackedSize /* encodedBodySize */, ackedSize /* encodedBodySize */,
false /* isHandshake */,
0 /* totalBytesSent */, 0 /* totalBytesSent */,
0 /* inflightBytes */, 0 /* inflightBytes */,
LossState() /* lossState */, LossState() /* lossState */,

View File

@ -30,7 +30,6 @@ class Copa2Test : public Test {
std::move(packet), std::move(packet),
Clock::now(), Clock::now(),
size, size,
false,
totalSent, totalSent,
inflight, inflight,
0, 0,

View File

@ -34,7 +34,6 @@ class CopaTest : public Test {
Clock::now(), Clock::now(),
10, 10,
0, 0,
false,
totalSentBytes, totalSentBytes,
0, 0,
LossState(), LossState(),
@ -59,7 +58,6 @@ class CopaTest : public Test {
Clock::now(), Clock::now(),
size, size,
0, 0,
false,
totalSent, totalSent,
inflight, inflight,
LossState(), LossState(),

View File

@ -30,7 +30,6 @@ CongestionController::LossEvent createLossEvent(
Clock::now(), Clock::now(),
10, 10,
0, 0,
false,
10, 10,
0, 0,
LossState(), LossState(),
@ -64,7 +63,6 @@ CongestionController::AckEvent createAckEvent(
packetSentTime, packetSentTime,
ackedSize, ackedSize,
0, 0,
false,
ackedSize, ackedSize,
0, 0,
LossState(), LossState(),
@ -86,7 +84,6 @@ OutstandingPacketWrapper createPacket(
sendTime, sendTime,
size, size,
0, 0,
false,
size, size,
inflight, inflight,
LossState(), LossState(),

View File

@ -373,8 +373,7 @@ bool processOutstandingsForLoss(
CHECK(conn.outstandings.packetCount[currentPacketNumberSpace]); CHECK(conn.outstandings.packetCount[currentPacketNumberSpace]);
--conn.outstandings.packetCount[currentPacketNumberSpace]; --conn.outstandings.packetCount[currentPacketNumberSpace];
} }
VLOG(10) << __func__ << " lost packetNum=" << currentPacketNum VLOG(10) << __func__ << " lost packetNum=" << currentPacketNum;
<< " handshake=" << pkt.metadata.isHandshake << " " << conn;
// Rather than erasing here, instead mark the packet as lost so we can // Rather than erasing here, instead mark the packet as lost so we can
// determine if this was spurious later. // determine if this was spurious later.
conn.lossState.totalPacketsMarkedLost++; conn.lossState.totalPacketsMarkedLost++;

View File

@ -287,7 +287,6 @@ void markZeroRttPacketsLost(
iter->packet.header.getProtectionType() == ProtectionType::ZeroRtt; iter->packet.header.getProtectionType() == ProtectionType::ZeroRtt;
if (isZeroRttPacket) { if (isZeroRttPacket) {
auto& pkt = *iter; auto& pkt = *iter;
DCHECK(!pkt.metadata.isHandshake);
bool processed = pkt.associatedEvent && bool processed = pkt.associatedEvent &&
!conn.outstandings.packetEvents.count(*pkt.associatedEvent); !conn.outstandings.packetEvents.count(*pkt.associatedEvent);
lossVisitor(conn, pkt.packet, processed); lossVisitor(conn, pkt.packet, processed);

View File

@ -194,7 +194,6 @@ PacketNum QuicLossFunctionsTest::sendPacket(
folly::Optional<uint16_t> forcedSize, folly::Optional<uint16_t> forcedSize,
bool isDsr) { bool isDsr) {
folly::Optional<PacketHeader> header; folly::Optional<PacketHeader> header;
bool isHandshake = false;
switch (packetType) { switch (packetType) {
case PacketType::Initial: case PacketType::Initial:
header = LongHeader( header = LongHeader(
@ -203,7 +202,6 @@ PacketNum QuicLossFunctionsTest::sendPacket(
*conn.serverConnectionId, *conn.serverConnectionId,
conn.ackStates.initialAckState->nextPacketNum, conn.ackStates.initialAckState->nextPacketNum,
*conn.version); *conn.version);
isHandshake = true;
break; break;
case PacketType::Handshake: case PacketType::Handshake:
header = LongHeader( header = LongHeader(
@ -212,7 +210,6 @@ PacketNum QuicLossFunctionsTest::sendPacket(
*conn.serverConnectionId, *conn.serverConnectionId,
conn.ackStates.handshakeAckState->nextPacketNum, conn.ackStates.handshakeAckState->nextPacketNum,
*conn.version); *conn.version);
isHandshake = true;
break; break;
case PacketType::ZeroRtt: case PacketType::ZeroRtt:
header = LongHeader( header = LongHeader(
@ -263,7 +260,6 @@ PacketNum QuicLossFunctionsTest::sendPacket(
time, time,
encodedSize, encodedSize,
encodedBodySize, encodedBodySize,
isHandshake,
encodedSize, encodedSize,
0, 0,
LossState(), LossState(),
@ -735,9 +731,7 @@ TEST_F(QuicLossFunctionsTest, TestReorderingThreshold) {
iter < iter <
getFirstOutstandingPacket(*conn, PacketNumberSpace::Handshake) + 5; getFirstOutstandingPacket(*conn, PacketNumberSpace::Handshake) + 5;
iter++) { iter++) {
if (iter->metadata.isHandshake) { conn->outstandings.packetCount[PacketNumberSpace::Handshake]--;
conn->outstandings.packetCount[PacketNumberSpace::Handshake]--;
}
} }
auto firstHandshakeOpIter = auto firstHandshakeOpIter =
getFirstOutstandingPacket(*conn, PacketNumberSpace::Handshake); getFirstOutstandingPacket(*conn, PacketNumberSpace::Handshake);
@ -794,7 +788,6 @@ TEST_F(QuicLossFunctionsTest, TestHandleAckForLoss) {
now, now,
0, 0,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -1850,7 +1843,6 @@ TEST_F(QuicLossFunctionsTest, PersistentCongestionAckOutsideWindow) {
currentTime + 12s /* sentTime */, currentTime + 12s /* sentTime */,
0 /* encodedSize */, 0 /* encodedSize */,
0 /* encodedBodySize */, 0 /* encodedBodySize */,
false /* isHandshake */,
0 /* totalBytesSent */, 0 /* totalBytesSent */,
0 /* inflightBytes */, 0 /* inflightBytes */,
LossState() /* lossState */, LossState() /* lossState */,
@ -1885,7 +1877,6 @@ TEST_F(QuicLossFunctionsTest, PersistentCongestionAckInsideWindow) {
currentTime + 4s /* sentTime */, currentTime + 4s /* sentTime */,
0 /* encodedSize */, 0 /* encodedSize */,
0 /* encodedBodySize */, 0 /* encodedBodySize */,
false /* isHandshake */,
0 /* totalBytesSent */, 0 /* totalBytesSent */,
0 /* inflightBytes */, 0 /* inflightBytes */,
LossState() /* lossState */, LossState() /* lossState */,
@ -1919,7 +1910,6 @@ TEST_F(QuicLossFunctionsTest, PersistentCongestionNoPTO) {
currentTime + 12s /* sentTime */, currentTime + 12s /* sentTime */,
0 /* encodedSize */, 0 /* encodedSize */,
0 /* encodedBodySize */, 0 /* encodedBodySize */,
false /* isHandshake */,
0 /* totalBytesSent */, 0 /* totalBytesSent */,
0 /* inflightBytes */, 0 /* inflightBytes */,
LossState() /* lossState */, LossState() /* lossState */,

View File

@ -54,7 +54,6 @@ class SocketObserverInterfaceTest : public ::testing::Test {
.setTime(TimePoint()) .setTime(TimePoint())
.setEncodedSize(0) .setEncodedSize(0)
.setEncodedBodySize(0) .setEncodedBodySize(0)
.setIsHandshake(false)
.setTotalBytesSent(0) .setTotalBytesSent(0)
.setTotalBodyBytesSent(0) .setTotalBodyBytesSent(0)
.setInflightBytes(0) .setInflightBytes(0)

View File

@ -225,9 +225,7 @@ AckEvent processAckFrame(
rPacketIt->metadata.scheduledForDestruction = true; rPacketIt->metadata.scheduledForDestruction = true;
conn.outstandings.scheduledForDestructionCount++; conn.outstandings.scheduledForDestructionCount++;
VLOG(10) << __func__ << " acked packetNum=" << currentPacketNum VLOG(10) << __func__ << " acked packetNum=" << currentPacketNum
<< " space=" << currentPacketNumberSpace << " handshake=" << " space=" << currentPacketNumberSpace << conn;
<< (int)((rPacketIt->metadata.isHandshake) ? 1 : 0) << " "
<< conn;
// If we hit a packet which has been lost we need to count the spurious // If we hit a packet which has been lost we need to count the spurious
// loss and ignore all other processing. // loss and ignore all other processing.
if (rPacketIt->declaredLost) { if (rPacketIt->declaredLost) {

View File

@ -22,8 +22,6 @@ struct OutstandingPacketMetadata {
uint32_t encodedSize; uint32_t encodedSize;
// Size of only the body within the packet sent on the wire. // Size of only the body within the packet sent on the wire.
uint32_t encodedBodySize; uint32_t encodedBodySize;
// Whether this packet has any data from stream 0
bool isHandshake;
// Total sent bytes on this connection including this packet itself when this // Total sent bytes on this connection including this packet itself when this
// packet is sent. // packet is sent.
uint64_t totalBytesSent; uint64_t totalBytesSent;
@ -114,7 +112,6 @@ struct OutstandingPacketMetadata {
TimePoint timeIn, TimePoint timeIn,
uint32_t encodedSizeIn, uint32_t encodedSizeIn,
uint32_t encodedBodySizeIn, uint32_t encodedBodySizeIn,
bool isHandshakeIn,
uint64_t totalBytesSentIn, uint64_t totalBytesSentIn,
uint64_t inflightBytesIn, uint64_t inflightBytesIn,
const LossState& lossStateIn, const LossState& lossStateIn,
@ -124,7 +121,6 @@ struct OutstandingPacketMetadata {
: time(timeIn), : time(timeIn),
encodedSize(encodedSizeIn), encodedSize(encodedSizeIn),
encodedBodySize(encodedBodySizeIn), encodedBodySize(encodedBodySizeIn),
isHandshake(isHandshakeIn),
totalBytesSent(totalBytesSentIn), totalBytesSent(totalBytesSentIn),
inflightBytes(inflightBytesIn), inflightBytes(inflightBytesIn),
totalAckElicitingPacketsSent(lossStateIn.totalAckElicitingPacketsSent), totalAckElicitingPacketsSent(lossStateIn.totalAckElicitingPacketsSent),
@ -198,7 +194,6 @@ struct OutstandingPacket {
TimePoint timeIn, TimePoint timeIn,
uint32_t encodedSizeIn, uint32_t encodedSizeIn,
uint32_t encodedBodySizeIn, uint32_t encodedBodySizeIn,
bool isHandshakeIn,
uint64_t totalBytesSentIn, uint64_t totalBytesSentIn,
uint64_t inflightBytesIn, uint64_t inflightBytesIn,
const LossState& lossStateIn, const LossState& lossStateIn,
@ -210,7 +205,6 @@ struct OutstandingPacket {
timeIn, timeIn,
encodedSizeIn, encodedSizeIn,
encodedBodySizeIn, encodedBodySizeIn,
isHandshakeIn,
totalBytesSentIn, totalBytesSentIn,
inflightBytesIn, inflightBytesIn,
lossStateIn, lossStateIn,
@ -232,7 +226,6 @@ struct OutstandingPacketWrapper : OutstandingPacket {
TimePoint timeIn, TimePoint timeIn,
uint32_t encodedSizeIn, uint32_t encodedSizeIn,
uint32_t encodedBodySizeIn, uint32_t encodedBodySizeIn,
bool isHandshakeIn,
uint64_t totalBytesSentIn, uint64_t totalBytesSentIn,
uint64_t inflightBytesIn, uint64_t inflightBytesIn,
const LossState& lossStateIn, const LossState& lossStateIn,
@ -246,7 +239,6 @@ struct OutstandingPacketWrapper : OutstandingPacket {
timeIn, timeIn,
encodedSizeIn, encodedSizeIn,
encodedBodySizeIn, encodedBodySizeIn,
isHandshakeIn,
totalBytesSentIn, totalBytesSentIn,
inflightBytesIn, inflightBytesIn,
lossStateIn, lossStateIn,

View File

@ -71,7 +71,6 @@ auto emplacePackets(
sentTime, sentTime,
1, 1,
0, 0,
false /* handshake */,
packetNum, packetNum,
packetNum + 1, packetNum + 1,
quic::LossState(), quic::LossState(),
@ -190,7 +189,6 @@ TEST_P(AckHandlersTest, TestAckMultipleSequentialBlocks) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -267,7 +265,6 @@ TEST_P(AckHandlersTest, TestAckWithECN) {
packetSendTime, packetSendTime,
0, 0,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -339,7 +336,6 @@ TEST_P(AckHandlersTest, TestSpuriousLossFullRemoval) {
startTime, startTime,
1, 1,
0, 0,
false /* handshake */,
0, 0,
1, 1,
quic::LossState(), quic::LossState(),
@ -419,7 +415,6 @@ TEST_P(AckHandlersTest, TestSpuriousLossSplitMiddleRemoval) {
startTime, startTime,
1, 1,
0, 0,
false /* handshake */,
0, 0,
1, 1,
quic::LossState(), quic::LossState(),
@ -505,7 +500,6 @@ TEST_P(AckHandlersTest, TestSpuriousLossTrimFrontRemoval) {
startTime, startTime,
1, 1,
0, 0,
false /* handshake */,
0, 0,
1, 1,
quic::LossState(), quic::LossState(),
@ -588,7 +582,6 @@ TEST_P(AckHandlersTest, TestSpuriousLossSplitFrontRemoval) {
startTime, startTime,
1, 1,
0, 0,
false /* handshake */,
0, 0,
1, 1,
quic::LossState(), quic::LossState(),
@ -674,7 +667,6 @@ TEST_P(AckHandlersTest, TestPacketDestructionAcks) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -754,7 +746,6 @@ TEST_P(AckHandlersTest, TestPacketDestructionSpuriousLoss) {
startTime + std::chrono::milliseconds((packetNum - 1) * 100), startTime + std::chrono::milliseconds((packetNum - 1) * 100),
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -820,7 +811,6 @@ TEST_P(AckHandlersTest, TestPacketDestructionSpuriousLoss) {
startTime + std::chrono::milliseconds((packetNum - 1) * 100), startTime + std::chrono::milliseconds((packetNum - 1) * 100),
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -898,7 +888,6 @@ TEST_P(AckHandlersTest, TestPacketDestructionBigDeque) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -1005,7 +994,6 @@ TEST_P(AckHandlersTest, TestAckMultipleSequentialBlocksLoss) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -1163,7 +1151,6 @@ TEST_P(AckHandlersTest, TestAckBlocksWithGaps) {
Clock::now(), Clock::now(),
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -1281,7 +1268,6 @@ TEST_P(AckHandlersTest, TestNonSequentialPacketNumbers) {
Clock::now(), Clock::now(),
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -1303,7 +1289,6 @@ TEST_P(AckHandlersTest, TestNonSequentialPacketNumbers) {
Clock::now(), Clock::now(),
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -1400,7 +1385,6 @@ TEST_P(AckHandlersTest, AckVisitorForAckTest) {
Clock::now(), Clock::now(),
0, 0,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -1422,7 +1406,6 @@ TEST_P(AckHandlersTest, AckVisitorForAckTest) {
Clock::now(), Clock::now(),
0, 0,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -1495,7 +1478,6 @@ TEST_P(AckHandlersTest, NoNewAckedPacket) {
Clock::now(), Clock::now(),
0, 0,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -1555,7 +1537,6 @@ TEST_P(AckHandlersTest, AckPacketNumDoesNotExist) {
Clock::now(), Clock::now(),
0, 0,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -1572,7 +1553,6 @@ TEST_P(AckHandlersTest, AckPacketNumDoesNotExist) {
Clock::now(), Clock::now(),
0, 0,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -1616,7 +1596,6 @@ TEST_P(AckHandlersTest, TestHandshakeCounterUpdate) {
Clock::now(), Clock::now(),
0, 0,
0, 0,
packetNum % 2 && GetParam().pnSpace != PacketNumberSpace::AppData,
packetNum / 2, packetNum / 2,
0, 0,
LossState(), LossState(),
@ -1828,7 +1807,6 @@ TEST_P(AckHandlersTest, NoSkipAckVisitor) {
Clock::now(), Clock::now(),
1, 1,
0, 0,
false,
1, 1,
0, 0,
LossState(), LossState(),
@ -1892,7 +1870,6 @@ TEST_P(AckHandlersTest, SkipAckVisitor) {
Clock::now(), Clock::now(),
1, 1,
0, 0,
false,
1, 1,
0, 0,
LossState(), LossState(),
@ -1954,7 +1931,6 @@ TEST_P(AckHandlersTest, MultiplePacketProcessors) {
Clock::now(), Clock::now(),
1, 1,
0, 0,
false,
1 * (packetNum + 1), 1 * (packetNum + 1),
0, 0,
LossState(), LossState(),
@ -2015,7 +1991,6 @@ TEST_P(AckHandlersTest, NoDoubleProcess) {
Clock::now(), Clock::now(),
1, 1,
0, 0,
false,
1, 1,
0, 0,
LossState(), LossState(),
@ -2028,7 +2003,6 @@ TEST_P(AckHandlersTest, NoDoubleProcess) {
Clock::now(), Clock::now(),
1, 1,
0, 0,
false,
1, 1,
0, 0,
LossState(), LossState(),
@ -2094,7 +2068,6 @@ TEST_P(AckHandlersTest, ClonedPacketsCounter) {
Clock::now(), Clock::now(),
1, 1,
0, 0,
false,
1, 1,
0, 0,
LossState(), LossState(),
@ -2111,7 +2084,6 @@ TEST_P(AckHandlersTest, ClonedPacketsCounter) {
Clock::now(), Clock::now(),
1, 1,
0, 0,
false,
1, 1,
0, 0,
LossState(), LossState(),
@ -2163,7 +2135,6 @@ TEST_P(AckHandlersTest, UpdateMaxAckDelay) {
sentTime, sentTime,
1, 1,
0, 0,
false,
1, 1,
0, 0,
LossState(), LossState(),
@ -2239,7 +2210,6 @@ TEST_P(AckHandlersTest, AckNotOutstandingButLoss) {
Clock::now() - delayUntilLost - 20ms, Clock::now() - delayUntilLost - 20ms,
1, 1,
0, 0,
false,
1, 1,
0, 0,
LossState(), LossState(),
@ -2290,7 +2260,6 @@ TEST_P(AckHandlersTest, UpdatePendingAckStates) {
sentTime, sentTime,
111, 111,
100, 100,
false,
conn.lossState.totalBytesSent + 111, conn.lossState.totalBytesSent + 111,
0, 0,
LossState(), LossState(),
@ -2359,7 +2328,6 @@ TEST_P(AckHandlersTest, AckEventCreation) {
getSentTime(packetNum), getSentTime(packetNum),
1 /* encodedSizeIn */, 1 /* encodedSizeIn */,
0 /* encodedBodySizeIn */, 0 /* encodedBodySizeIn */,
false /* isHandshakeIn */,
1 * (packetNum + 1) /* totalBytesSentIn */, 1 * (packetNum + 1) /* totalBytesSentIn */,
0 /* inflightBytesIn */, 0 /* inflightBytesIn */,
LossState(), LossState(),
@ -2487,7 +2455,6 @@ TEST_P(AckHandlersTest, AckEventCreationSingleWrite) {
getSentTime(packetNum), getSentTime(packetNum),
1 /* encodedSizeIn */, 1 /* encodedSizeIn */,
0 /* encodedBodySizeIn */, 0 /* encodedBodySizeIn */,
false /* isHandshakeIn */,
1 * (packetNum + 1) /* totalBytesSentIn */, 1 * (packetNum + 1) /* totalBytesSentIn */,
0 /* inflightBytesIn */, 0 /* inflightBytesIn */,
LossState(), LossState(),
@ -2616,7 +2583,6 @@ TEST_P(AckHandlersTest, AckEventCreationNoCongestionController) {
getSentTime(packetNum), getSentTime(packetNum),
1 /* encodedSizeIn */, 1 /* encodedSizeIn */,
0 /* encodedBodySizeIn */, 0 /* encodedBodySizeIn */,
false /* isHandshakeIn */,
1 * (packetNum + 1) /* totalBytesSentIn */, 1 * (packetNum + 1) /* totalBytesSentIn */,
0 /* inflightBytesIn */, 0 /* inflightBytesIn */,
LossState(), LossState(),
@ -3350,7 +3316,6 @@ TEST_P(AckHandlersTest, AckEventCreationInvalidAckDelay) {
getSentTime(packetNum), getSentTime(packetNum),
1 /* encodedSizeIn */, 1 /* encodedSizeIn */,
0 /* encodedBodySizeIn */, 0 /* encodedBodySizeIn */,
false /* isHandshakeIn */,
1 * (packetNum + 1) /* totalBytesSentIn */, 1 * (packetNum + 1) /* totalBytesSentIn */,
0 /* inflightBytesIn */, 0 /* inflightBytesIn */,
LossState(), LossState(),
@ -3454,7 +3419,6 @@ TEST_P(AckHandlersTest, AckEventCreationRttMinusAckDelayIsZero) {
getSentTime(packetNum), getSentTime(packetNum),
1 /* encodedSizeIn */, 1 /* encodedSizeIn */,
0 /* encodedBodySizeIn */, 0 /* encodedBodySizeIn */,
false /* isHandshakeIn */,
1 * (packetNum + 1) /* totalBytesSentIn */, 1 * (packetNum + 1) /* totalBytesSentIn */,
0 /* inflightBytesIn */, 0 /* inflightBytesIn */,
LossState(), LossState(),
@ -3565,7 +3529,6 @@ TEST_P(AckHandlersTest, AckEventCreationReorderingLargestPacketAcked) {
getSentTime(packetNum), getSentTime(packetNum),
1 /* encodedSizeIn */, 1 /* encodedSizeIn */,
0 /* encodedBodySizeIn */, 0 /* encodedBodySizeIn */,
false /* isHandshakeIn */,
1 * (packetNum + 1) /* totalBytesSentIn */, 1 * (packetNum + 1) /* totalBytesSentIn */,
0 /* inflightBytesIn */, 0 /* inflightBytesIn */,
LossState(), LossState(),
@ -3797,7 +3760,6 @@ TEST_P(AckHandlersTest, AckEventCreationNoMatchingPacketDueToLoss) {
getSentTime(packetNum), getSentTime(packetNum),
1 /* encodedSizeIn */, 1 /* encodedSizeIn */,
0 /* encodedBodySizeIn */, 0 /* encodedBodySizeIn */,
false /* isHandshakeIn */,
1 * (packetNum + 1) /* totalBytesSentIn */, 1 * (packetNum + 1) /* totalBytesSentIn */,
0 /* inflightBytesIn */, 0 /* inflightBytesIn */,
LossState(), LossState(),
@ -3938,7 +3900,6 @@ TEST_P(AckHandlersTest, ImplictAckEventCreation) {
getSentTime(packetNum), getSentTime(packetNum),
1 /* encodedSizeIn */, 1 /* encodedSizeIn */,
0 /* encodedBodySizeIn */, 0 /* encodedBodySizeIn */,
false /* isHandshakeIn */,
1 * (packetNum + 1) /* totalBytesSentIn */, 1 * (packetNum + 1) /* totalBytesSentIn */,
0 /* inflightBytesIn */, 0 /* inflightBytesIn */,
LossState(), LossState(),
@ -4040,7 +4001,6 @@ TEST_P(AckHandlersTest, ObserverRttSample) {
sentTime, sentTime,
1, 1,
0, 0,
false /* handshake */,
packetNum, packetNum,
packetNum + 1, packetNum + 1,
LossState(), LossState(),
@ -4324,7 +4284,6 @@ TEST_P(AckHandlersTest, SubMicrosecondRTT) {
packetSendTime, packetSendTime,
0, 0,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),

View File

@ -48,7 +48,6 @@ TEST(OutstandingPacketTest, BasicPacketDestructionCallback) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -98,7 +97,6 @@ TEST(OutstandingPacketTest, BasicPacketDestructionDequeDestroy) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -138,7 +136,6 @@ TEST(OutstandingPacketTest, BasicPacketDestructionNoCallback) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -174,7 +171,6 @@ TEST(OutstandingPacketTest, PacketMoveConstuctorCallback) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -217,7 +213,6 @@ TEST(OutstandingPacketTest, PacketMoveAssignCallback) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -260,7 +255,6 @@ TEST(OutstandingPacketTest, PacketMoveAssignExistingPacketCallback) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),
@ -280,7 +274,6 @@ TEST(OutstandingPacketTest, PacketMoveAssignExistingPacketCallback) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum + 1, packetNum + 1,
0, 0,
LossState(), LossState(),
@ -333,7 +326,6 @@ TEST(OutstandingPacketTest, DequeMoveAssignPacketDestructionCallback) {
sentTime, sentTime,
1, 1,
0, 0,
false,
packetNum, packetNum,
0, 0,
LossState(), LossState(),

View File

@ -1142,7 +1142,6 @@ TEST_F(QuicStateFunctionsTest, GetOutstandingPackets) {
Clock::now(), Clock::now(),
135, 135,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -1153,7 +1152,6 @@ TEST_F(QuicStateFunctionsTest, GetOutstandingPackets) {
Clock::now(), Clock::now(),
1217, 1217,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -1164,7 +1162,6 @@ TEST_F(QuicStateFunctionsTest, GetOutstandingPackets) {
Clock::now(), Clock::now(),
5556, 5556,
5000, 5000,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -1175,7 +1172,6 @@ TEST_F(QuicStateFunctionsTest, GetOutstandingPackets) {
Clock::now(), Clock::now(),
56, 56,
0, 0,
false,
0, 0,
0, 0,
LossState(), LossState(),
@ -1186,7 +1182,6 @@ TEST_F(QuicStateFunctionsTest, GetOutstandingPackets) {
Clock::now(), Clock::now(),
6665, 6665,
6000, 6000,
false,
0, 0,
0, 0,
LossState(), LossState(),

View File

@ -150,7 +150,6 @@ TEST_F(StateDataTest, SingleLostPacketEvent) {
Clock::now(), Clock::now(),
1234, 1234,
0, 0,
false,
1234, 1234,
0, 0,
LossState(), LossState(),
@ -174,7 +173,6 @@ TEST_F(StateDataTest, MultipleLostPacketsEvent) {
Clock::now(), Clock::now(),
1234, 1234,
0, 0,
false,
1234, 1234,
0, 0,
LossState(), LossState(),
@ -192,7 +190,6 @@ TEST_F(StateDataTest, MultipleLostPacketsEvent) {
Clock::now(), Clock::now(),
1357, 1357,
0, 0,
false,
1357, 1357,
0, 0,
LossState(), LossState(),