| /external/cronet/net/third_party/quiche/src/quiche/quic/core/http/ |
| D | quic_spdy_stream.cc | 48 class QuicSpdyStream::HttpDecoderVisitor : public HttpDecoder::Visitor {
50 explicit HttpDecoderVisitor(QuicSpdyStream* stream) : stream_(stream) {} in HttpDecoderVisitor()
160 QuicSpdyStream* stream_;
178 QuicSpdyStream::QuicSpdyStream(QuicStreamId id, QuicSpdySession* spdy_session, in QuicSpdyStream() function in quic::QuicSpdyStream
215 QuicSpdyStream::QuicSpdyStream(PendingStream* pending, in QuicSpdyStream() function in quic::QuicSpdyStream
250 QuicSpdyStream::~QuicSpdyStream() {} in ~QuicSpdyStream()
252 size_t QuicSpdyStream::WriteHeaders( in WriteHeaders()
306 void QuicSpdyStream::WriteOrBufferBody(absl::string_view data, bool fin) { in WriteOrBufferBody()
331 size_t QuicSpdyStream::WriteTrailers( in WriteTrailers()
373 QuicConsumedData QuicSpdyStream::WritevBody(const struct iovec* iov, int count, in WritevBody()
[all …]
|
| D | quic_spdy_server_stream_base.cc | 20 : QuicSpdyStream(id, session, type) {} in QuicSpdyServerStreamBase()
24 : QuicSpdyStream(pending, session) {} in QuicSpdyServerStreamBase()
37 QuicSpdyStream::CloseWriteSide(); in CloseWriteSide()
48 QuicSpdyStream::StopReading(); in StopReading()
57 if (!QuicSpdyStream::AreHeadersValid(header_list)) { in AreHeadersValid()
|
| D | quic_spdy_stream.h | 55 class QUIC_EXPORT_PRIVATE QuicSpdyStream
68 virtual void OnClose(QuicSpdyStream* stream) = 0;
78 QuicSpdyStream(QuicStreamId id, QuicSpdySession* spdy_session,
80 QuicSpdyStream(PendingStream* pending, QuicSpdySession* spdy_session);
81 QuicSpdyStream(const QuicSpdyStream&) = delete;
82 QuicSpdyStream& operator=(const QuicSpdyStream&) = delete;
83 ~QuicSpdyStream() override;
378 WebTransportDataStream(QuicSpdyStream* stream,
|
| D | quic_server_initiated_spdy_stream.h | 17 : public QuicSpdyStream {
19 using QuicSpdyStream::QuicSpdyStream;
|
| D | quic_spdy_client_stream.cc | 26 : QuicSpdyStream(id, session, type), in QuicSpdyClientStream()
36 : QuicSpdyStream(pending, session), in QuicSpdyClientStream()
91 QuicSpdyStream::OnInitialHeadersComplete(fin, frame_len, header_list); in OnInitialHeadersComplete()
135 QuicSpdyStream::OnTrailingHeadersComplete(fin, frame_len, header_list); in OnTrailingHeadersComplete()
211 if (!QuicSpdyStream::AreHeadersValid(header_list)) { in AreHeadersValid()
|
| D | web_transport_http3.h | 27 class QuicSpdyStream; variable
44 public QuicSpdyStream::Http3DatagramVisitor {
46 WebTransportHttp3(QuicSpdySession* session, QuicSpdyStream* connect_stream,
109 QuicSpdyStream* const connect_stream_; // Unowned.
|
| D | quic_spdy_client_session.cc | 177 QuicSpdyStream* QuicSpdyClientSession::CreateIncomingStream( in CreateIncomingStream()
179 QuicSpdyStream* stream = new QuicSpdyClientStream(pending, this); in CreateIncomingStream()
184 QuicSpdyStream* QuicSpdyClientSession::CreateIncomingStream(QuicStreamId id) { in CreateIncomingStream()
188 QuicSpdyStream* stream; in CreateIncomingStream()
|
| D | quic_spdy_session.h | 368 void OnStreamCreated(QuicSpdyStream* stream);
452 QuicSpdyStream* CreateOutgoingBidirectionalWebTransportStream(
455 QuicSpdyStream* GetOrCreateSpdyDataStream(const QuicStreamId stream_id);
466 QuicSpdyStream* CreateIncomingStream(QuicStreamId id) override = 0;
467 QuicSpdyStream* CreateIncomingStream(PendingStream* pending) override = 0;
468 virtual QuicSpdyStream* CreateOutgoingBidirectionalStream() = 0;
469 virtual QuicSpdyStream* CreateOutgoingUnidirectionalStream() = 0;
|
| D | web_transport_http3.cc | 45 QuicSpdyStream* connect_stream, in WebTransportHttp3()
166 if (!QuicSpdyStream::ParseHeaderStatusCode(headers, &status_code)) { in HeadersReceived()
216 QuicSpdyStream* stream = session_->GetOrCreateSpdyDataStream(id); in AcceptIncomingBidirectionalStream()
250 QuicSpdyStream* stream = in OpenOutgoingBidirectionalStream()
279 return static_cast<QuicSpdyStream*>(stream)->web_transport_stream(); in GetStreamById()
|
| D | quic_spdy_client_stream.h | 23 class QUIC_EXPORT_PRIVATE QuicSpdyClientStream : public QuicSpdyStream {
71 using QuicSpdyStream::SetPriority;
|
| D | quic_spdy_client_session.h | 96 QuicSpdyStream* CreateIncomingStream(QuicStreamId id) override;
97 QuicSpdyStream* CreateIncomingStream(PendingStream* pending) override;
|
| D | quic_server_session_base_test.cc | 78 QuicSpdyStream* CreateIncomingStream(QuicStreamId id) override { in CreateIncomingStream()
82 QuicSpdyStream* stream = new QuicSimpleServerStream( in CreateIncomingStream()
88 QuicSpdyStream* CreateIncomingStream(PendingStream* pending) override { in CreateIncomingStream()
89 QuicSpdyStream* stream = in CreateIncomingStream()
95 QuicSpdyStream* CreateOutgoingBidirectionalStream() override { in CreateOutgoingBidirectionalStream()
100 QuicSpdyStream* CreateOutgoingUnidirectionalStream() override { in CreateOutgoingUnidirectionalStream()
105 QuicSpdyStream* stream = new QuicSimpleServerStream( in CreateOutgoingUnidirectionalStream()
|
| D | quic_spdy_client_session_base.cc | 96 QuicSpdyStream* stream = GetOrCreateSpdyDataStream(stream_id); in OnPromiseHeaderList()
177 QuicSpdyStream* QuicSpdyClientSessionBase::GetPromisedStream( in GetPromisedStream()
181 return static_cast<QuicSpdyStream*>(stream); in GetPromisedStream()
|
| D | quic_spdy_session.cc | 566 QuicSpdyStream* stream = GetOrCreateSpdyDataStream(stream_id); in OnStreamHeadersPriority()
583 QuicSpdyStream* stream = GetOrCreateSpdyDataStream(stream_id); in OnStreamHeaderList()
614 QuicSpdyStream* stream = GetOrCreateSpdyDataStream(stream_id); in OnPriorityFrame()
839 void QuicSpdySession::OnStreamCreated(QuicSpdyStream* stream) { in OnStreamCreated()
849 QuicSpdyStream* QuicSpdySession::GetOrCreateSpdyDataStream( in GetOrCreateSpdyDataStream()
863 return static_cast<QuicSpdyStream*>(stream); in GetOrCreateSpdyDataStream()
1008 QuicSpdyStream* stream = GetOrCreateSpdyDataStream(stream_id); in OnSettingsFrame()
1667 QuicSpdyStream* stream = in OnMessageReceived()
1668 static_cast<QuicSpdyStream*>(GetActiveStream(stream_id)); in OnMessageReceived()
1698 QuicSpdyStream* connect_stream = GetOrCreateSpdyDataStream(id); in GetWebTransportSession()
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/masque/ |
| D | masque_server_session.h | 60 : public QuicSpdyStream::Http3DatagramVisitor {
65 QuicSpdyStream* stream, const QuicSocketAddress& target_server_address,
76 QuicSpdyStream* stream() const { return stream_; } in stream()
89 QuicSpdyStream* stream_;
97 : public QuicSpdyStream::Http3DatagramVisitor,
98 public QuicSpdyStream::ConnectIpVisitor {
103 QuicSpdyStream* stream, QuicUdpSocketFd fd,
114 QuicSpdyStream* stream() const { return stream_; } in stream()
134 QuicSpdyStream* stream_;
|
| D | masque_client_session.h | 130 : public QuicSpdyStream::Http3DatagramVisitor {
171 : public QuicSpdyStream::Http3DatagramVisitor,
172 public QuicSpdyStream::ConnectIpVisitor {
|
| D | masque_server_session.cc | 201 QuicSpdyStream* stream = static_cast<QuicSpdyStream*>( in HandleMasqueRequest()
298 QuicSpdyStream* stream = in HandleMasqueRequest()
299 static_cast<QuicSpdyStream*>(GetActiveStream(request_handler->stream_id())); in HandleMasqueRequest()
441 QuicSpdyStream* stream, const QuicSocketAddress& target_server_address, in ConnectUdpServerState()
521 QuicIpAddress client_ip, QuicSpdyStream* stream, QuicUdpSocketFd fd, in ConnectIpServerState()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | quic_spdy_stream_peer.h | 14 class QuicSpdyStream; variable
21 QuicSpdyStream* stream,
25 QuicSpdyStream* stream);
26 static bool OnHeadersFrameEnd(QuicSpdyStream* stream);
|
| D | quic_spdy_stream_peer.cc | 15 QuicSpdyStream* stream, in set_ack_listener()
23 QuicSpdyStreamPeer::unacked_frame_headers_offsets(QuicSpdyStream* stream) { in unacked_frame_headers_offsets()
28 bool QuicSpdyStreamPeer::OnHeadersFrameEnd(QuicSpdyStream* stream) { in OnHeadersFrameEnd()
|
| D | quic_test_utils.h | 790 MOCK_METHOD(QuicSpdyStream*, CreateIncomingStream, (PendingStream*),
932 MOCK_METHOD(QuicSpdyStream*, CreateIncomingStream, (QuicStreamId id),
934 MOCK_METHOD(QuicSpdyStream*, CreateIncomingStream, (PendingStream*),
936 MOCK_METHOD(QuicSpdyStream*, CreateOutgoingBidirectionalStream, (),
938 MOCK_METHOD(QuicSpdyStream*, CreateOutgoingUnidirectionalStream, (),
1046 MOCK_METHOD(QuicSpdyStream*, CreateIncomingStream, (QuicStreamId id),
1048 MOCK_METHOD(QuicSpdyStream*, CreateIncomingStream, (PendingStream*),
1050 MOCK_METHOD(QuicSpdyStream*, CreateOutgoingBidirectionalStream, (),
1052 MOCK_METHOD(QuicSpdyStream*, CreateOutgoingUnidirectionalStream, (),
1105 void OnRendezvousResult(QuicSpdyStream* stream) override;
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/tools/ |
| D | quic_simple_server_session.cc | 56 QuicSpdyStream* QuicSimpleServerSession::CreateIncomingStream(QuicStreamId id) { in CreateIncomingStream()
61 QuicSpdyStream* stream = new QuicSimpleServerStream( in CreateIncomingStream()
67 QuicSpdyStream* QuicSimpleServerSession::CreateIncomingStream( in CreateIncomingStream()
69 QuicSpdyStream* stream = in CreateIncomingStream()
75 QuicSpdyStream* QuicSimpleServerSession::CreateOutgoingBidirectionalStream() { in CreateOutgoingBidirectionalStream()
|
| D | quic_simple_server_session.h | 55 QuicSpdyStream* CreateIncomingStream(QuicStreamId id) override;
56 QuicSpdyStream* CreateIncomingStream(PendingStream* pending) override;
57 QuicSpdyStream* CreateOutgoingBidirectionalStream() override;
|
| D | quic_spdy_client_base.h | 31 public QuicSpdyStream::Visitor {
80 void OnClose(QuicSpdyStream* stream) override;
113 void OnRendezvousResult(QuicSpdyStream*) override;
|
| /external/cronet/net/websockets/ |
| D | websocket_quic_spdy_stream.cc | 16 : quic::QuicSpdyStream(id, session, type) {} in WebSocketQuicSpdyStream()
34 QuicSpdyStream::OnInitialHeadersComplete(fin, frame_len, header_list); in OnInitialHeadersComplete()
|
| /external/cronet/net/quic/ |
| D | quic_chromium_client_stream.h | 40 : public quic::QuicSpdyStream {
265 using quic::QuicSpdyStream::SetPriority;
309 using quic::QuicSpdyStream::HasBufferedData;
|