| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/api/ |
| H A D | QuicTransportFunctions.h | 72 const ConnectionId& srcConnId,
95 const ConnectionId& srcConnId,
110 const ConnectionId& srcConnId,
127 const ConnectionId& srcConnId,
141 const ConnectionId& srcConnId,
232 const ConnectionId& srcConnId,
275 const ConnectionId& srcConnId,
290 const ConnectionId& srcConnId,
305 const ConnectionId& srcConnId,
|
| H A D | QuicTransportFunctions.cpp | 132 srcConnId, in writeQuicDataToSocketImpl()
168 srcConnId, in writeQuicDataToSocketImpl()
988 srcConnId, in writeCryptoAndAckDataToSocket()
1007 srcConnId, in writeCryptoAndAckDataToSocket()
1039 srcConnId, in writeQuicDataToSocket()
1060 srcConnId, in writeQuicDataExceptCryptoStreamToSocket()
1099 srcConnId, in writeZeroRttDataToSocket()
1233 srcConnId, in writeLongClose()
1438 srcConnId, in writeProbingDataToSocket()
1460 srcConnId, in writeProbingDataToSocket()
[all …]
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/codec/test/ |
| H A D | QuicPacketBuilderTest.cpp | 123 VersionNegotiationPacketBuilder builder(srcConnId, destConnId, versions); in TEST_F()
130 EXPECT_EQ(resultVersionNegotiationPacket.sourceConnectionId, srcConnId); in TEST_F()
167 EXPECT_EQ(resultVersionNegotiationPacket.sourceConnectionId, srcConnId); in TEST_F()
176 EXPECT_EQ(decodedPacket->sourceConnectionId, srcConnId); in TEST_F()
569 auto srcConnId = getTestConnectionId(0); in TEST_F() local
578 srcConnId, in TEST_F()
654 srcConnId, in TEST_F()
665 srcConnId.size() + retryToken.size() + kRetryIntegrityTagLen; in TEST_F()
688 EXPECT_EQ(scidLen, srcConnId.size()); in TEST_F()
692 EXPECT_EQ(scidObtained, srcConnId); in TEST_F()
[all …]
|
| H A D | QuicHeaderCodecTest.cpp | 37 ConnectionId srcConnId = getTestConnectionId(0), in TEST_F() local
41 VersionNegotiationPacketBuilder builder(srcConnId, destConnId, versions); in TEST_F()
|
| H A D | QuicReadCodecTest.cpp | 82 auto srcConnId = getTestConnectionId(0), destConnId = getTestConnectionId(1); in TEST_F() local
91 VersionNegotiationPacketBuilder builder(srcConnId, destConnId, versions); in TEST_F()
98 EXPECT_EQ(versionNegotiationPacket->sourceConnectionId, srcConnId); in TEST_F()
104 ConnectionId srcConnId = getTestConnectionId(70); in TEST_F() local
118 appender.writeBE<uint8_t>(srcConnId.size()); in TEST_F()
119 appender.push(srcConnId.data(), srcConnId.size()); in TEST_F()
134 EXPECT_EQ(headerOut.getSourceConnId(), srcConnId); in TEST_F()
171 auto srcConnId = getTestConnectionId(0), destConnId = getTestConnectionId(1); in TEST_F() local
173 VersionNegotiationPacketBuilder builder(srcConnId, destConnId, versions); in TEST_F()
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/common/test/ |
| H A D | TestUtils.cpp | 32 ConnectionId srcConnId, in writeQuicPacket() argument
45 srcConnId, in writeQuicPacket()
99 auto srcConnId = in createAckPacket() local
109 srcConnId, in createAckPacket()
116 srcConnId, in createAckPacket()
281 ConnectionId srcConnId, in createStreamPacket() argument
298 srcConnId, in createStreamPacket()
331 ConnectionId srcConnId, in createInitialCryptoPacket() argument
341 LongHeader::Types::Initial, srcConnId, dstConnId, packetNum, version); in createInitialCryptoPacket()
359 ConnectionId srcConnId, in createCryptoPacket() argument
[all …]
|
| H A D | TestUtils.h | 53 ConnectionId srcConnId,
77 ConnectionId srcConnId,
95 ConnectionId srcConnId,
106 ConnectionId srcConnId,
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/server/test/ |
| H A D | QuicServerTest.cpp | 201 ConnectionId& srcConnId,
207 ConnectionId& srcConnId,
368 ConnectionId& srcConnId, in testSendRetry() argument
428 ConnectionId& srcConnId, in testSendInitialWithRetryToken() argument
435 srcConnId, in testSendInitialWithRetryToken()
577 auto srcConnId = getTestConnectionId(0); in TEST_F() local
589 auto srcConnId = getTestConnectionId(0); in TEST_F() local
1005 srcConnId); in TEST_F()
1308 ConnectionId srcConnId, in createInitialStream() argument
1318 srcConnId, in createInitialStream()
[all …]
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/codec/ |
| H A D | Types.cpp | 19 : version(ver), srcConnId(std::move(scid)), dstConnId(std::move(dcid)) {} in LongHeaderInvariant()
174 const ConnectionId& srcConnId, in LongHeader() argument
180 invariant_(LongHeaderInvariant(version, srcConnId, dstConnId)), in LongHeader()
190 return invariant_.srcConnId; in getSourceConnId()
|
| H A D | Decode.cpp | 878 longHeaderInvariant.invariant.srcConnId, in decodeVersionNegotiation()
940 ConnectionId srcConnId(cursor, srcConnIdLen); in parseLongHeaderInvariant() local
945 LongHeaderInvariant(version, std::move(srcConnId), std::move(destConnId)), in parseLongHeaderInvariant()
|
| H A D | Types.h | 715 ConnectionId srcConnId; member
755 const ConnectionId& srcConnId,
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/server/ |
| H A D | QuicServerTransport.cpp | 209 const ConnectionId& srcConnId = *conn_->serverConnectionId; in writeData() local
238 srcConnId, in writeData()
251 srcConnId, in writeData()
286 srcConnId /* src */, in writeData()
316 srcConnId /* src */, in writeData()
337 srcConnId /* src */, in writeData()
354 srcConnId, in writeData()
|
| H A D | QuicServerWorker.cpp | 203 invariant.srcConnId, in maybeSendVersionNegotiationPacketOrDrop()
221 invariant.dstConnId, invariant.srcConnId, supportedVersions_); in maybeSendVersionNegotiationPacketOrDrop()
436 std::move(parsedLongHeader->invariant.srcConnId)); in handleNetworkData()
944 const ConnectionId& srcConnId) { in sendRetryPacket() argument
965 srcConnId, /* dst conn id */ in sendRetryPacket()
977 srcConnId, /* dst conn id */ in sendRetryPacket()
|
| H A D | QuicServerWorker.h | 501 const ConnectionId& srcConnId);
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/client/ |
| H A D | QuicClientTransport.cpp | 68 auto srcConnId = connectionIdSize > 0 in QuicClientTransport() local
71 conn_->clientConnectionId = srcConnId; in QuicClientTransport()
73 conn_->readCodec->setClientConnectionId(srcConnId); in QuicClientTransport()
74 conn_->selfConnectionIds.emplace_back(srcConnId, kInitialSequenceNumber); in QuicClientTransport()
788 const ConnectionId& srcConnId = *conn_->clientConnectionId; in writeData() local
820 srcConnId, in writeData()
833 srcConnId, in writeData()
869 srcConnId /* src */, in writeData()
899 srcConnId /* src */, in writeData()
917 srcConnId /* src */, in writeData()
[all …]
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/api/test/ |
| H A D | QuicPacketSchedulerTest.cpp | 75 ConnectionId srcConnId(zeroConnIdData); in addInitialOutstandingPacket() local
78 srcConnId, in addInitialOutstandingPacket()
94 ConnectionId srcConnId(zeroConnIdData); in addHandshakeOutstandingPacket() local
97 srcConnId, in addHandshakeOutstandingPacket()
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/server/state/ |
| H A D | ServerStateMachine.cpp | 672 const auto& clientConnectionId = parsedLongHeader->invariant.srcConnId; in onServerReadDataFromOpen()
|
| /dports/net/mvfst/mvfst-248b2dc39bbd36863bbaa50385e8683428610009/quic/fizz/client/test/ |
| H A D | QuicClientTransportTest.cpp | 4864 ConnectionId srcConnId, in getHandshakePacketWithFrame() argument
4871 srcConnId, in getHandshakePacketWithFrame()
|