| /external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_stream_send_buffer.h | 30 BufferedSlice(quiche::QuicheMemSlice mem_slice, QuicStreamOffset offset);
44 QuicStreamOffset offset;
48 constexpr StreamPendingRetransmission(QuicStreamOffset offset, in StreamPendingRetransmission()
53 QuicStreamOffset offset;
84 bool WriteStreamData(QuicStreamOffset offset, QuicByteCount data_length,
90 bool OnStreamDataAcked(QuicStreamOffset offset, QuicByteCount data_length,
94 void OnStreamDataLost(QuicStreamOffset offset, QuicByteCount data_length);
97 void OnStreamDataRetransmitted(QuicStreamOffset offset,
108 bool IsStreamDataOutstanding(QuicStreamOffset offset,
114 QuicStreamOffset stream_offset() const { return stream_offset_; } in stream_offset()
[all …]
|
| D | quic_flow_controller.h | 42 QuicStreamOffset send_window_offset,
43 QuicStreamOffset receive_window_offset,
58 bool UpdateHighestReceivedOffset(QuicStreamOffset new_offset);
71 bool UpdateSendWindowOffset(QuicStreamOffset new_send_window_offset);
97 QuicStreamOffset send_window_offset() const { return send_window_offset_; } in send_window_offset()
99 QuicStreamOffset highest_received_byte_offset() const { in highest_received_byte_offset()
109 void UpdateReceiveWindowSize(QuicStreamOffset size);
124 QuicStreamOffset available_window);
155 QuicStreamOffset send_window_offset_;
183 QuicStreamOffset highest_received_byte_offset_;
[all …]
|
| D | quic_stream_sequencer_buffer.h | 109 QuicErrorCode OnStreamData(QuicStreamOffset offset, absl::string_view data,
136 bool PeekRegion(QuicStreamOffset offset, iovec* iov) const;
154 QuicStreamOffset BytesConsumed() const;
163 QuicStreamOffset FirstMissingByte() const;
166 QuicStreamOffset NextExpectedByte() const;
176 bool CopyStreamData(QuicStreamOffset offset, absl::string_view data,
198 size_t GetBlockIndex(QuicStreamOffset offset) const;
202 size_t GetInBlockOffset(QuicStreamOffset offset) const;
212 void MaybeAddMoreBlocks(QuicStreamOffset next_expected_byte);
225 QuicStreamOffset total_bytes_read_;
[all …]
|
| D | quic_stream_send_buffer.cc | 23 bool operator()(const BufferedSlice& slice, QuicStreamOffset offset) const { in operator ()()
31 QuicStreamOffset offset) in BufferedSlice()
88 const QuicStreamOffset end = stream_offset_ + length; in SaveMemSlice()
115 bool QuicStreamSendBuffer::WriteStreamData(QuicStreamOffset offset, in WriteStreamData()
141 const QuicStreamOffset new_end = in WriteStreamData()
149 QuicStreamOffset offset, QuicByteCount data_length, in OnStreamDataAcked()
157 QuicInterval<QuicStreamOffset>(offset, offset + data_length))) { in OnStreamDataAcked()
177 QuicIntervalSet<QuicStreamOffset> newly_acked(offset, offset + data_length); in OnStreamDataAcked()
198 void QuicStreamSendBuffer::OnStreamDataLost(QuicStreamOffset offset, in OnStreamDataLost()
203 QuicIntervalSet<QuicStreamOffset> bytes_lost(offset, offset + data_length); in OnStreamDataLost()
[all …]
|
| D | quic_stream.h | 107 bool MaybeIncreaseHighestReceivedOffset(QuicStreamOffset new_offset);
259 QuicStreamOffset highest_received_byte_offset() const;
260 void UpdateReceiveWindowSize(QuicStreamOffset size);
265 bool MaybeIncreaseHighestReceivedOffset(QuicStreamOffset new_offset);
271 bool MaybeConfigSendWindowOffset(QuicStreamOffset new_offset,
319 bool WriteStreamData(QuicStreamOffset offset, QuicByteCount data_length,
325 virtual bool OnStreamFrameAcked(QuicStreamOffset offset,
333 virtual void OnStreamFrameRetransmitted(QuicStreamOffset offset,
339 virtual void OnStreamFrameLost(QuicStreamOffset offset,
345 virtual bool RetransmitStreamData(QuicStreamOffset offset,
[all …]
|
| D | quic_stream_sequencer.h | 92 bool PeekRegion(QuicStreamOffset offset, iovec* iov) const;
140 QuicStreamOffset NumBytesConsumed() const;
146 QuicStreamOffset close_offset() const { return close_offset_; } in close_offset()
177 bool CloseStreamAtOffset(QuicStreamOffset offset);
184 void OnFrameData(QuicStreamOffset byte_offset, size_t data_len,
194 QuicStreamOffset highest_offset_;
198 QuicStreamOffset close_offset_;
|
| D | quic_stream_sequencer_buffer.cc | 80 QuicStreamOffset next_expected_byte) { in MaybeAddMoreBlocks()
84 QuicStreamOffset last_byte = next_expected_byte - 1; in MaybeAddMoreBlocks()
110 QuicStreamOffset starting_offset, absl::string_view data, in OnStreamData()
127 bytes_received_.IsDisjoint(QuicInterval<QuicStreamOffset>( in OnStreamData()
149 QuicIntervalSet<QuicStreamOffset> newly_received(starting_offset, in OnStreamData()
164 const QuicStreamOffset copy_offset = interval.min(); in OnStreamData()
178 bool QuicStreamSequencerBuffer::CopyStreamData(QuicStreamOffset offset, in CopyStreamData()
320 QuicStreamOffset readable_offset_end = FirstMissingByte() - 1; in GetReadableRegions()
370 bool QuicStreamSequencerBuffer::PeekRegion(QuicStreamOffset offset, in PeekRegion()
447 QuicStreamOffset QuicStreamSequencerBuffer::BytesConsumed() const { in BytesConsumed()
[all …]
|
| D | quic_flow_controller.cc | 33 QuicStreamOffset send_window_offset, QuicStreamOffset receive_window_offset, in QuicFlowController()
76 QuicStreamOffset new_offset) { in UpdateHighestReceivedOffset()
200 QuicStreamOffset available_window = receive_window_offset_ - bytes_consumed_; in MaybeSendWindowUpdate()
221 QuicStreamOffset available_window) { in UpdateReceiveWindowOffsetAndSendWindowUpdate()
254 QuicStreamOffset new_send_window_offset) { in UpdateSendWindowOffset()
278 QuicStreamOffset available_window = receive_window_offset_ - bytes_consumed_; in EnsureWindowAtLeast()
292 void QuicFlowController::UpdateReceiveWindowSize(QuicStreamOffset size) { in UpdateReceiveWindowSize()
|
| D | quic_packet_creator.h | 150 QuicStreamOffset offset);
157 QuicStreamOffset offset, bool fin,
166 QuicStreamOffset offset,
174 bool HasRoomForStreamFrame(QuicStreamId id, QuicStreamOffset offset,
191 QuicStreamOffset iov_offset,
192 QuicStreamOffset stream_offset, bool fin,
359 QuicStreamOffset offset,
368 QuicStreamOffset offset, bool fin,
376 QuicStreamOffset offset);
513 QuicStreamOffset offset, bool fin, QuicFrame* frame);
[all …]
|
| D | quic_stream_sequencer.cc | 34 close_offset_(std::numeric_limits<QuicStreamOffset>::max()), in QuicStreamSequencer()
52 const QuicStreamOffset byte_offset = frame.offset; in OnStreamFrame()
76 void QuicStreamSequencer::OnFrameData(QuicStreamOffset byte_offset, in OnFrameData()
129 bool QuicStreamSequencer::CloseStreamAtOffset(QuicStreamOffset offset) { in CloseStreamAtOffset()
130 const QuicStreamOffset kMaxOffset = in CloseStreamAtOffset()
131 std::numeric_limits<QuicStreamOffset>::max(); in CloseStreamAtOffset()
191 bool QuicStreamSequencer::PeekRegion(QuicStreamOffset offset, in PeekRegion()
291 QuicStreamOffset QuicStreamSequencer::NumBytesConsumed() const { in NumBytesConsumed()
|
| D | quic_session.h | 195 QuicStreamOffset offset,
198 bool WriteCryptoData(EncryptionLevel level, QuicStreamOffset offset,
284 virtual void SendBlocked(QuicStreamId id, QuicStreamOffset byte_offset);
287 virtual void SendWindowUpdate(QuicStreamId id, QuicStreamOffset byte_offset);
350 QuicStreamOffset offset, StreamSendingState state,
355 QuicStreamOffset offset,
600 QuicStreamOffset bytes_written);
714 QuicStreamOffset final_byte_offset);
761 QuicStreamOffset offset);
844 void OnNewStreamFlowControlWindow(QuicStreamOffset new_window);
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | quic_stream_peer.h | 27 static void SetStreamBytesWritten(QuicStreamOffset stream_bytes_written,
29 static void SetSendWindowOffset(QuicStream* stream, QuicStreamOffset offset);
31 QuicStreamOffset offset);
32 static void SetMaxReceiveWindow(QuicStream* stream, QuicStreamOffset size);
38 static QuicStreamOffset SendWindowOffset(QuicStream* stream);
39 static QuicStreamOffset ReceiveWindowOffset(QuicStream* stream);
|
| D | simple_session_notifier.h | 37 QuicStreamOffset bytes_written);
40 void WriteOrBufferWindowUpate(QuicStreamId id, QuicStreamOffset byte_offset);
51 QuicStreamOffset offset);
102 QuicIntervalSet<QuicStreamOffset> bytes_acked;
104 QuicIntervalSet<QuicStreamOffset> pending_retransmissions;
116 void OnStreamDataConsumed(QuicStreamId id, QuicStreamOffset offset,
155 QuicIntervalSet<QuicStreamOffset>
|
| D | simple_session_notifier.cc | 52 QuicStreamOffset offset = stream_state.bytes_sent; in WriteOrBufferData()
72 QuicStreamOffset offset, in OnStreamDataConsumed()
88 QuicStreamOffset offset) { in WriteCryptoData()
99 QuicStreamOffset bytes_written) { in WriteOrBufferRstStream()
117 QuicStreamId id, QuicStreamOffset byte_offset) { in WriteOrBufferWindowUpate()
268 QuicStreamOffset offset = frame.crypto_frame->offset; in OnFrameAcked()
270 QuicIntervalSet<QuicStreamOffset> newly_acked(offset, offset + data_length); in OnFrameAcked()
286 QuicStreamOffset offset = frame.stream_frame.offset; in OnFrameAcked()
288 QuicIntervalSet<QuicStreamOffset> newly_acked(offset, offset + data_length); in OnFrameAcked()
307 QuicStreamOffset offset = frame.crypto_frame->offset; in OnFrameLost()
[all …]
|
| D | quic_stream_peer.cc | 24 QuicStreamOffset stream_bytes_written, QuicStream* stream) { in SetStreamBytesWritten()
33 QuicStreamOffset offset) { in SetSendWindowOffset()
45 QuicStreamOffset offset) { in SetReceiveWindowOffset()
52 QuicStreamOffset size) { in SetMaxReceiveWindow()
62 QuicStreamOffset QuicStreamPeer::ReceiveWindowOffset(QuicStream* stream) { in ReceiveWindowOffset()
73 QuicStreamOffset QuicStreamPeer::SendWindowOffset(QuicStream* stream) { in SendWindowOffset()
|
| D | quic_flow_controller_peer.h | 21 QuicStreamOffset offset);
24 QuicStreamOffset offset);
29 static QuicStreamOffset SendWindowOffset(QuicFlowController* flow_controller);
33 static QuicStreamOffset ReceiveWindowOffset(
|
| D | quic_stream_sequencer_buffer_peer.h | 36 size_t GetInBlockOffset(QuicStreamOffset offset);
46 void set_total_bytes_read(QuicStreamOffset total_bytes_read);
48 void AddBytesReceived(QuicStreamOffset offset, QuicByteCount length);
56 const QuicIntervalSet<QuicStreamOffset>& bytes_received();
|
| D | quic_flow_controller_peer.cc | 17 QuicFlowController* flow_controller, QuicStreamOffset offset) { in SetSendWindowOffset()
23 QuicFlowController* flow_controller, QuicStreamOffset offset) { in SetReceiveWindowOffset()
34 QuicStreamOffset QuicFlowControllerPeer::SendWindowOffset( in SendWindowOffset()
46 QuicStreamOffset QuicFlowControllerPeer::ReceiveWindowOffset( in ReceiveWindowOffset()
|
| D | simple_data_producer.h | 30 void SaveCryptoData(EncryptionLevel level, QuicStreamOffset offset,
35 QuicStreamOffset offset,
38 bool WriteCryptoData(EncryptionLevel level, QuicStreamOffset offset,
47 absl::flat_hash_map<std::pair<EncryptionLevel, QuicStreamOffset>,
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/http/ |
| D | quic_headers_stream.h | 41 bool OnStreamFrameAcked(QuicStreamOffset offset, QuicByteCount data_length,
46 void OnStreamFrameRetransmitted(QuicStreamOffset offset,
59 QuicStreamOffset headers_stream_offset, QuicStreamOffset full_length,
66 QuicStreamOffset headers_stream_offset;
84 QuicStreamOffset offset, QuicByteCount data_length,
|
| D | quic_headers_stream.cc | 16 QuicStreamOffset headers_stream_offset, QuicStreamOffset full_length, in CompressedHeaderInfo()
58 bool QuicHeadersStream::OnStreamFrameAcked(QuicStreamOffset offset, in OnStreamFrameAcked()
64 QuicIntervalSet<QuicStreamOffset> newly_acked(offset, offset + data_length); in OnStreamFrameAcked()
67 QuicStreamOffset acked_offset = acked.min(); in OnStreamFrameAcked()
112 void QuicHeadersStream::OnStreamFrameRetransmitted(QuicStreamOffset offset, in OnStreamFrameRetransmitted()
140 QuicStreamOffset offset, QuicByteCount data_length, in OnDataBuffered()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/tools/ |
| D | quic_tcp_like_trace_converter.cc | 20 QuicStreamOffset stream_offset, uint64_t connection_offset, in StreamOffsetSegment()
28 EncryptionLevel level, QuicStreamOffset offset, QuicByteCount data_length) { in OnCryptoFrameSent()
38 QuicStreamId stream_id, QuicStreamOffset offset, QuicByteCount data_length, in OnStreamFrameSent()
46 QuicStreamOffset offset, QuicByteCount data_length, bool fin, in OnFrameSent()
55 QuicInterval<QuicStreamOffset> retransmission(offset, offset + data_length); in OnFrameSent()
72 QuicStreamOffset least_unsent_offset = in OnFrameSent()
79 QuicStreamOffset new_data_offset = std::max(least_unsent_offset, offset); in OnFrameSent()
|
| D | quic_tcp_like_trace_converter.h | 26 StreamOffsetSegment(QuicStreamOffset stream_offset,
29 QuicInterval<QuicStreamOffset> stream_data;
42 QuicStreamOffset offset,
48 QuicStreamOffset offset,
69 QuicIntervalSet<uint64_t> OnFrameSent(QuicStreamOffset offset,
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/frames/ |
| D | quic_crypto_frame.h | 19 QuicCryptoFrame(EncryptionLevel level, QuicStreamOffset offset,
21 QuicCryptoFrame(EncryptionLevel level, QuicStreamOffset offset,
38 QuicStreamOffset offset = 0; // Location of this data in the stream.
40 QuicCryptoFrame(EncryptionLevel level, QuicStreamOffset offset,
|
| D | quic_stream_frame.h | 21 QuicStreamFrame(QuicStreamId stream_id, bool fin, QuicStreamOffset offset,
23 QuicStreamFrame(QuicStreamId stream_id, bool fin, QuicStreamOffset offset,
40 QuicStreamOffset offset = 0; // Location of this data in the stream.
42 QuicStreamFrame(QuicStreamId stream_id, bool fin, QuicStreamOffset offset,
|