Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(85)

Side by Side Diff: net/quic/quic_spdy_session.h

Issue 2193073003: Move shared files in net/quic/ into net/quic/core/ (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: io_thread_unittest.cc Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « net/quic/quic_socket_address_coder_test.cc ('k') | net/quic/quic_spdy_session.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
(Empty)
1 // Copyright (c) 2015 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #ifndef NET_QUIC_QUIC_SPDY_SESSION_H_
6 #define NET_QUIC_QUIC_SPDY_SESSION_H_
7
8 #include <stddef.h>
9
10 #include <memory>
11
12 #include "base/macros.h"
13 #include "net/quic/quic_header_list.h"
14 #include "net/quic/quic_headers_stream.h"
15 #include "net/quic/quic_session.h"
16 #include "net/quic/quic_spdy_stream.h"
17
18 namespace net {
19
20 namespace test {
21 class QuicSpdySessionPeer;
22 } // namespace test
23
24 // A QUIC session with a headers stream.
25 class NET_EXPORT_PRIVATE QuicSpdySession : public QuicSession {
26 public:
27 QuicSpdySession(QuicConnection* connection, const QuicConfig& config);
28
29 ~QuicSpdySession() override;
30
31 void Initialize() override;
32
33 // Called by |headers_stream_| when headers have been received for a stream.
34 virtual void OnStreamHeaders(QuicStreamId stream_id,
35 base::StringPiece headers_data);
36 // Called by |headers_stream_| when headers with a priority have been
37 // received for this stream. This method will only be called for server
38 // streams.
39 virtual void OnStreamHeadersPriority(QuicStreamId stream_id,
40 SpdyPriority priority);
41 // Called by |headers_stream_| when headers have been completely received
42 // for a stream. |fin| will be true if the fin flag was set in the headers
43 // frame.
44 virtual void OnStreamHeadersComplete(QuicStreamId stream_id,
45 bool fin,
46 size_t frame_len);
47
48 // Called by |headers_stream_| when headers have been completely received
49 // for a stream. |fin| will be true if the fin flag was set in the headers
50 // frame.
51 virtual void OnStreamHeaderList(QuicStreamId stream_id,
52 bool fin,
53 size_t frame_len,
54 const QuicHeaderList& header_list);
55
56 // Called by |headers_stream_| when push promise headers have been
57 // received for a stream.
58 virtual void OnPromiseHeaders(QuicStreamId stream_id,
59 base::StringPiece headers_data);
60
61 // Called by |headers_stream_| when push promise headers have been
62 // completely received. |fin| will be true if the fin flag was set
63 // in the headers.
64 virtual void OnPromiseHeadersComplete(QuicStreamId stream_id,
65 QuicStreamId promised_stream_id,
66 size_t frame_len);
67
68 // Called by |headers_stream_| when push promise headers have been
69 // completely received. |fin| will be true if the fin flag was set
70 // in the headers.
71 virtual void OnPromiseHeaderList(QuicStreamId stream_id,
72 QuicStreamId promised_stream_id,
73 size_t frame_len,
74 const QuicHeaderList& header_list);
75
76 // Writes |headers| for the stream |id| to the dedicated headers stream.
77 // If |fin| is true, then no more data will be sent for the stream |id|.
78 // If provided, |ack_notifier_delegate| will be registered to be notified when
79 // we have seen ACKs for all packets resulting from this call.
80 virtual size_t WriteHeaders(QuicStreamId id,
81 SpdyHeaderBlock headers,
82 bool fin,
83 SpdyPriority priority,
84 QuicAckListenerInterface* ack_notifier_delegate);
85
86 QuicHeadersStream* headers_stream() { return headers_stream_.get(); }
87
88 // Called when Head of Line Blocking happens in the headers stream.
89 // |delta| indicates how long that piece of data has been blocked.
90 virtual void OnHeadersHeadOfLineBlocking(QuicTime::Delta delta);
91
92 // Called by the stream on creation to set priority in the write blocked list.
93 void RegisterStreamPriority(QuicStreamId id, SpdyPriority priority);
94 // Called by the stream on deletion to clear priority crom the write blocked
95 // list.
96 void UnregisterStreamPriority(QuicStreamId id);
97 // Called by the stream on SetPriority to update priority on the write blocked
98 // list.
99 void UpdateStreamPriority(QuicStreamId id, SpdyPriority new_priority);
100
101 void OnConfigNegotiated() override;
102
103 // Called by |headers_stream_| when |force_hol_blocking_| is true.
104 virtual void OnStreamFrameData(QuicStreamId stream_id,
105 const char* data,
106 size_t len,
107 bool fin);
108
109 bool force_hol_blocking() const { return force_hol_blocking_; }
110
111 protected:
112 // Override CreateIncomingDynamicStream() and CreateOutgoingDynamicStream()
113 // with QuicSpdyStream return type to make sure that all data streams are
114 // QuicSpdyStreams.
115 QuicSpdyStream* CreateIncomingDynamicStream(QuicStreamId id) override = 0;
116 QuicSpdyStream* CreateOutgoingDynamicStream(SpdyPriority priority) override =
117 0;
118
119 QuicSpdyStream* GetSpdyDataStream(const QuicStreamId stream_id);
120
121 // If an incoming stream can be created, return true.
122 virtual bool ShouldCreateIncomingDynamicStream(QuicStreamId id) = 0;
123
124 // If an outgoing stream can be created, return true.
125 virtual bool ShouldCreateOutgoingDynamicStream() = 0;
126
127 private:
128 friend class test::QuicSpdySessionPeer;
129
130 std::unique_ptr<QuicHeadersStream> headers_stream_;
131
132 // If set, redirect all data through the headers stream in order to
133 // simulate forced HOL blocking between streams as happens in
134 // HTTP/2 over TCP.
135 bool force_hol_blocking_;
136
137 DISALLOW_COPY_AND_ASSIGN(QuicSpdySession);
138 };
139
140 } // namespace net
141
142 #endif // NET_QUIC_QUIC_SPDY_SESSION_H_
OLDNEW
« no previous file with comments | « net/quic/quic_socket_address_coder_test.cc ('k') | net/quic/quic_spdy_session.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698