| OLD | NEW |
| 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_SPDY_SPDY_FRAMER_H_ | 5 #ifndef NET_SPDY_SPDY_FRAMER_H_ |
| 6 #define NET_SPDY_SPDY_FRAMER_H_ | 6 #define NET_SPDY_SPDY_FRAMER_H_ |
| 7 | 7 |
| 8 #include <list> | 8 #include <list> |
| 9 #include <map> | 9 #include <map> |
| 10 #include <string> | 10 #include <string> |
| (...skipping 196 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 207 virtual void OnWindowUpdate(SpdyStreamId stream_id, | 207 virtual void OnWindowUpdate(SpdyStreamId stream_id, |
| 208 int delta_window_size) = 0; | 208 int delta_window_size) = 0; |
| 209 | 209 |
| 210 // Called after a control frame has been compressed to allow the visitor | 210 // Called after a control frame has been compressed to allow the visitor |
| 211 // to record compression statistics. | 211 // to record compression statistics. |
| 212 virtual void OnControlFrameCompressed( | 212 virtual void OnControlFrameCompressed( |
| 213 const SpdyControlFrame& uncompressed_frame, | 213 const SpdyControlFrame& uncompressed_frame, |
| 214 const SpdyControlFrame& compressed_frame) = 0; | 214 const SpdyControlFrame& compressed_frame) = 0; |
| 215 }; | 215 }; |
| 216 | 216 |
| 217 // Optionally, and in addition to SpdyFramerVisitorInterface, a class supporting |
| 218 // SpdyFramerDebugVisitorInterface may be used in conjunction with SpdyFramer in |
| 219 // order to extract debug/internal information about the SpdyFramer as it |
| 220 // operates. |
| 221 // |
| 222 // Most SPDY implementations need not bother with this interface at all. |
| 223 class SpdyFramerDebugVisitorInterface { |
| 224 public: |
| 225 virtual ~SpdyFramerDebugVisitorInterface() {} |
| 226 |
| 227 // Called after compressing header blocks. |
| 228 // Provides decompressed and compressed sizes. |
| 229 virtual void OnCompressedHeaderBlock(size_t decompressed_len, |
| 230 size_t compressed_len) {} |
| 231 }; |
| 232 |
| 217 class NET_EXPORT_PRIVATE SpdyFramer { | 233 class NET_EXPORT_PRIVATE SpdyFramer { |
| 218 public: | 234 public: |
| 219 // SPDY states. | 235 // SPDY states. |
| 220 // TODO(mbelshe): Can we move these into the implementation | 236 // TODO(mbelshe): Can we move these into the implementation |
| 221 // and avoid exposing through the header. (Needed for test) | 237 // and avoid exposing through the header. (Needed for test) |
| 222 enum SpdyState { | 238 enum SpdyState { |
| 223 SPDY_ERROR, | 239 SPDY_ERROR, |
| 224 SPDY_DONE, | 240 SPDY_DONE, |
| 225 SPDY_RESET, | 241 SPDY_RESET, |
| 226 SPDY_AUTO_RESET, | 242 SPDY_AUTO_RESET, |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 277 virtual ~SpdyFramer(); | 293 virtual ~SpdyFramer(); |
| 278 | 294 |
| 279 // Set callbacks to be called from the framer. A visitor must be set, or | 295 // Set callbacks to be called from the framer. A visitor must be set, or |
| 280 // else the framer will likely crash. It is acceptable for the visitor | 296 // else the framer will likely crash. It is acceptable for the visitor |
| 281 // to do nothing. If this is called multiple times, only the last visitor | 297 // to do nothing. If this is called multiple times, only the last visitor |
| 282 // will be used. | 298 // will be used. |
| 283 void set_visitor(SpdyFramerVisitorInterface* visitor) { | 299 void set_visitor(SpdyFramerVisitorInterface* visitor) { |
| 284 visitor_ = visitor; | 300 visitor_ = visitor; |
| 285 } | 301 } |
| 286 | 302 |
| 303 // Set debug callbacks to be called from the framer. The debug visitor is |
| 304 // completely optional and need not be set in order for normal operation. |
| 305 // If this is called multiple times, only the last visitor will be used. |
| 306 void set_debug_visitor(SpdyFramerDebugVisitorInterface* debug_visitor) { |
| 307 debug_visitor_ = debug_visitor; |
| 308 } |
| 309 |
| 287 // Pass data into the framer for parsing. | 310 // Pass data into the framer for parsing. |
| 288 // Returns the number of bytes consumed. It is safe to pass more bytes in | 311 // Returns the number of bytes consumed. It is safe to pass more bytes in |
| 289 // than may be consumed. | 312 // than may be consumed. |
| 290 size_t ProcessInput(const char* data, size_t len); | 313 size_t ProcessInput(const char* data, size_t len); |
| 291 | 314 |
| 292 // Resets the framer state after a frame has been successfully decoded. | 315 // Resets the framer state after a frame has been successfully decoded. |
| 293 // TODO(mbelshe): can we make this private? | 316 // TODO(mbelshe): can we make this private? |
| 294 void Reset(); | 317 void Reset(); |
| 295 | 318 |
| 296 // Check the state of the framer. | 319 // Check the state of the framer. |
| (...skipping 275 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 572 // TODO(hkhalil): Unify memory for this scratch space with | 595 // TODO(hkhalil): Unify memory for this scratch space with |
| 573 // current_frame_buffer_. | 596 // current_frame_buffer_. |
| 574 SpdySettingsScratch settings_scratch_; | 597 SpdySettingsScratch settings_scratch_; |
| 575 | 598 |
| 576 bool enable_compression_; // Controls all compression | 599 bool enable_compression_; // Controls all compression |
| 577 // SPDY header compressors. | 600 // SPDY header compressors. |
| 578 scoped_ptr<z_stream> header_compressor_; | 601 scoped_ptr<z_stream> header_compressor_; |
| 579 scoped_ptr<z_stream> header_decompressor_; | 602 scoped_ptr<z_stream> header_decompressor_; |
| 580 | 603 |
| 581 SpdyFramerVisitorInterface* visitor_; | 604 SpdyFramerVisitorInterface* visitor_; |
| 605 SpdyFramerDebugVisitorInterface* debug_visitor_; |
| 582 | 606 |
| 583 std::string display_protocol_; | 607 std::string display_protocol_; |
| 584 | 608 |
| 585 // The SPDY version to be spoken/understood by this framer. We support only | 609 // The SPDY version to be spoken/understood by this framer. We support only |
| 586 // integer versions here, as major version numbers indicate framer-layer | 610 // integer versions here, as major version numbers indicate framer-layer |
| 587 // incompatibility and minor version numbers indicate application-layer | 611 // incompatibility and minor version numbers indicate application-layer |
| 588 // incompatibility. | 612 // incompatibility. |
| 589 const int spdy_version_; | 613 const int spdy_version_; |
| 590 | 614 |
| 591 // Tracks if we've ever gotten far enough in framing to see a control frame of | 615 // Tracks if we've ever gotten far enough in framing to see a control frame of |
| 592 // type SYN_STREAM or SYN_REPLY. | 616 // type SYN_STREAM or SYN_REPLY. |
| 593 // | 617 // |
| 594 // If we ever get something which looks like a data frame before we've had a | 618 // If we ever get something which looks like a data frame before we've had a |
| 595 // SYN, we explicitly check to see if it looks like we got an HTTP response to | 619 // SYN, we explicitly check to see if it looks like we got an HTTP response to |
| 596 // a SPDY request. This boolean lets us do that. | 620 // a SPDY request. This boolean lets us do that. |
| 597 bool syn_frame_processed_; | 621 bool syn_frame_processed_; |
| 598 | 622 |
| 599 // If we ever get a data frame before a SYN frame, we check to see if it | 623 // If we ever get a data frame before a SYN frame, we check to see if it |
| 600 // starts with HTTP. If it does, we likely have an HTTP response. This | 624 // starts with HTTP. If it does, we likely have an HTTP response. This |
| 601 // isn't guaranteed though: we could have gotten a settings frame and then | 625 // isn't guaranteed though: we could have gotten a settings frame and then |
| 602 // corrupt data that just looks like HTTP, but deterministic checking requires | 626 // corrupt data that just looks like HTTP, but deterministic checking requires |
| 603 // a lot more state. | 627 // a lot more state. |
| 604 bool probable_http_response_; | 628 bool probable_http_response_; |
| 605 }; | 629 }; |
| 606 | 630 |
| 607 } // namespace net | 631 } // namespace net |
| 608 | 632 |
| 609 #endif // NET_SPDY_SPDY_FRAMER_H_ | 633 #endif // NET_SPDY_SPDY_FRAMER_H_ |
| OLD | NEW |