Home
last modified time | relevance | path

Searched refs:stream_frame (Results 1 – 25 of 56) sorted by relevance

123

/dports/www/trafficserver/trafficserver-9.1.1/iocore/net/quic/test/
H A Dtest_QUICFrameRetransmitter.cc118 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 Dtest_QUICStreamState.cc60 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 Dtest_QUICFrame.cc94 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 Dsimple_session_notifier.cc139 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 Dsimple_session_notifier.cc139 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 DQUICIncomingFrameBuffer.cc91 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 DQUICBidirectionalStream.cc196 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 DQUICFrameRetransmitter.cc122 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 DQUICUnidirectionalStream.cc625 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 Dquic_stream_frame.cc40 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 Dquic_crypto_frame.cc37 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 Dquic_frame.cc19 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 Dquic_frame.h48 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 Dquic_stream_frame.cc39 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 Dquic_crypto_frame.cc34 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 Dquic_frame.cc20 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 Dp2p_quic_stream_unittest.cc350 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 Dquic_unacked_packet_map.cc374 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 Dquic_packet_creator_test.cc1335 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 Dquic_session.cc1917 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 Dquic_trace_visitor.cc118 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 Dquic_unacked_packet_map.cc493 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 Dquic_packet_creator_test.cc1274 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 Dquic_session.cc2156 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 Dquic_trace_visitor.cc188 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()

123