Index: net/spdy/spdy_session.cc |
=================================================================== |
--- net/spdy/spdy_session.cc (revision 122608) |
+++ net/spdy/spdy_session.cc (working copy) |
@@ -295,7 +295,6 @@ |
streams_pushed_count_(0), |
streams_pushed_and_claimed_count_(0), |
streams_abandoned_count_(0), |
- frames_received_(0), |
bytes_received_(0), |
sent_settings_(false), |
received_settings_(false), |
@@ -1105,7 +1104,7 @@ |
dict->SetInteger("streams_pushed_and_claimed_count", |
streams_pushed_and_claimed_count_); |
dict->SetInteger("streams_abandoned_count", streams_abandoned_count_); |
- dict->SetInteger("frames_received", frames_received_); |
+ dict->SetInteger("frames_received", buffered_spdy_framer_.frames_received()); |
dict->SetBoolean("sent_settings", sent_settings_); |
dict->SetBoolean("received_settings", received_settings_); |
@@ -1230,10 +1229,15 @@ |
return ssl_socket->origin_bound_cert_type(); |
} |
-void SpdySession::OnError(spdy::SpdyFramer* framer) { |
+void SpdySession::OnError() { |
CloseSessionOnError(net::ERR_SPDY_PROTOCOL_ERROR, true); |
} |
+void SpdySession::OnStreamError(spdy::SpdyStreamId stream_id) { |
+ if (IsStreamActive(stream_id)) |
+ ResetStream(stream_id, spdy::PROTOCOL_ERROR, ""); |
+} |
+ |
void SpdySession::OnStreamFrameData(spdy::SpdyStreamId stream_id, |
const char* data, |
size_t len) { |
@@ -1267,8 +1271,9 @@ |
return true; |
} |
-void SpdySession::OnSyn(const spdy::SpdySynStreamControlFrame& frame, |
- const linked_ptr<spdy::SpdyHeaderBlock>& headers) { |
+void SpdySession::OnSynStream( |
+ const spdy::SpdySynStreamControlFrame& frame, |
+ const linked_ptr<spdy::SpdyHeaderBlock>& headers) { |
spdy::SpdyStreamId stream_id = frame.stream_id(); |
spdy::SpdyStreamId associated_stream_id = frame.associated_stream_id(); |
@@ -1438,67 +1443,7 @@ |
} |
} |
-void SpdySession::OnControl(const spdy::SpdyControlFrame* frame) { |
- uint32 type = frame->type(); |
- if (type == spdy::SYN_STREAM || |
- type == spdy::SYN_REPLY || |
- type == spdy::HEADERS) { |
- buffered_spdy_framer_.OnControl(frame); |
- return; |
- } |
- |
- frames_received_++; |
- |
- switch (type) { |
- case spdy::GOAWAY: |
- OnGoAway(*reinterpret_cast<const spdy::SpdyGoAwayControlFrame*>(frame)); |
- break; |
- case spdy::PING: |
- OnPing(*reinterpret_cast<const spdy::SpdyPingControlFrame*>(frame)); |
- break; |
- case spdy::SETTINGS: |
- OnSettings( |
- *reinterpret_cast<const spdy::SpdySettingsControlFrame*>(frame)); |
- break; |
- case spdy::RST_STREAM: |
- OnRst(*reinterpret_cast<const spdy::SpdyRstStreamControlFrame*>(frame)); |
- break; |
- case spdy::WINDOW_UPDATE: |
- OnWindowUpdate( |
- *reinterpret_cast<const spdy::SpdyWindowUpdateControlFrame*>(frame)); |
- break; |
- default: |
- DCHECK(false); // Error! |
- } |
-} |
- |
-bool SpdySession::OnControlFrameHeaderData(spdy::SpdyStreamId stream_id, |
- const char* header_data, |
- size_t len) { |
- if (!buffered_spdy_framer_.OnControlFrameHeaderData( |
- stream_id, header_data, len)) { |
- if (IsStreamActive(stream_id)) |
- ResetStream(stream_id, spdy::PROTOCOL_ERROR, ""); |
- return false; |
- } |
- if (len == 0) { |
- // Indicates end-of-header-block. |
- frames_received_++; |
- } |
- return true; |
-} |
- |
-bool SpdySession::OnCredentialFrameData(const char* frame_data, |
- size_t len) { |
- DCHECK(false); |
- return false; |
-} |
- |
-void SpdySession::OnDataFrameHeader(const spdy::SpdyDataFrame* frame) { |
- buffered_spdy_framer_.OnDataFrameHeader(frame); |
-} |
- |
-void SpdySession::OnRst(const spdy::SpdyRstStreamControlFrame& frame) { |
+void SpdySession::OnRstStream(const spdy::SpdyRstStreamControlFrame& frame) { |
spdy::SpdyStreamId stream_id = frame.stream_id(); |
net_log().AddEvent( |