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

Side by Side Diff: net/tools/flip_server/spdy_interface.h

Issue 623213004: replace OVERRIDE and FINAL with override and final in net/ (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: undo unwanted change in comment Created 6 years, 2 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/tools/flip_server/sm_connection.h ('k') | net/tools/flip_server/streamer_interface.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef NET_TOOLS_FLIP_SERVER_SPDY_INTERFACE_H_ 5 #ifndef NET_TOOLS_FLIP_SERVER_SPDY_INTERFACE_H_
6 #define NET_TOOLS_FLIP_SERVER_SPDY_INTERFACE_H_ 6 #define NET_TOOLS_FLIP_SERVER_SPDY_INTERFACE_H_
7 7
8 #include <map> 8 #include <map>
9 #include <string> 9 #include <string>
10 #include <vector> 10 #include <vector>
(...skipping 17 matching lines...) Expand all
28 public: 28 public:
29 SpdySM(SMConnection* connection, 29 SpdySM(SMConnection* connection,
30 SMInterface* sm_http_interface, 30 SMInterface* sm_http_interface,
31 EpollServer* epoll_server, 31 EpollServer* epoll_server,
32 MemoryCache* memory_cache, 32 MemoryCache* memory_cache,
33 FlipAcceptor* acceptor, 33 FlipAcceptor* acceptor,
34 SpdyMajorVersion spdy_version); 34 SpdyMajorVersion spdy_version);
35 virtual ~SpdySM(); 35 virtual ~SpdySM();
36 36
37 virtual void InitSMInterface(SMInterface* sm_http_interface, 37 virtual void InitSMInterface(SMInterface* sm_http_interface,
38 int32 server_idx) OVERRIDE {} 38 int32 server_idx) override {}
39 39
40 virtual void InitSMConnection(SMConnectionPoolInterface* connection_pool, 40 virtual void InitSMConnection(SMConnectionPoolInterface* connection_pool,
41 SMInterface* sm_interface, 41 SMInterface* sm_interface,
42 EpollServer* epoll_server, 42 EpollServer* epoll_server,
43 int fd, 43 int fd,
44 std::string server_ip, 44 std::string server_ip,
45 std::string server_port, 45 std::string server_port,
46 std::string remote_ip, 46 std::string remote_ip,
47 bool use_ssl) OVERRIDE; 47 bool use_ssl) override;
48 48
49 // Create new SPDY framer after reusing SpdySM and negotiating new version 49 // Create new SPDY framer after reusing SpdySM and negotiating new version
50 void CreateFramer(SpdyMajorVersion spdy_version); 50 void CreateFramer(SpdyMajorVersion spdy_version);
51 51
52 private: 52 private:
53 virtual void set_is_request() OVERRIDE {} 53 virtual void set_is_request() override {}
54 SMInterface* NewConnectionInterface(); 54 SMInterface* NewConnectionInterface();
55 // virtual for tests 55 // virtual for tests
56 virtual SMInterface* FindOrMakeNewSMConnectionInterface( 56 virtual SMInterface* FindOrMakeNewSMConnectionInterface(
57 const std::string& server_ip, 57 const std::string& server_ip,
58 const std::string& server_port); 58 const std::string& server_port);
59 int SpdyHandleNewStream(SpdyStreamId stream_id, 59 int SpdyHandleNewStream(SpdyStreamId stream_id,
60 SpdyPriority priority, 60 SpdyPriority priority,
61 const SpdyHeaderBlock& headers, 61 const SpdyHeaderBlock& headers,
62 std::string& http_data, 62 std::string& http_data,
63 bool* is_https_scheme); 63 bool* is_https_scheme);
64 64
65 // BufferedSpdyFramerVisitorInterface: 65 // BufferedSpdyFramerVisitorInterface:
66 virtual void OnError(SpdyFramer::SpdyError error_code) OVERRIDE {} 66 virtual void OnError(SpdyFramer::SpdyError error_code) override {}
67 virtual void OnStreamError(SpdyStreamId stream_id, 67 virtual void OnStreamError(SpdyStreamId stream_id,
68 const std::string& description) OVERRIDE {} 68 const std::string& description) override {}
69 // Called after all the header data for SYN_STREAM control frame is received. 69 // Called after all the header data for SYN_STREAM control frame is received.
70 virtual void OnSynStream(SpdyStreamId stream_id, 70 virtual void OnSynStream(SpdyStreamId stream_id,
71 SpdyStreamId associated_stream_id, 71 SpdyStreamId associated_stream_id,
72 SpdyPriority priority, 72 SpdyPriority priority,
73 bool fin, 73 bool fin,
74 bool unidirectional, 74 bool unidirectional,
75 const SpdyHeaderBlock& headers) OVERRIDE; 75 const SpdyHeaderBlock& headers) override;
76 76
77 // Called after all the header data for SYN_REPLY control frame is received. 77 // Called after all the header data for SYN_REPLY control frame is received.
78 virtual void OnSynReply(SpdyStreamId stream_id, 78 virtual void OnSynReply(SpdyStreamId stream_id,
79 bool fin, 79 bool fin,
80 const SpdyHeaderBlock& headers) OVERRIDE; 80 const SpdyHeaderBlock& headers) override;
81 81
82 // Called after all the header data for HEADERS control frame is received. 82 // Called after all the header data for HEADERS control frame is received.
83 virtual void OnHeaders(SpdyStreamId stream_id, 83 virtual void OnHeaders(SpdyStreamId stream_id,
84 bool fin, 84 bool fin,
85 const SpdyHeaderBlock& headers) OVERRIDE; 85 const SpdyHeaderBlock& headers) override;
86 86
87 // Called when data frame header is received. 87 // Called when data frame header is received.
88 virtual void OnDataFrameHeader(SpdyStreamId stream_id, 88 virtual void OnDataFrameHeader(SpdyStreamId stream_id,
89 size_t length, 89 size_t length,
90 bool fin) OVERRIDE {} 90 bool fin) override {}
91 91
92 // Called when data is received. 92 // Called when data is received.
93 // |stream_id| The stream receiving data. 93 // |stream_id| The stream receiving data.
94 // |data| A buffer containing the data received. 94 // |data| A buffer containing the data received.
95 // |len| The length of the data buffer. 95 // |len| The length of the data buffer.
96 // When the other side has finished sending data on this stream, 96 // When the other side has finished sending data on this stream,
97 // this method will be called with a zero-length buffer. 97 // this method will be called with a zero-length buffer.
98 virtual void OnStreamFrameData(SpdyStreamId stream_id, 98 virtual void OnStreamFrameData(SpdyStreamId stream_id,
99 const char* data, 99 const char* data,
100 size_t len, 100 size_t len,
101 bool fin) OVERRIDE; 101 bool fin) override;
102 102
103 // Called when a SETTINGS frame is received. 103 // Called when a SETTINGS frame is received.
104 // |clear_persisted| True if the respective flag is set on the SETTINGS frame. 104 // |clear_persisted| True if the respective flag is set on the SETTINGS frame.
105 virtual void OnSettings(bool clear_persisted) OVERRIDE {} 105 virtual void OnSettings(bool clear_persisted) override {}
106 106
107 // Called when an individual setting within a SETTINGS frame has been parsed 107 // Called when an individual setting within a SETTINGS frame has been parsed
108 // and validated. 108 // and validated.
109 virtual void OnSetting(SpdySettingsIds id, 109 virtual void OnSetting(SpdySettingsIds id,
110 uint8 flags, 110 uint8 flags,
111 uint32 value) OVERRIDE {} 111 uint32 value) override {}
112 112
113 // Called when a PING frame has been parsed. 113 // Called when a PING frame has been parsed.
114 virtual void OnPing(SpdyPingId unique_id, bool is_ack) OVERRIDE {} 114 virtual void OnPing(SpdyPingId unique_id, bool is_ack) override {}
115 115
116 // Called when a RST_STREAM frame has been parsed. 116 // Called when a RST_STREAM frame has been parsed.
117 virtual void OnRstStream(SpdyStreamId stream_id, 117 virtual void OnRstStream(SpdyStreamId stream_id,
118 SpdyRstStreamStatus status) OVERRIDE; 118 SpdyRstStreamStatus status) override;
119 119
120 // Called when a GOAWAY frame has been parsed. 120 // Called when a GOAWAY frame has been parsed.
121 virtual void OnGoAway(SpdyStreamId last_accepted_stream_id, 121 virtual void OnGoAway(SpdyStreamId last_accepted_stream_id,
122 SpdyGoAwayStatus status) OVERRIDE {} 122 SpdyGoAwayStatus status) override {}
123 123
124 // Called when a WINDOW_UPDATE frame has been parsed. 124 // Called when a WINDOW_UPDATE frame has been parsed.
125 virtual void OnWindowUpdate(SpdyStreamId stream_id, 125 virtual void OnWindowUpdate(SpdyStreamId stream_id,
126 uint32 delta_window_size) OVERRIDE {} 126 uint32 delta_window_size) override {}
127 127
128 // Called when a PUSH_PROMISE frame has been parsed. 128 // Called when a PUSH_PROMISE frame has been parsed.
129 virtual void OnPushPromise(SpdyStreamId stream_id, 129 virtual void OnPushPromise(SpdyStreamId stream_id,
130 SpdyStreamId promised_stream_id, 130 SpdyStreamId promised_stream_id,
131 const SpdyHeaderBlock& headers) OVERRIDE {} 131 const SpdyHeaderBlock& headers) override {}
132 132
133 virtual bool OnUnknownFrame(SpdyStreamId stream_id, int frame_type) OVERRIDE; 133 virtual bool OnUnknownFrame(SpdyStreamId stream_id, int frame_type) override;
134 134
135 public: 135 public:
136 virtual size_t ProcessReadInput(const char* data, size_t len) OVERRIDE; 136 virtual size_t ProcessReadInput(const char* data, size_t len) override;
137 virtual size_t ProcessWriteInput(const char* data, size_t len) OVERRIDE; 137 virtual size_t ProcessWriteInput(const char* data, size_t len) override;
138 virtual bool MessageFullyRead() const OVERRIDE; 138 virtual bool MessageFullyRead() const override;
139 virtual void SetStreamID(uint32 stream_id) OVERRIDE {} 139 virtual void SetStreamID(uint32 stream_id) override {}
140 virtual bool Error() const OVERRIDE; 140 virtual bool Error() const override;
141 virtual const char* ErrorAsString() const OVERRIDE; 141 virtual const char* ErrorAsString() const override;
142 virtual void Reset() OVERRIDE {} 142 virtual void Reset() override {}
143 virtual void ResetForNewInterface(int32 server_idx) OVERRIDE; 143 virtual void ResetForNewInterface(int32 server_idx) override;
144 virtual void ResetForNewConnection() OVERRIDE; 144 virtual void ResetForNewConnection() override;
145 // SMInterface's Cleanup is currently only called by SMConnection after a 145 // SMInterface's Cleanup is currently only called by SMConnection after a
146 // protocol message as been fully read. Spdy's SMInterface does not need 146 // protocol message as been fully read. Spdy's SMInterface does not need
147 // to do any cleanup at this time. 147 // to do any cleanup at this time.
148 // TODO(klindsay) This method is probably not being used properly and 148 // TODO(klindsay) This method is probably not being used properly and
149 // some logic review and method renaming is probably in order. 149 // some logic review and method renaming is probably in order.
150 virtual void Cleanup() OVERRIDE {} 150 virtual void Cleanup() override {}
151 // Send a settings frame 151 // Send a settings frame
152 virtual int PostAcceptHook() OVERRIDE; 152 virtual int PostAcceptHook() override;
153 virtual void NewStream(uint32 stream_id, 153 virtual void NewStream(uint32 stream_id,
154 uint32 priority, 154 uint32 priority,
155 const std::string& filename) OVERRIDE; 155 const std::string& filename) override;
156 void AddToOutputOrder(const MemCacheIter& mci); 156 void AddToOutputOrder(const MemCacheIter& mci);
157 virtual void SendEOF(uint32 stream_id) OVERRIDE; 157 virtual void SendEOF(uint32 stream_id) override;
158 virtual void SendErrorNotFound(uint32 stream_id) OVERRIDE; 158 virtual void SendErrorNotFound(uint32 stream_id) override;
159 virtual size_t SendSynStream(uint32 stream_id, 159 virtual size_t SendSynStream(uint32 stream_id,
160 const BalsaHeaders& headers) OVERRIDE; 160 const BalsaHeaders& headers) override;
161 virtual size_t SendSynReply(uint32 stream_id, 161 virtual size_t SendSynReply(uint32 stream_id,
162 const BalsaHeaders& headers) OVERRIDE; 162 const BalsaHeaders& headers) override;
163 virtual void SendDataFrame(uint32 stream_id, 163 virtual void SendDataFrame(uint32 stream_id,
164 const char* data, 164 const char* data,
165 int64 len, 165 int64 len,
166 uint32 flags, 166 uint32 flags,
167 bool compress) OVERRIDE; 167 bool compress) override;
168 BufferedSpdyFramer* spdy_framer() { return buffered_spdy_framer_.get(); } 168 BufferedSpdyFramer* spdy_framer() { return buffered_spdy_framer_.get(); }
169 169
170 const OutputOrdering& output_ordering() const { 170 const OutputOrdering& output_ordering() const {
171 return client_output_ordering_; 171 return client_output_ordering_;
172 } 172 }
173 173
174 static std::string forward_ip_header() { return forward_ip_header_; } 174 static std::string forward_ip_header() { return forward_ip_header_; }
175 static void set_forward_ip_header(const std::string& value) { 175 static void set_forward_ip_header(const std::string& value) {
176 forward_ip_header_ = value; 176 forward_ip_header_ = value;
177 } 177 }
178 SpdyMajorVersion spdy_version() const { 178 SpdyMajorVersion spdy_version() const {
179 DCHECK(buffered_spdy_framer_); 179 DCHECK(buffered_spdy_framer_);
180 return buffered_spdy_framer_->protocol_version(); 180 return buffered_spdy_framer_->protocol_version();
181 } 181 }
182 182
183 private: 183 private:
184 void SendEOFImpl(uint32 stream_id); 184 void SendEOFImpl(uint32 stream_id);
185 void SendErrorNotFoundImpl(uint32 stream_id); 185 void SendErrorNotFoundImpl(uint32 stream_id);
186 void KillStream(uint32 stream_id); 186 void KillStream(uint32 stream_id);
187 void CopyHeaders(SpdyHeaderBlock& dest, const BalsaHeaders& headers); 187 void CopyHeaders(SpdyHeaderBlock& dest, const BalsaHeaders& headers);
188 size_t SendSynStreamImpl(uint32 stream_id, const BalsaHeaders& headers); 188 size_t SendSynStreamImpl(uint32 stream_id, const BalsaHeaders& headers);
189 size_t SendSynReplyImpl(uint32 stream_id, const BalsaHeaders& headers); 189 size_t SendSynReplyImpl(uint32 stream_id, const BalsaHeaders& headers);
190 void SendDataFrameImpl(uint32 stream_id, 190 void SendDataFrameImpl(uint32 stream_id,
191 const char* data, 191 const char* data,
192 int64 len, 192 int64 len,
193 SpdyDataFlags flags, 193 SpdyDataFlags flags,
194 bool compress); 194 bool compress);
195 void EnqueueDataFrame(DataFrame* df); 195 void EnqueueDataFrame(DataFrame* df);
196 virtual void GetOutput() OVERRIDE; 196 virtual void GetOutput() override;
197 197
198 private: 198 private:
199 scoped_ptr<BufferedSpdyFramer> buffered_spdy_framer_; 199 scoped_ptr<BufferedSpdyFramer> buffered_spdy_framer_;
200 bool valid_spdy_session_; // True if we have seen valid data on this session. 200 bool valid_spdy_session_; // True if we have seen valid data on this session.
201 // Use this to fail fast when junk is sent to our 201 // Use this to fail fast when junk is sent to our
202 // port. 202 // port.
203 203
204 SMConnection* connection_; 204 SMConnection* connection_;
205 OutputList* client_output_list_; 205 OutputList* client_output_list_;
206 OutputOrdering client_output_ordering_; 206 OutputOrdering client_output_ordering_;
207 uint32 next_outgoing_stream_id_; 207 uint32 next_outgoing_stream_id_;
208 EpollServer* epoll_server_; 208 EpollServer* epoll_server_;
209 FlipAcceptor* acceptor_; 209 FlipAcceptor* acceptor_;
210 MemoryCache* memory_cache_; 210 MemoryCache* memory_cache_;
211 std::vector<SMInterface*> server_interface_list; 211 std::vector<SMInterface*> server_interface_list;
212 std::vector<int32> unused_server_interface_list; 212 std::vector<int32> unused_server_interface_list;
213 typedef std::map<uint32, SMInterface*> StreamToSmif; 213 typedef std::map<uint32, SMInterface*> StreamToSmif;
214 StreamToSmif stream_to_smif_; 214 StreamToSmif stream_to_smif_;
215 bool close_on_error_; 215 bool close_on_error_;
216 216
217 static std::string forward_ip_header_; 217 static std::string forward_ip_header_;
218 }; 218 };
219 219
220 } // namespace net 220 } // namespace net
221 221
222 #endif // NET_TOOLS_FLIP_SERVER_SPDY_INTERFACE_H_ 222 #endif // NET_TOOLS_FLIP_SERVER_SPDY_INTERFACE_H_
OLDNEW
« no previous file with comments | « net/tools/flip_server/sm_connection.h ('k') | net/tools/flip_server/streamer_interface.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698