| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/http2/adapter/ |
| H A D | recording_http2_visitor.cc | 21 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 …]
|
| H A D | event_forwarder.cc | 17 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 …]
|
| H A D | oghttp2_session.cc | 111 uint32_t stream_id() { return stream_id_; } in stream_id() function in http2::adapter::__anond62579530111::FrameAttributeCollector
388 void OgHttp2Session::SetStreamUserData(Http2StreamId stream_id, in SetStreamUserData()
396 void* OgHttp2Session::GetStreamUserData(Http2StreamId stream_id) { in GetStreamUserData()
408 bool OgHttp2Session::ResumeStream(Http2StreamId stream_id) { in ResumeStream()
526 int OgHttp2Session::Consume(Http2StreamId stream_id, size_t num_bytes) { in Consume()
617 const Http2StreamId stream_id = GetNextReadyStream(); in Send() local
646 const Http2StreamId stream_id = *trailers_ready_.begin(); in GetNextReadyStream() local
659 const Http2StreamId stream_id = next_stream_id_; in SubmitRequestInternal() local
676 Http2StreamId stream_id, absl::Span<const Header> headers, in SubmitResponseInternal()
780 bool OgHttp2Session::AfterFrameSent(uint8_t frame_type_int, uint32_t stream_id, in AfterFrameSent()
[all …]
|
| H A D | nghttp2_adapter.cc | 29 Http2StreamId stream_id, in NotifyingMetadataSource()
97 void NgHttp2Adapter::SubmitPriorityForStream(Http2StreamId stream_id, in SubmitPriorityForStream()
127 void NgHttp2Adapter::SubmitWindowUpdate(Http2StreamId stream_id, in SubmitWindowUpdate()
133 void NgHttp2Adapter::SubmitMetadata(Http2StreamId stream_id, in SubmitMetadata()
204 void NgHttp2Adapter::MarkDataConsumedForStream(Http2StreamId stream_id, in MarkDataConsumedForStream()
213 void NgHttp2Adapter::SubmitRst(Http2StreamId stream_id, in SubmitRst()
231 int32_t stream_id = in SubmitRequest() local
242 Http2StreamId stream_id, absl::Span<const Header> headers, in SubmitResponse()
257 int NgHttp2Adapter::SubmitTrailer(Http2StreamId stream_id, in SubmitTrailer()
267 void NgHttp2Adapter::SetStreamUserData(Http2StreamId stream_id, in SetStreamUserData()
[all …]
|
| H A D | callback_visitor.cc | 114 bool CallbackVisitor::OnFrameHeader(Http2StreamId stream_id, size_t length, in OnFrameHeader()
190 bool CallbackVisitor::OnBeginHeadersForStream(Http2StreamId stream_id) { in OnBeginHeadersForStream()
226 Http2StreamId stream_id, absl::string_view name, absl::string_view value) { in OnHeaderForStream()
247 bool CallbackVisitor::OnEndHeadersForStream(Http2StreamId stream_id) { in OnEndHeadersForStream()
284 bool CallbackVisitor::OnDataForStream(Http2StreamId stream_id, in OnDataForStream()
306 bool CallbackVisitor::OnEndStream(Http2StreamId stream_id) { in OnEndStream()
321 void CallbackVisitor::OnRstStream(Http2StreamId stream_id, in OnRstStream()
333 bool CallbackVisitor::OnCloseStream(Http2StreamId stream_id, in OnCloseStream()
400 void CallbackVisitor::OnWindowUpdate(Http2StreamId stream_id, in OnWindowUpdate()
413 Http2StreamId stream_id, size_t length, in PopulateFrame()
[all …]
|
| H A D | oghttp2_adapter.cc | 44 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()
|
| H A D | test_frame_sequence.cc | 35 TestFrameSequence& TestFrameSequence::Data(Http2StreamId stream_id, in Data()
47 TestFrameSequence& TestFrameSequence::RstStream(Http2StreamId stream_id, in RstStream()
72 Http2StreamId stream_id, Http2StreamId promised_stream_id, in PushPromise()
100 Http2StreamId stream_id, in Headers()
106 TestFrameSequence& TestFrameSequence::Headers(Http2StreamId stream_id, in Headers()
136 TestFrameSequence& TestFrameSequence::Headers(Http2StreamId stream_id, in Headers()
142 TestFrameSequence& TestFrameSequence::WindowUpdate(Http2StreamId stream_id, in WindowUpdate()
149 TestFrameSequence& TestFrameSequence::Priority(Http2StreamId stream_id, in Priority()
157 TestFrameSequence& TestFrameSequence::Metadata(Http2StreamId stream_id, in Metadata()
|
| /aosp_15_r20/external/cronet/net/spdy/ |
| H A D | buffered_spdy_framer.cc | 55 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 …]
|
| H A D | spdy_test_util_common.cc | 193 void OnStreamError(spdy::SpdyStreamId stream_id, in OnStreamError()
195 void OnHeaders(spdy::SpdyStreamId stream_id, in OnHeaders()
207 void OnDataFrameHeader(spdy::SpdyStreamId stream_id, in OnDataFrameHeader()
210 void OnStreamFrameData(spdy::SpdyStreamId stream_id, in OnStreamFrameData()
213 void OnStreamEnd(spdy::SpdyStreamId stream_id) override {} in OnStreamEnd()
214 void OnStreamPadding(spdy::SpdyStreamId stream_id, size_t len) override {} in OnStreamPadding()
220 void OnRstStream(spdy::SpdyStreamId stream_id, in OnRstStream()
225 void OnWindowUpdate(spdy::SpdyStreamId stream_id, in OnWindowUpdate()
227 void OnPushPromise(spdy::SpdyStreamId stream_id, in OnPushPromise()
230 void OnAltSvc(spdy::SpdyStreamId stream_id, in OnAltSvc()
[all …]
|
| H A D | spdy_session.cc | 132 const spdy::SpdyStreamId stream_id = stream_ ? stream_->stream_id() : 0; in ProduceBuffer() local
179 spdy::SpdyStreamId stream_id, in NetLogSpdyHeadersSentParams()
206 spdy::SpdyStreamId stream_id, in NetLogSpdyHeadersReceivedParams()
266 spdy::SpdyStreamId stream_id, in NetLogSpdyWindowUpdateFrameParams()
280 base::Value::Dict NetLogSpdyDataParams(spdy::SpdyStreamId stream_id, in NetLogSpdyDataParams()
290 spdy::SpdyStreamId stream_id, in NetLogSpdyRecvRstStreamParams()
299 spdy::SpdyStreamId stream_id, in NetLogSpdySendRstStreamParams()
343 base::Value::Dict NetLogSpdyPriorityParams(spdy::SpdyStreamId stream_id, in NetLogSpdyPriorityParams()
354 base::Value::Dict NetLogSpdyGreasedFrameParams(spdy::SpdyStreamId stream_id, in NetLogSpdyGreasedFrameParams()
1045 spdy::SpdyStreamId stream_id, in CreateHeaders()
[all …]
|
| H A D | buffered_spdy_framer_unittest.cc | 33 void OnStreamError(spdy::SpdyStreamId stream_id, in OnStreamError()
40 void OnHeaders(spdy::SpdyStreamId stream_id, in OnHeaders()
53 void OnDataFrameHeader(spdy::SpdyStreamId stream_id, in OnDataFrameHeader()
59 void OnStreamFrameData(spdy::SpdyStreamId stream_id, in OnStreamFrameData()
65 void OnStreamEnd(spdy::SpdyStreamId stream_id) override { in OnStreamEnd()
69 void OnStreamPadding(spdy::SpdyStreamId stream_id, size_t len) override { in OnStreamPadding()
85 void OnRstStream(spdy::SpdyStreamId stream_id, in OnRstStream()
104 void OnWindowUpdate(spdy::SpdyStreamId stream_id, in OnWindowUpdate()
107 void OnPushPromise(spdy::SpdyStreamId stream_id, in OnPushPromise()
116 void OnAltSvc(spdy::SpdyStreamId stream_id, in OnAltSvc()
[all …]
|
| /aosp_15_r20/external/cronet/net/test/embedded_test_server/ |
| H A D | http2_connection.cc | 54 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 …]
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/http2/core/ |
| H A D | http2_trace_logging.cc | 143 void Http2TraceLogger::OnCommonHeader(SpdyStreamId stream_id, size_t length, in OnCommonHeader()
152 void Http2TraceLogger::OnDataFrameHeader(SpdyStreamId stream_id, size_t length, in OnDataFrameHeader()
160 void Http2TraceLogger::OnStreamFrameData(SpdyStreamId stream_id, in OnStreamFrameData()
168 void Http2TraceLogger::OnStreamEnd(SpdyStreamId stream_id) { in OnStreamEnd()
174 void Http2TraceLogger::OnStreamPadLength(SpdyStreamId stream_id, size_t value) { in OnStreamPadLength()
181 void Http2TraceLogger::OnStreamPadding(SpdyStreamId stream_id, size_t len) { in OnStreamPadding()
189 SpdyStreamId stream_id) { in OnHeaderFrameStart()
205 void Http2TraceLogger::OnHeaderFrameEnd(SpdyStreamId stream_id) { in OnHeaderFrameEnd()
214 void Http2TraceLogger::OnRstStream(SpdyStreamId stream_id, in OnRstStream()
263 void Http2TraceLogger::OnHeaders(SpdyStreamId stream_id, size_t payload_length, in OnHeaders()
[all …]
|
| H A D | priority_write_scheduler.h | 70 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 …]
|
| /aosp_15_r20/external/cronet/net/quic/ |
| H A D | quic_http3_logger.cc | 87 void QuicHttp3Logger::OnControlStreamCreated(quic::QuicStreamId stream_id) { in OnControlStreamCreated()
97 quic::QuicStreamId stream_id) { in OnQpackEncoderStreamCreated()
107 quic::QuicStreamId stream_id) { in OnQpackDecoderStreamCreated()
116 void QuicHttp3Logger::OnPeerControlStreamCreated(quic::QuicStreamId stream_id) { in OnPeerControlStreamCreated()
125 quic::QuicStreamId stream_id) { in OnPeerQpackEncoderStreamCreated()
134 quic::QuicStreamId stream_id) { in OnPeerQpackDecoderStreamCreated()
198 void QuicHttp3Logger::OnDataFrameReceived(quic::QuicStreamId stream_id, in OnDataFrameReceived()
211 quic::QuicStreamId stream_id, in OnHeadersFrameReceived()
224 void QuicHttp3Logger::OnHeadersDecoded(quic::QuicStreamId stream_id, in OnHeadersDecoded()
241 quic::QuicStreamId stream_id, in OnUnknownFrameReceived()
[all …]
|
| H A D | quic_test_packet_maker.cc | 279 quic::QuicStreamId stream_id, in MakeRstPacket()
287 quic::QuicStreamId stream_id, in MakeRstPacket()
389 quic::QuicStreamId stream_id, in MakeAckAndRstPacket()
401 quic::QuicStreamId stream_id, in MakeAckAndRstPacket()
423 quic::QuicStreamId stream_id, in MakeRstAckAndConnectionClosePacket()
443 quic::QuicStreamId stream_id, in MakeRstAckAndDataPacket()
461 quic::QuicStreamId stream_id, in MakeAckDataAndRst()
482 quic::QuicStreamId stream_id, in MakeAckRstAndDataPacket()
540 quic::QuicStreamId stream_id, in MakeRstAndConnectionClosePacket()
625 quic::QuicStreamId stream_id, in MakeStopSendingPacket()
[all …]
|
| /aosp_15_r20/hardware/google/camera/common/hal/utils/ |
| D | internal_stream_manager.cc | 76 int32_t InternalStreamManager::GetBufferManagerOwnerIdLocked(int32_t stream_id) { in GetBufferManagerOwnerIdLocked()
91 int32_t* stream_id) { in RegisterNewInternalStream()
156 int32_t stream_id = hal_stream.id; in AllocateBuffersLocked() local
222 int32_t stream_id = hal_streams[i].id; in CanHalStreamsShareBuffersLocked() local
350 void InternalStreamManager::FreeStream(int32_t stream_id) { in FreeStream()
377 status_t InternalStreamManager::GetStreamBuffer(int32_t stream_id, in GetStreamBuffer()
414 bool InternalStreamManager::IsPendingBufferEmpty(int32_t stream_id) { in IsPendingBufferEmpty()
433 int32_t stream_id, std::vector<StreamBuffer>* input_buffers, in GetMostRecentStreamBuffer()
497 int32_t stream_id) { in ReturnZslStreamBuffers()
529 int32_t stream_id = buffer.stream_id; in ReturnStreamBuffer() local
[all …]
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/ |
| H A D | quic_spdy_session.cc | 350 void OnHeaders(SpdyStreamId stream_id, size_t /*payload_length*/, in OnHeaders() argument
404 void OnPriority(SpdyStreamId stream_id, SpdyStreamId /* parent_id */, in OnPriority() argument
612 QuicStreamId stream_id, const spdy::SpdyStreamPrecedence& precedence) { in OnStreamHeadersPriority()
621 void QuicSpdySession::OnStreamHeaderList(QuicStreamId stream_id, bool fin, in OnStreamHeaderList()
660 QuicStreamId stream_id, const spdy::SpdyStreamPrecedence& precedence) { in OnPriorityFrame()
671 QuicStreamId stream_id, HttpStreamPriority priority) { in OnPriorityUpdateForRequestStream()
744 size_t QuicSpdySession::WritePriority(QuicStreamId stream_id, in WritePriority()
755 void QuicSpdySession::WriteHttp3PriorityUpdate(QuicStreamId stream_id, in WriteHttp3PriorityUpdate()
786 QuicStreamId stream_id = static_cast<QuicStreamId>(id); in OnHttp3GoAway() local
845 QuicStreamId stream_id = in SendHttp3GoAway() local
[all …]
|
| H A D | quic_spdy_session_test.cc | 338 QuicStream* GetOrCreateStream(QuicStreamId stream_id) { in GetOrCreateStream()
603 QuicStreamId stream_id) { in ReceiveWebTransportUnidirectionalStream()
749 QuicStreamId stream_id = StreamCountToId( in TEST_P() local
779 QuicStreamId stream_id = GetNthClientInitiatedBidirectionalId(0); in TEST_P() local
817 QuicStreamId stream_id = GetNthClientInitiatedBidirectionalId(0); in TEST_P() local
1212 QuicStreamId stream_id = StreamCountToId( in TEST_P() local
1546 QuicStreamId stream_id = 5; in TEST_P() local
1859 QuicStreamId stream_id = QuicUtils::GetFirstUnidirectionalStreamId( in TEST_P() local
1924 QuicStreamId stream_id = stream->id(); in TEST_P() local
2026 QuicStreamId stream_id = in TEST_P() local
[all …]
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/qpack/fuzzer/ |
| H A D | qpack_round_trip_fuzzer.cc | 72 std::string EncodeHeaderList(QuicStreamId stream_id, in EncodeHeaderList()
124 void SendEncodedHeaderBlock(QuicStreamId stream_id, in SendEncodedHeaderBlock()
144 const QuicStreamId stream_id = it->first; in MaybeTransmitSomeData() local
183 const QuicStreamId stream_id = it->first; in Flush() local
263 VerifyingDecoder(QuicStreamId stream_id, Visitor* visitor, in VerifyingDecoder()
337 void AddExpectedHeaderList(QuicStreamId stream_id, in AddExpectedHeaderList()
348 void OnHeaderBlockDecoded(QuicStreamId stream_id) override { in OnHeaderBlockDecoded()
354 bool IsDecodingInProgressOnStream(QuicStreamId stream_id) override { in IsDecodingInProgressOnStream()
358 void OnHeaderBlockStart(QuicStreamId stream_id) override { in OnHeaderBlockStart()
378 void OnHeaderBlockFragment(QuicStreamId stream_id, in OnHeaderBlockFragment()
[all …]
|
| /aosp_15_r20/hardware/google/camera/common/hal/google_camera_hal/ |
| D | pending_requests_tracker.cc | 96 int32_t stream_id = OverrideStreamIdForGroup(buffer.stream_id); in TrackRequestBuffersLocked() local
120 int32_t stream_id = OverrideStreamIdForGroup(buffer.stream_id); in TrackReturnedResultBuffers() local
159 int32_t stream_id = OverrideStreamIdForGroup(buffer.stream_id); in TrackReturnedAcquiredBuffers() local
205 int32_t stream_id = OverrideStreamIdForGroup(buffer.stream_id); in DoStreamsHaveEnoughBuffersLocked() local
229 int32_t stream_id, uint32_t num_buffers) const { in DoesStreamHaveEnoughBuffersToAcquireLocked()
254 int32_t stream_id = OverrideStreamIdForGroup(buffer.stream_id); in UpdateRequestedStreamIdsLocked() local
321 int32_t stream_id, uint32_t num_buffers) { in WaitAndTrackAcquiredBuffers()
354 void PendingRequestsTracker::TrackBufferAcquisitionFailure(int32_t stream_id, in TrackBufferAcquisitionFailure()
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| H A D | quic_session.cc | 192 QuicStreamId stream_id = frame.stream_id; in PendingStreamOnStreamFrame() local
221 QuicStreamId stream_id = pending->id(); in MaybeProcessPendingStream() local
276 QuicStreamId stream_id = frame.stream_id; in OnStreamFrame() local
316 QuicStreamId stream_id = frame.stream_id; in OnStopSendingFrame() local
388 QuicStreamId stream_id = frame.stream_id; in PendingStreamOnRstStream() local
406 QuicStreamId stream_id = frame.stream_id; in OnRstStream() local
556 QuicStreamId stream_id = frame.stream_id; in OnWindowUpdateFrame() local
1052 void QuicSession::OnStreamClosed(QuicStreamId stream_id) { in OnStreamClosed()
1123 void QuicSession::ClosePendingStream(QuicStreamId stream_id) { in ClosePendingStream()
1140 QuicStreamId stream_id, QuicStreamOffset final_byte_offset) { in OnFinalByteOffsetReceived()
[all …]
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/common/ |
| H A D | btree_scheduler.h | 165 absl::Status BTreeScheduler<Id, Priority>::Register(Id stream_id, in Register()
191 absl::Status BTreeScheduler<Id, Priority>::Unregister(Id stream_id) { in Unregister()
212 Id stream_id, const Priority& new_priority) { in UpdatePriority()
241 Id stream_id) const { in ShouldYield()
273 absl::Status BTreeScheduler<Id, Priority>::Schedule(Id stream_id) { in Schedule()
293 bool BTreeScheduler<Id, Priority>::IsScheduled(Id stream_id) const { in IsScheduled()
|
| /aosp_15_r20/external/grpc-grpc/src/core/ext/transport/chaotic_good/ |
| H A D | server_transport.cc | 75 uint32_t stream_id) { in PushFragmentIntoCall()
107 ClientFragmentFrame frame, uint32_t stream_id) { in MaybePushFragmentIntoCall()
156 uint32_t stream_id, MpscSender<ServerFrame> outgoing_frames, in SendCallBody()
184 uint32_t stream_id, MpscSender<ServerFrame> outgoing_frames, in SendCallInitialMetadataAndBody()
212 uint32_t stream_id, CallInitiator call_initiator) { in CallOutboundLoop()
425 uint32_t stream_id) { in LookupStream()
433 uint32_t stream_id) { in ExtractStream()
443 uint32_t stream_id, CallInitiator call_initiator) { in NewStream()
|
| /aosp_15_r20/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| H A D | frame.h | 56 uint32_t stream_id = 0; member
68 uint32_t stream_id = 0; member
82 uint32_t stream_id = 0; member
94 uint32_t stream_id = 0; member
147 uint32_t stream_id; member
181 uint32_t stream_id; member
|