Home
last modified time | relevance | path

Searched defs:stream_id (Results 1 – 25 of 299) sorted by relevance

12345678910>>...12

/external/cronet/net/third_party/quiche/src/quiche/http2/adapter/
Drecording_http2_visitor.cc21 bool RecordingHttp2Visitor::OnFrameHeader(Http2StreamId stream_id, in OnFrameHeader()
46 bool RecordingHttp2Visitor::OnBeginHeadersForStream(Http2StreamId stream_id) { in OnBeginHeadersForStream()
52 Http2StreamId stream_id, absl::string_view name, absl::string_view value) { in OnHeaderForStream()
58 bool RecordingHttp2Visitor::OnEndHeadersForStream(Http2StreamId stream_id) { in OnEndHeadersForStream()
63 bool RecordingHttp2Visitor::OnDataPaddingLength(Http2StreamId stream_id, in OnDataPaddingLength()
70 bool RecordingHttp2Visitor::OnBeginDataForStream(Http2StreamId stream_id, in OnBeginDataForStream()
77 bool RecordingHttp2Visitor::OnDataForStream(Http2StreamId stream_id, in OnDataForStream()
83 bool RecordingHttp2Visitor::OnEndStream(Http2StreamId stream_id) { in OnEndStream()
88 void RecordingHttp2Visitor::OnRstStream(Http2StreamId stream_id, in OnRstStream()
94 bool RecordingHttp2Visitor::OnCloseStream(Http2StreamId stream_id, in OnCloseStream()
[all …]
Devent_forwarder.cc17 void EventForwarder::OnCommonHeader(spdy::SpdyStreamId stream_id, size_t length, in OnCommonHeader()
24 void EventForwarder::OnDataFrameHeader(spdy::SpdyStreamId stream_id, in OnDataFrameHeader()
31 void EventForwarder::OnStreamFrameData(spdy::SpdyStreamId stream_id, in OnStreamFrameData()
38 void EventForwarder::OnStreamEnd(spdy::SpdyStreamId stream_id) { in OnStreamEnd()
44 void EventForwarder::OnStreamPadLength(spdy::SpdyStreamId stream_id, in OnStreamPadLength()
51 void EventForwarder::OnStreamPadding(spdy::SpdyStreamId stream_id, size_t len) { in OnStreamPadding()
58 spdy::SpdyStreamId stream_id) { in OnHeaderFrameStart()
62 void EventForwarder::OnHeaderFrameEnd(spdy::SpdyStreamId stream_id) { in OnHeaderFrameEnd()
68 void EventForwarder::OnRstStream(spdy::SpdyStreamId stream_id, in OnRstStream()
119 void EventForwarder::OnHeaders(spdy::SpdyStreamId stream_id, in OnHeaders()
[all …]
Doghttp2_adapter.cc44 void OgHttp2Adapter::SubmitPriorityForStream(Http2StreamId stream_id, in SubmitPriorityForStream()
66 void OgHttp2Adapter::SubmitWindowUpdate(Http2StreamId stream_id, in SubmitWindowUpdate()
72 void OgHttp2Adapter::SubmitMetadata(Http2StreamId stream_id, in SubmitMetadata()
122 void OgHttp2Adapter::MarkDataConsumedForStream(Http2StreamId stream_id, in MarkDataConsumedForStream()
127 void OgHttp2Adapter::SubmitRst(Http2StreamId stream_id, in SubmitRst()
140 Http2StreamId stream_id, absl::Span<const Header> headers, in SubmitResponse()
145 int OgHttp2Adapter::SubmitTrailer(Http2StreamId stream_id, in SubmitTrailer()
150 void OgHttp2Adapter::SetStreamUserData(Http2StreamId stream_id, in SetStreamUserData()
155 void* OgHttp2Adapter::GetStreamUserData(Http2StreamId stream_id) { in GetStreamUserData()
159 bool OgHttp2Adapter::ResumeStream(Http2StreamId stream_id) { in ResumeStream()
Doghttp2_session.cc108 uint32_t stream_id() { return stream_id_; } in stream_id() function in http2::adapter::__anon1df836620111::FrameAttributeCollector
383 void OgHttp2Session::SetStreamUserData(Http2StreamId stream_id, in SetStreamUserData()
391 void* OgHttp2Session::GetStreamUserData(Http2StreamId stream_id) { in GetStreamUserData()
403 bool OgHttp2Session::ResumeStream(Http2StreamId stream_id) { in ResumeStream()
523 int OgHttp2Session::Consume(Http2StreamId stream_id, size_t num_bytes) { in Consume()
614 const Http2StreamId stream_id = GetNextReadyStream(); in Send() local
643 const Http2StreamId stream_id = *trailers_ready_.begin(); in GetNextReadyStream() local
737 bool OgHttp2Session::AfterFrameSent(uint8_t frame_type_int, uint32_t stream_id, in AfterFrameSent()
784 Http2StreamId stream_id) { in WriteForStream()
908 void OgHttp2Session::SerializeMetadata(Http2StreamId stream_id, in SerializeMetadata()
[all …]
Dcallback_visitor.cc76 bool CallbackVisitor::OnFrameHeader(Http2StreamId stream_id, size_t length, in OnFrameHeader()
152 bool CallbackVisitor::OnBeginHeadersForStream(Http2StreamId stream_id) { in OnBeginHeadersForStream()
184 Http2StreamId stream_id, absl::string_view name, absl::string_view value) { in OnHeaderForStream()
205 bool CallbackVisitor::OnEndHeadersForStream(Http2StreamId stream_id) { in OnEndHeadersForStream()
243 bool CallbackVisitor::OnDataForStream(Http2StreamId stream_id, in OnDataForStream()
265 bool CallbackVisitor::OnEndStream(Http2StreamId stream_id) { in OnEndStream()
280 void CallbackVisitor::OnRstStream(Http2StreamId stream_id, in OnRstStream()
292 bool CallbackVisitor::OnCloseStream(Http2StreamId stream_id, in OnCloseStream()
359 void CallbackVisitor::OnWindowUpdate(Http2StreamId stream_id, in OnWindowUpdate()
372 Http2StreamId stream_id, size_t length, in PopulateFrame()
[all …]
Dnghttp2_adapter.cc92 void NgHttp2Adapter::SubmitPriorityForStream(Http2StreamId stream_id, in SubmitPriorityForStream()
122 void NgHttp2Adapter::SubmitWindowUpdate(Http2StreamId stream_id, in SubmitWindowUpdate()
128 void NgHttp2Adapter::SubmitMetadata(Http2StreamId stream_id, in SubmitMetadata()
194 void NgHttp2Adapter::MarkDataConsumedForStream(Http2StreamId stream_id, in MarkDataConsumedForStream()
203 void NgHttp2Adapter::SubmitRst(Http2StreamId stream_id, in SubmitRst()
221 int32_t stream_id = in SubmitRequest() local
232 Http2StreamId stream_id, absl::Span<const Header> headers, in SubmitResponse()
247 int NgHttp2Adapter::SubmitTrailer(Http2StreamId stream_id, in SubmitTrailer()
257 void NgHttp2Adapter::SetStreamUserData(Http2StreamId stream_id, in SetStreamUserData()
263 void* NgHttp2Adapter::GetStreamUserData(Http2StreamId stream_id) { in GetStreamUserData()
[all …]
Dtest_frame_sequence.cc34 TestFrameSequence& TestFrameSequence::Data(Http2StreamId stream_id, in Data()
46 TestFrameSequence& TestFrameSequence::RstStream(Http2StreamId stream_id, in RstStream()
71 Http2StreamId stream_id, Http2StreamId promised_stream_id, in PushPromise()
99 Http2StreamId stream_id, in Headers()
105 TestFrameSequence& TestFrameSequence::Headers(Http2StreamId stream_id, in Headers()
135 TestFrameSequence& TestFrameSequence::Headers(Http2StreamId stream_id, in Headers()
141 TestFrameSequence& TestFrameSequence::WindowUpdate(Http2StreamId stream_id, in WindowUpdate()
148 TestFrameSequence& TestFrameSequence::Priority(Http2StreamId stream_id, in Priority()
156 TestFrameSequence& TestFrameSequence::Metadata(Http2StreamId stream_id, in Metadata()
/external/cronet/net/spdy/
Dbuffered_spdy_framer.cc55 void BufferedSpdyFramer::OnHeaders(spdy::SpdyStreamId stream_id, in OnHeaders()
78 void BufferedSpdyFramer::OnDataFrameHeader(spdy::SpdyStreamId stream_id, in OnDataFrameHeader()
85 void BufferedSpdyFramer::OnStreamFrameData(spdy::SpdyStreamId stream_id, in OnStreamFrameData()
91 void BufferedSpdyFramer::OnStreamEnd(spdy::SpdyStreamId stream_id) { in OnStreamEnd()
95 void BufferedSpdyFramer::OnStreamPadLength(spdy::SpdyStreamId stream_id, in OnStreamPadLength()
101 void BufferedSpdyFramer::OnStreamPadding(spdy::SpdyStreamId stream_id, in OnStreamPadding()
107 spdy::SpdyStreamId stream_id) { in OnHeaderFrameStart()
113 void BufferedSpdyFramer::OnHeaderFrameEnd(spdy::SpdyStreamId stream_id) { in OnHeaderFrameEnd()
164 void BufferedSpdyFramer::OnRstStream(spdy::SpdyStreamId stream_id, in OnRstStream()
192 void BufferedSpdyFramer::OnWindowUpdate(spdy::SpdyStreamId stream_id, in OnWindowUpdate()
[all …]
Dspdy_test_util_common.cc191 void OnStreamError(spdy::SpdyStreamId stream_id, in OnStreamError()
193 void OnHeaders(spdy::SpdyStreamId stream_id, in OnHeaders()
205 void OnDataFrameHeader(spdy::SpdyStreamId stream_id, in OnDataFrameHeader()
208 void OnStreamFrameData(spdy::SpdyStreamId stream_id, in OnStreamFrameData()
211 void OnStreamEnd(spdy::SpdyStreamId stream_id) override {} in OnStreamEnd()
212 void OnStreamPadding(spdy::SpdyStreamId stream_id, size_t len) override {} in OnStreamPadding()
218 void OnRstStream(spdy::SpdyStreamId stream_id, in OnRstStream()
223 void OnWindowUpdate(spdy::SpdyStreamId stream_id, in OnWindowUpdate()
225 void OnPushPromise(spdy::SpdyStreamId stream_id, in OnPushPromise()
228 void OnAltSvc(spdy::SpdyStreamId stream_id, in OnAltSvc()
[all …]
Dbuffered_spdy_framer_unittest.cc32 void OnStreamError(spdy::SpdyStreamId stream_id, in OnStreamError()
39 void OnHeaders(spdy::SpdyStreamId stream_id, in OnHeaders()
52 void OnDataFrameHeader(spdy::SpdyStreamId stream_id, in OnDataFrameHeader()
58 void OnStreamFrameData(spdy::SpdyStreamId stream_id, in OnStreamFrameData()
64 void OnStreamEnd(spdy::SpdyStreamId stream_id) override { in OnStreamEnd()
68 void OnStreamPadding(spdy::SpdyStreamId stream_id, size_t len) override { in OnStreamPadding()
84 void OnRstStream(spdy::SpdyStreamId stream_id, in OnRstStream()
103 void OnWindowUpdate(spdy::SpdyStreamId stream_id, in OnWindowUpdate()
106 void OnPushPromise(spdy::SpdyStreamId stream_id, in OnPushPromise()
115 void OnAltSvc(spdy::SpdyStreamId stream_id, in OnAltSvc()
[all …]
Dspdy_session.cc187 const spdy::SpdyStreamId stream_id = stream_ ? stream_->stream_id() : 0; in ProduceBuffer() local
245 spdy::SpdyStreamId stream_id, in NetLogSpdyHeadersSentParams()
271 spdy::SpdyStreamId stream_id, in NetLogSpdyHeadersReceivedParams()
337 spdy::SpdyStreamId stream_id, in NetLogSpdyWindowUpdateFrameParams()
353 base::Value::Dict NetLogSpdyDataParams(spdy::SpdyStreamId stream_id, in NetLogSpdyDataParams()
364 spdy::SpdyStreamId stream_id, in NetLogSpdyRecvRstStreamParams()
374 spdy::SpdyStreamId stream_id, in NetLogSpdySendRstStreamParams()
414 spdy::SpdyStreamId stream_id, in NetLogSpdyPushPromiseReceivedParams()
425 spdy::SpdyStreamId stream_id, in NetLogSpdyAdoptedPushStreamParams()
447 base::Value::Dict NetLogSpdyPriorityParams(spdy::SpdyStreamId stream_id, in NetLogSpdyPriorityParams()
[all …]
/external/cronet/net/quic/
Dquic_http3_logger.cc90 void QuicHttp3Logger::OnControlStreamCreated(quic::QuicStreamId stream_id) { in OnControlStreamCreated()
100 quic::QuicStreamId stream_id) { in OnQpackEncoderStreamCreated()
110 quic::QuicStreamId stream_id) { in OnQpackDecoderStreamCreated()
119 void QuicHttp3Logger::OnPeerControlStreamCreated(quic::QuicStreamId stream_id) { in OnPeerControlStreamCreated()
128 quic::QuicStreamId stream_id) { in OnPeerQpackEncoderStreamCreated()
137 quic::QuicStreamId stream_id) { in OnPeerQpackDecoderStreamCreated()
207 void QuicHttp3Logger::OnDataFrameReceived(quic::QuicStreamId stream_id, in OnDataFrameReceived()
220 quic::QuicStreamId stream_id, in OnHeadersFrameReceived()
233 void QuicHttp3Logger::OnHeadersDecoded(quic::QuicStreamId stream_id, in OnHeadersDecoded()
251 quic::QuicStreamId stream_id, in OnUnknownFrameReceived()
[all …]
/external/cronet/net/third_party/quiche/src/quiche/http2/core/
Dpriority_write_scheduler.h70 void RegisterStream(StreamIdType stream_id, PriorityType priority) { in RegisterStream()
84 void UnregisterStream(StreamIdType stream_id) { in UnregisterStream()
102 bool StreamRegistered(StreamIdType stream_id) const { in StreamRegistered()
109 PriorityType GetStreamPriority(StreamIdType stream_id) const { in GetStreamPriority()
121 void UpdateStreamPriority(StreamIdType stream_id, PriorityType priority) { in UpdateStreamPriority()
157 void RecordStreamEventTime(StreamIdType stream_id, absl::Time now) { in RecordStreamEventTime()
175 StreamIdType stream_id) const { in GetLatestEventWithPriority()
228 bool ShouldYield(StreamIdType stream_id) const { in ShouldYield()
262 void MarkStreamReady(StreamIdType stream_id, bool add_to_front) { in MarkStreamReady()
287 void MarkStreamNotReady(StreamIdType stream_id) { in MarkStreamNotReady()
[all …]
Dhttp2_trace_logging.cc142 void Http2TraceLogger::OnCommonHeader(SpdyStreamId stream_id, size_t length, in OnCommonHeader()
151 void Http2TraceLogger::OnDataFrameHeader(SpdyStreamId stream_id, size_t length, in OnDataFrameHeader()
159 void Http2TraceLogger::OnStreamFrameData(SpdyStreamId stream_id, in OnStreamFrameData()
167 void Http2TraceLogger::OnStreamEnd(SpdyStreamId stream_id) { in OnStreamEnd()
173 void Http2TraceLogger::OnStreamPadLength(SpdyStreamId stream_id, size_t value) { in OnStreamPadLength()
180 void Http2TraceLogger::OnStreamPadding(SpdyStreamId stream_id, size_t len) { in OnStreamPadding()
188 SpdyStreamId stream_id) { in OnHeaderFrameStart()
204 void Http2TraceLogger::OnHeaderFrameEnd(SpdyStreamId stream_id) { in OnHeaderFrameEnd()
213 void Http2TraceLogger::OnRstStream(SpdyStreamId stream_id, in OnRstStream()
262 void Http2TraceLogger::OnHeaders(SpdyStreamId stream_id, size_t payload_length, in OnHeaders()
[all …]
/external/cronet/net/test/embedded_test_server/
Dhttp2_connection.cc54 const StreamId& stream_id) in DataFrameSource()
125 ResponseDelegate(Http2Connection* connection, StreamId stream_id) in ResponseDelegate()
264 StreamId stream_id = ready_streams_.front(); in HandleData() local
301 bool Http2Connection::OnCloseStream(StreamId stream_id, in OnCloseStream()
342 for (const auto& stream_id : blocked_streams_) in OnSendInternalDone() local
362 Http2Connection::OnHeaderForStream(http2::adapter::Http2StreamId stream_id, in OnHeaderForStream()
370 http2::adapter::Http2StreamId stream_id) { in OnEndHeadersForStream()
390 bool Http2Connection::OnEndStream(http2::adapter::Http2StreamId stream_id) { in OnEndStream()
402 bool Http2Connection::OnBeginHeadersForStream(StreamId stream_id) { in OnBeginHeadersForStream()
406 bool Http2Connection::OnBeginDataForStream(StreamId stream_id, in OnBeginDataForStream()
[all …]
Dhttp2_connection.h75 void OnRstStream(StreamId stream_id, in OnRstStream()
77 void OnPriorityForStream(StreamId stream_id, in OnPriorityForStream()
82 void OnPushPromiseForStream(StreamId stream_id, in OnPushPromiseForStream()
87 void OnWindowUpdate(StreamId stream_id, int window_increment) override {} in OnWindowUpdate()
98 void OnBeginMetadataForStream(StreamId stream_id, in OnBeginMetadataForStream()
/external/cronet/net/third_party/quiche/src/quiche/quic/core/qpack/
Dqpack_decoder.cc31 void QpackDecoder::OnStreamReset(QuicStreamId stream_id) { in OnStreamReset()
38 bool QpackDecoder::OnStreamBlocked(QuicStreamId stream_id) { in OnStreamBlocked()
44 void QpackDecoder::OnStreamUnblocked(QuicStreamId stream_id) { in OnStreamUnblocked()
49 void QpackDecoder::OnDecodingCompleted(QuicStreamId stream_id, in OnDecodingCompleted()
164 QuicStreamId stream_id, in CreateProgressiveDecoder()
Dqpack_blocking_manager.cc14 bool QpackBlockingManager::OnHeaderAcknowledgement(QuicStreamId stream_id) { in OnHeaderAcknowledgement()
40 void QpackBlockingManager::OnStreamCancellation(QuicStreamId stream_id) { in OnStreamCancellation()
63 void QpackBlockingManager::OnHeaderBlockSent(QuicStreamId stream_id, in OnHeaderBlockSent()
72 QuicStreamId stream_id, uint64_t maximum_blocked_streams) const { in blocking_allowed_on_stream()
/external/perfetto/protos/perfetto/trace/ftrace/
Dvirtio_video.proto9 optional uint32 stream_id = 1; field
13 optional uint32 stream_id = 1; field
23 optional int32 stream_id = 7; field
33 optional int32 stream_id = 7; field
/external/cronet/net/third_party/quiche/src/quiche/quic/core/
Dquic_write_blocked_list.cc77 void QuicWriteBlockedList::RegisterStream(QuicStreamId stream_id, in RegisterStream()
90 void QuicWriteBlockedList::UnregisterStream(QuicStreamId stream_id) { in UnregisterStream()
98 QuicStreamId stream_id, const QuicStreamPriority& new_priority) { in UpdateStreamPriority()
104 void QuicWriteBlockedList::UpdateBytesForStream(QuicStreamId stream_id, in UpdateBytesForStream()
119 void QuicWriteBlockedList::AddStream(QuicStreamId stream_id) { in AddStream()
/external/cronet/net/third_party/quiche/src/quiche/quic/core/qpack/fuzzer/
Dqpack_round_trip_fuzzer.cc71 std::string EncodeHeaderList(QuicStreamId stream_id, in EncodeHeaderList()
123 void SendEncodedHeaderBlock(QuicStreamId stream_id, in SendEncodedHeaderBlock()
143 const QuicStreamId stream_id = it->first; in MaybeTransmitSomeData() local
182 const QuicStreamId stream_id = it->first; in Flush() local
262 VerifyingDecoder(QuicStreamId stream_id, Visitor* visitor, in VerifyingDecoder()
334 void AddExpectedHeaderList(QuicStreamId stream_id, in AddExpectedHeaderList()
345 void OnHeaderBlockDecoded(QuicStreamId stream_id) override { in OnHeaderBlockDecoded()
351 bool IsDecodingInProgressOnStream(QuicStreamId stream_id) override { in IsDecodingInProgressOnStream()
355 void OnHeaderBlockStart(QuicStreamId stream_id) override { in OnHeaderBlockStart()
375 void OnHeaderBlockFragment(QuicStreamId stream_id, in OnHeaderBlockFragment()
[all …]
/external/cronet/net/third_party/quiche/src/quiche/common/
Dbtree_scheduler.h159 absl::Status BTreeScheduler<Id, Priority>::Register(Id stream_id, in Register()
185 absl::Status BTreeScheduler<Id, Priority>::Unregister(Id stream_id) { in Unregister()
206 Id stream_id, const Priority& new_priority) { in UpdatePriority()
235 Id stream_id) const { in ShouldYield()
267 absl::Status BTreeScheduler<Id, Priority>::Schedule(Id stream_id) { in Schedule()
287 bool BTreeScheduler<Id, Priority>::IsScheduled(Id stream_id) const { in IsScheduled()
/external/libopus/src/
Dopus_multistream.c57 int get_left_channel(const ChannelLayout *layout, int stream_id, int prev) in get_left_channel()
69 int get_right_channel(const ChannelLayout *layout, int stream_id, int prev) in get_right_channel()
81 int get_mono_channel(const ChannelLayout *layout, int stream_id, int prev) in get_mono_channel()
/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/
Dquic_spdy_session.cc321 void OnHeaders(SpdyStreamId stream_id, size_t /*payload_length*/, in OnHeaders() argument
352 void OnPushPromise(SpdyStreamId stream_id, SpdyStreamId promised_stream_id, in OnPushPromise()
369 void OnPriority(SpdyStreamId stream_id, SpdyStreamId /* parent_id */, in OnPriority() argument
565 QuicStreamId stream_id, const spdy::SpdyStreamPrecedence& precedence) { in OnStreamHeadersPriority()
574 void QuicSpdySession::OnStreamHeaderList(QuicStreamId stream_id, bool fin, in OnStreamHeaderList()
613 QuicStreamId stream_id, const spdy::SpdyStreamPrecedence& precedence) { in OnPriorityFrame()
624 QuicStreamId stream_id, HttpStreamPriority priority) { in OnPriorityUpdateForRequestStream()
697 size_t QuicSpdySession::WritePriority(QuicStreamId stream_id, in WritePriority()
708 void QuicSpdySession::WriteHttp3PriorityUpdate(QuicStreamId stream_id, in WriteHttp3PriorityUpdate()
739 QuicStreamId stream_id = static_cast<QuicStreamId>(id); in OnHttp3GoAway() local
[all …]
/external/grpc-grpc/test/http2_test/
Dhttp2_base_server.py119 def setup_send(self, data_to_send, stream_id, pad_length=None, read_chunk_size=_READ_CHUNK_SIZE): argument
126 def default_send(self, stream_id, pad_length=None, read_chunk_size=_READ_CHUNK_SIZE): argument
164 def on_send_done_default(self, stream_id): argument
171 def default_send_trailer(self, stream_id): argument
187 def parse_received_data(self, stream_id): argument

12345678910>>...12