/dports/www/trafficserver/trafficserver-9.1.1/iocore/net/quic/test/ |
H A D | test_QUICFrameRetransmitter.cc | 118 CHECK(stream_frame->offset() == 0x67890); 153 CHECK(stream_frame->offset() == 0x67890); 154 CHECK(stream_frame->size() <= 25); 156 auto size = stream_frame->data_length(); 157 CHECK(memcmp(stream_frame->data()->start(), data, stream_frame->data_length()) == 0); 175 CHECK(memcmp(stream_frame->data()->start(), data + size, stream_frame->data_length()) == 0); 265 CHECK(stream_frame->offset() == 0x67890); 266 CHECK(stream_frame->size() <= 25); 269 auto size = stream_frame->data_length(); 270 CHECK(memcmp(stream_frame->data()->start(), data, stream_frame->data_length()) == 0); [all …]
|
H A D | test_QUICStreamState.cc | 60 ss.update_with_sending_frame(*stream_frame); 124 ss.update_with_sending_frame(*stream_frame); 150 ss.update_with_sending_frame(*stream_frame); 212 ss.update_with_receiving_frame(*stream_frame); 245 ss.update_with_receiving_frame(*stream_frame); 265 ss.update_with_receiving_frame(*stream_frame); 287 ss.update_with_receiving_frame(*stream_frame); 316 ss.update_with_receiving_frame(*stream_frame); 426 ss.update_with_sending_frame(*stream_frame); 449 ss.update_with_sending_frame(*stream_frame); [all …]
|
H A D | test_QUICFrame.cc | 94 CHECK(stream_frame->offset() == 0x00); 113 CHECK(stream_frame->offset() == 0x00); 134 CHECK(stream_frame->offset() == 0x02); 207 CHECK(stream_frame.size() == 8); 236 CHECK(stream_frame.size() == 9); 265 CHECK(stream_frame.size() == 12); 294 CHECK(stream_frame.size() == 16); 323 CHECK(stream_frame.size() == 17); 352 CHECK(stream_frame.size() == 19); 381 CHECK(stream_frame.size() == 19); [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/test_tools/ |
H A D | simple_session_notifier.cc | 139 QuicStreamFrame stream_frame( in NeuterUnencryptedData() local 241 QuicStreamOffset offset = frame.stream_frame.offset; in OnFrameAcked() 242 QuicByteCount data_length = frame.stream_frame.data_length; in OnFrameAcked() 282 QuicStreamOffset offset = frame.stream_frame.offset; in OnFrameLost() 283 QuicByteCount data_length = frame.stream_frame.data_length; in OnFrameLost() 337 frame.stream_frame.offset, in RetransmitFrames() 338 frame.stream_frame.offset + frame.stream_frame.data_length); in RetransmitFrames() 367 frame.stream_frame.stream_id, retransmission_length, in RetransmitFrames() 414 QuicStreamOffset offset = frame.stream_frame.offset; in IsFrameOutstanding() 415 QuicByteCount data_length = frame.stream_frame.data_length; in IsFrameOutstanding() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/quic/test_tools/ |
H A D | simple_session_notifier.cc | 139 QuicStreamFrame stream_frame( in NeuterUnencryptedData() local 241 QuicStreamOffset offset = frame.stream_frame.offset; in OnFrameAcked() 242 QuicByteCount data_length = frame.stream_frame.data_length; in OnFrameAcked() 282 QuicStreamOffset offset = frame.stream_frame.offset; in OnFrameLost() 283 QuicByteCount data_length = frame.stream_frame.data_length; in OnFrameLost() 338 frame.stream_frame.offset, in RetransmitFrames() 339 frame.stream_frame.offset + frame.stream_frame.data_length); in RetransmitFrames() 368 frame.stream_frame.stream_id, retransmission_length, in RetransmitFrames() 415 QuicStreamOffset offset = frame.stream_frame.offset; in IsFrameOutstanding() 416 QuicByteCount data_length = frame.stream_frame.data_length; in IsFrameOutstanding() [all …]
|
/dports/www/trafficserver/trafficserver-9.1.1/iocore/net/quic/ |
H A D | QUICIncomingFrameBuffer.cc | 91 const QUICStreamFrame *stream_frame = static_cast<const QUICStreamFrame *>(frame); in insert() local 93 QUICOffset offset = stream_frame->offset(); in insert() 94 size_t len = stream_frame->data_length(); in insert() 96 …QUICConnectionErrorUPtr err = this->_check_and_set_fin_flag(offset, len, stream_frame->has_fin_fla… in insert() 103 if (len == 0 && !stream_frame->has_fin_flag()) { in insert() 114 this->_recv_buffer.push(stream_frame); in insert() 116 auto result = this->_out_of_order_queue.insert(std::make_pair(offset, stream_frame)); in insert() 119 delete stream_frame; in insert()
|
H A D | QUICBidirectionalStream.cc | 196 const QUICStreamFrame *stream_frame = nullptr; in recv() local 201 stream_frame = static_cast<const QUICStreamFrame *>(new_frame); in recv() 202 last_offset = stream_frame->offset(); in recv() 203 last_length = stream_frame->data_length(); in recv() 205 …this->_write_to_read_vio(stream_frame->offset(), reinterpret_cast<uint8_t *>(stream_frame->data()-… in recv() 206 stream_frame->data_length(), stream_frame->has_fin_flag()); in recv() 214 if (stream_frame) { in recv()
|
H A D | QUICFrameRetransmitter.cc | 122 QUICStreamFrame *stream_frame = static_cast<QUICStreamFrame *>(frame); in _create_stream_frame() local 123 IOBufferBlock *block = stream_frame->data(); in _create_stream_frame() 124 size_t over_length = stream_frame->data_length() - maximum_data_size; in _create_stream_frame() 131 stream_info->block->consume(stream_frame->data_length()); in _create_stream_frame() 132 stream_info->offset += stream_frame->data_length(); in _create_stream_frame()
|
H A D | QUICUnidirectionalStream.cc | 625 const QUICStreamFrame *stream_frame = nullptr; in recv() local 630 stream_frame = static_cast<const QUICStreamFrame *>(new_frame); in recv() 631 last_offset = stream_frame->offset(); in recv() 632 last_length = stream_frame->data_length(); in recv() 634 …this->_write_to_read_vio(stream_frame->offset(), reinterpret_cast<uint8_t *>(stream_frame->data()-… in recv() 635 stream_frame->data_length(), stream_frame->has_fin_flag()); in recv() 643 if (stream_frame) { in recv()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/core/frames/ |
H A D | quic_stream_frame.cc | 40 const QuicStreamFrame& stream_frame) { in operator <<() argument 41 os << "{ stream_id: " << stream_frame.stream_id in operator <<() 42 << ", fin: " << stream_frame.fin << ", offset: " << stream_frame.offset in operator <<() 43 << ", length: " << stream_frame.data_length << " }\n"; in operator <<()
|
H A D | quic_crypto_frame.cc | 37 const QuicCryptoFrame& stream_frame) { in operator <<() argument 38 os << "{ level: " << static_cast<int>(stream_frame.level) in operator <<() 39 << ", offset: " << stream_frame.offset in operator <<() 40 << ", length: " << stream_frame.data_length << " }\n"; in operator <<()
|
H A D | quic_frame.cc | 19 QuicFrame::QuicFrame(QuicStreamFrame stream_frame) in QuicFrame() argument 20 : stream_frame(stream_frame) {} in QuicFrame() 148 if (it->type != STREAM_FRAME || it->stream_frame.stream_id != stream_id) { in RemoveFramesForStream() 305 copy = QuicFrame(QuicStreamFrame(frame.stream_frame)); in CopyQuicFrame() 400 os << "type { STREAM_FRAME } " << frame.stream_frame; in operator <<()
|
H A D | quic_frame.h | 48 explicit QuicFrame(QuicStreamFrame stream_frame); 80 QuicStreamFrame stream_frame; member
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/quic/core/frames/ |
H A D | quic_stream_frame.cc | 39 const QuicStreamFrame& stream_frame) { in operator <<() argument 40 os << "{ stream_id: " << stream_frame.stream_id in operator <<() 41 << ", fin: " << stream_frame.fin << ", offset: " << stream_frame.offset in operator <<() 42 << ", length: " << stream_frame.data_length << " }\n"; in operator <<()
|
H A D | quic_crypto_frame.cc | 34 const QuicCryptoFrame& stream_frame) { in operator <<() argument 35 os << "{ level: " << stream_frame.level << ", offset: " << stream_frame.offset in operator <<() 36 << ", length: " << stream_frame.data_length << " }\n"; in operator <<()
|
H A D | quic_frame.cc | 20 QuicFrame::QuicFrame(QuicStreamFrame stream_frame) in QuicFrame() argument 21 : stream_frame(stream_frame) {} in QuicFrame() 164 if (it->type != STREAM_FRAME || it->stream_frame.stream_id != stream_id) { in RemoveFramesForStream() 330 copy = QuicFrame(QuicStreamFrame(frame.stream_frame)); in CopyQuicFrame() 428 os << "type { STREAM_FRAME } " << frame.stream_frame; in operator <<()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/modules/peerconnection/adapters/ |
H A D | p2p_quic_stream_unittest.cc | 350 quic::QuicStreamFrame stream_frame(stream_->id(), /*fin=*/false, 0, in TEST_F() local 356 stream_->OnStreamFrame(stream_frame); in TEST_F() 363 quic::QuicStreamFrame stream_frame(stream_->id(), /*fin=*/false, 0, in TEST_F() local 367 stream_->OnStreamFrame(stream_frame); in TEST_F() 389 stream_->OnStreamFrame(stream_frame); in TEST_F() 416 stream_->OnStreamFrame(stream_frame); in TEST_F() 445 stream_->OnStreamFrame(stream_frame); in TEST_F() 477 quic::QuicStreamFrame stream_frame(stream_->id(), /*fin=*/true, 0, in TEST_F() local 485 stream_->OnStreamFrame(stream_frame); in TEST_F() 551 stream_->OnStreamFrame(stream_frame); in TEST_F() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/core/ |
H A D | quic_unacked_packet_map.cc | 374 frame.stream_frame.stream_id == aggregated_stream_frame_.stream_id && in MaybeAggregateAckedStreamFrame() 375 frame.stream_frame.offset == aggregated_stream_frame_.offset + in MaybeAggregateAckedStreamFrame() 382 frame.stream_frame.data_length); in MaybeAggregateAckedStreamFrame() 386 aggregated_stream_frame_.data_length += frame.stream_frame.data_length; in MaybeAggregateAckedStreamFrame() 387 aggregated_stream_frame_.fin = frame.stream_frame.fin; in MaybeAggregateAckedStreamFrame() 397 if (frame.type != STREAM_FRAME || frame.stream_frame.fin) { in MaybeAggregateAckedStreamFrame() 404 aggregated_stream_frame_.stream_id = frame.stream_frame.stream_id; in MaybeAggregateAckedStreamFrame() 405 aggregated_stream_frame_.offset = frame.stream_frame.offset; in MaybeAggregateAckedStreamFrame() 406 aggregated_stream_frame_.data_length = frame.stream_frame.data_length; in MaybeAggregateAckedStreamFrame() 407 aggregated_stream_frame_.fin = frame.stream_frame.fin; in MaybeAggregateAckedStreamFrame()
|
H A D | quic_packet_creator_test.cc | 1335 QuicStreamFrame stream_frame( in TEST_P() local 1373 QuicStreamFrame stream_frame( in TEST_P() local 1938 QuicStreamFrame stream_frame( in TEST_P() local 2910 const QuicStreamFrame& stream_frame = in TEST_F() local 2912 EXPECT_EQ(10000u, stream_frame.data_length + stream_frame.offset); in TEST_F() 2939 const QuicStreamFrame& stream_frame = in TEST_F() local 2941 EXPECT_EQ(10000u, stream_frame.data_length + stream_frame.offset); in TEST_F() 2982 const QuicStreamFrame& stream_frame = in TEST_F() local 2984 EXPECT_EQ(10000u, stream_frame.data_length + stream_frame.offset); in TEST_F() 3011 const QuicStreamFrame& stream_frame = in TEST_F() local [all …]
|
H A D | quic_session.cc | 1917 QuicStream* stream = GetStream(frame.stream_frame.stream_id); in OnFrameAcked() 1922 frame.stream_frame.offset, frame.stream_frame.data_length, in OnFrameAcked() 1959 QuicStream* stream = GetStream(frame.stream_frame.stream_id); in OnFrameLost() 1963 stream->OnStreamFrameLost(frame.stream_frame.offset, in OnFrameLost() 1964 frame.stream_frame.data_length, in OnFrameLost() 1965 frame.stream_frame.fin); in OnFrameLost() 1968 frame.stream_frame.stream_id)) { in OnFrameLost() 1970 std::make_pair(frame.stream_frame.stream_id, true)); in OnFrameLost() 1995 QuicStream* stream = GetStream(frame.stream_frame.stream_id); in RetransmitFrames() 1997 !stream->RetransmitStreamData(frame.stream_frame.offset, in RetransmitFrames() [all …]
|
H A D | quic_trace_visitor.cc | 118 info->set_stream_id(frame.stream_frame.stream_id); in PopulateFrameInfo() 119 info->set_fin(frame.stream_frame.fin); in PopulateFrameInfo() 120 info->set_offset(frame.stream_frame.offset); in PopulateFrameInfo() 121 info->set_length(frame.stream_frame.data_length); in PopulateFrameInfo()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/quic/core/ |
H A D | quic_unacked_packet_map.cc | 493 frame.stream_frame.stream_id == aggregated_stream_frame_.stream_id && in MaybeAggregateAckedStreamFrame() 494 frame.stream_frame.offset == aggregated_stream_frame_.offset + in MaybeAggregateAckedStreamFrame() 501 frame.stream_frame.data_length); in MaybeAggregateAckedStreamFrame() 505 aggregated_stream_frame_.data_length += frame.stream_frame.data_length; in MaybeAggregateAckedStreamFrame() 506 aggregated_stream_frame_.fin = frame.stream_frame.fin; in MaybeAggregateAckedStreamFrame() 516 if (frame.type != STREAM_FRAME || frame.stream_frame.fin) { in MaybeAggregateAckedStreamFrame() 523 aggregated_stream_frame_.stream_id = frame.stream_frame.stream_id; in MaybeAggregateAckedStreamFrame() 524 aggregated_stream_frame_.offset = frame.stream_frame.offset; in MaybeAggregateAckedStreamFrame() 525 aggregated_stream_frame_.data_length = frame.stream_frame.data_length; in MaybeAggregateAckedStreamFrame() 526 aggregated_stream_frame_.fin = frame.stream_frame.fin; in MaybeAggregateAckedStreamFrame()
|
H A D | quic_packet_creator_test.cc | 1274 QuicStreamFrame stream_frame( in TEST_P() local 1311 QuicStreamFrame stream_frame( in TEST_P() local 1954 QuicStreamFrame stream_frame( in TEST_P() local 2966 const QuicStreamFrame& stream_frame = in TEST_F() local 2968 EXPECT_EQ(10000u, stream_frame.data_length + stream_frame.offset); in TEST_F() 2995 const QuicStreamFrame& stream_frame = in TEST_F() local 2997 EXPECT_EQ(10000u, stream_frame.data_length + stream_frame.offset); in TEST_F() 3038 const QuicStreamFrame& stream_frame = in TEST_F() local 3040 EXPECT_EQ(10000u, stream_frame.data_length + stream_frame.offset); in TEST_F() 3067 const QuicStreamFrame& stream_frame = in TEST_F() local [all …]
|
H A D | quic_session.cc | 2156 QuicStream* stream = GetStream(frame.stream_frame.stream_id); in OnFrameAcked() 2161 frame.stream_frame.offset, frame.stream_frame.data_length, in OnFrameAcked() 2198 QuicStream* stream = GetStream(frame.stream_frame.stream_id); in OnFrameLost() 2202 stream->OnStreamFrameLost(frame.stream_frame.offset, in OnFrameLost() 2203 frame.stream_frame.data_length, in OnFrameLost() 2204 frame.stream_frame.fin); in OnFrameLost() 2207 frame.stream_frame.stream_id)) { in OnFrameLost() 2209 std::make_pair(frame.stream_frame.stream_id, true)); in OnFrameLost() 2231 QuicStream* stream = GetStream(frame.stream_frame.stream_id); in RetransmitFrames() 2233 !stream->RetransmitStreamData(frame.stream_frame.offset, in RetransmitFrames() [all …]
|
H A D | quic_trace_visitor.cc | 188 info->set_stream_id(frame.stream_frame.stream_id); in PopulateFrameInfo() 189 info->set_fin(frame.stream_frame.fin); in PopulateFrameInfo() 190 info->set_offset(frame.stream_frame.offset); in PopulateFrameInfo() 191 info->set_length(frame.stream_frame.data_length); in PopulateFrameInfo()
|