| OLD | NEW |
| 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 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 #include "net/spdy/spdy_stream.h" | 5 #include "net/spdy/spdy_stream.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/message_loop.h" | 8 #include "base/message_loop.h" |
| 9 #include "base/singleton.h" | 9 #include "base/singleton.h" |
| 10 #include "base/values.h" | 10 #include "base/values.h" |
| (...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 198 net_log_.AddEvent(NetLog::TYPE_SPDY_STREAM_RECV_WINDOW_UPDATE, | 198 net_log_.AddEvent(NetLog::TYPE_SPDY_STREAM_RECV_WINDOW_UPDATE, |
| 199 new NetLogSpdyStreamWindowUpdateParameter(stream_id_, | 199 new NetLogSpdyStreamWindowUpdateParameter(stream_id_, |
| 200 -delta_window_size, recv_window_size_)); | 200 -delta_window_size, recv_window_size_)); |
| 201 | 201 |
| 202 // Since we never decrease the initial window size, we should never hit | 202 // Since we never decrease the initial window size, we should never hit |
| 203 // a negative |recv_window_size_|, if we do, it's a flow-control violation. | 203 // a negative |recv_window_size_|, if we do, it's a flow-control violation. |
| 204 if (recv_window_size_ < 0) | 204 if (recv_window_size_ < 0) |
| 205 session_->ResetStream(stream_id_, spdy::FLOW_CONTROL_ERROR); | 205 session_->ResetStream(stream_id_, spdy::FLOW_CONTROL_ERROR); |
| 206 } | 206 } |
| 207 | 207 |
| 208 int SpdyStream::GetPeerAddress(AddressList* address) const { | |
| 209 return session_->GetPeerAddress(address); | |
| 210 } | |
| 211 | |
| 212 bool SpdyStream::WasEverUsed() const { | |
| 213 return session_->WasEverUsed(); | |
| 214 } | |
| 215 | 208 |
| 216 base::Time SpdyStream::GetRequestTime() const { | 209 base::Time SpdyStream::GetRequestTime() const { |
| 217 return request_time_; | 210 return request_time_; |
| 218 } | 211 } |
| 219 | 212 |
| 220 void SpdyStream::SetRequestTime(base::Time t) { | 213 void SpdyStream::SetRequestTime(base::Time t) { |
| 221 request_time_ = t; | 214 request_time_ = t; |
| 222 } | 215 } |
| 223 | 216 |
| 224 int SpdyStream::OnResponseReceived(const spdy::SpdyHeaderBlock& response) { | 217 int SpdyStream::OnResponseReceived(const spdy::SpdyHeaderBlock& response) { |
| (...skipping 280 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 505 UMA_HISTOGRAM_TIMES("Net.SpdyStreamDownloadTime", | 498 UMA_HISTOGRAM_TIMES("Net.SpdyStreamDownloadTime", |
| 506 recv_last_byte_time_ - recv_first_byte_time_); | 499 recv_last_byte_time_ - recv_first_byte_time_); |
| 507 UMA_HISTOGRAM_TIMES("Net.SpdyStreamTime", | 500 UMA_HISTOGRAM_TIMES("Net.SpdyStreamTime", |
| 508 recv_last_byte_time_ - send_time_); | 501 recv_last_byte_time_ - send_time_); |
| 509 | 502 |
| 510 UMA_HISTOGRAM_COUNTS("Net.SpdySendBytes", send_bytes_); | 503 UMA_HISTOGRAM_COUNTS("Net.SpdySendBytes", send_bytes_); |
| 511 UMA_HISTOGRAM_COUNTS("Net.SpdyRecvBytes", recv_bytes_); | 504 UMA_HISTOGRAM_COUNTS("Net.SpdyRecvBytes", recv_bytes_); |
| 512 } | 505 } |
| 513 | 506 |
| 514 } // namespace net | 507 } // namespace net |
| OLD | NEW |