diff options
author | mbelshe@chromium.org <mbelshe@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2010-09-03 21:30:39 +0000 |
---|---|---|
committer | mbelshe@chromium.org <mbelshe@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2010-09-03 21:30:39 +0000 |
commit | e20cc6db1994ad4b789aebbae578f7928ca12af8 (patch) | |
tree | 2ee65df0f34107ae0e59a3b8d4166e0466ec786a /net/spdy | |
parent | 41e0c0d3aefe5965bf1c0a3e0fc723001de1f863 (diff) | |
download | chromium_src-e20cc6db1994ad4b789aebbae578f7928ca12af8.zip chromium_src-e20cc6db1994ad4b789aebbae578f7928ca12af8.tar.gz chromium_src-e20cc6db1994ad4b789aebbae578f7928ca12af8.tar.bz2 |
Cleanup the LOG(INFO)s out of the SpdyStream. Most of the logging was
redundant, so it is removed. Next changelist will refactor the way we do
headers from the HttpNetworkTransaction, which will move the header logging
back into the stream. then I think I'm done.
BUG=53956
TEST=none
Review URL: http://codereview.chromium.org/3331012
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@58541 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'net/spdy')
-rw-r--r-- | net/spdy/spdy_stream.cc | 57 |
1 files changed, 38 insertions, 19 deletions
diff --git a/net/spdy/spdy_stream.cc b/net/spdy/spdy_stream.cc index 66ca694..88b009d 100644 --- a/net/spdy/spdy_stream.cc +++ b/net/spdy/spdy_stream.cc @@ -7,10 +7,35 @@ #include "base/logging.h" #include "base/message_loop.h" #include "base/singleton.h" +#include "base/values.h" #include "net/spdy/spdy_session.h" namespace net { +namespace { + +class NetLogSpdyStreamWindowUpdateParameter : public NetLog::EventParameters { + public: + NetLogSpdyStreamWindowUpdateParameter(spdy::SpdyStreamId stream_id, + int delta, + int window_size) + : stream_id_(stream_id), delta_(delta), window_size_(window_size) {} + virtual Value* ToValue() const { + DictionaryValue* dict = new DictionaryValue(); + dict->SetInteger("id", static_cast<int>(stream_id_)); + dict->SetInteger("delta", delta_); + dict->SetInteger("window_size", window_size_); + return dict; + } + private: + const spdy::SpdyStreamId stream_id_; + const int delta_; + const int window_size_; + DISALLOW_COPY_AND_ASSIGN(NetLogSpdyStreamWindowUpdateParameter); +}; + +} + SpdyStream::SpdyStream(SpdySession* session, spdy::SpdyStreamId stream_id, bool pushed, @@ -121,11 +146,11 @@ void SpdyStream::IncreaseSendWindowSize(int delta_window_size) { return; } - LOG(INFO) << "Increasing stream " << stream_id_ - << " send_window_size_ [current:" << send_window_size_ << "]" - << " by " << delta_window_size << " bytes"; send_window_size_ = new_window_size; + net_log_.AddEvent(NetLog::TYPE_SPDY_STREAM_SEND_WINDOW_UPDATE, + new NetLogSpdyStreamWindowUpdateParameter(stream_id_, + delta_window_size, send_window_size_)); if (stalled_by_flow_control_) { stalled_by_flow_control_ = false; io_state_ = STATE_SEND_BODY; @@ -143,10 +168,11 @@ void SpdyStream::DecreaseSendWindowSize(int delta_window_size) { // this call to happen. DCHECK_GE(send_window_size_, delta_window_size); - LOG(INFO) << "Decreasing stream " << stream_id_ - << " send_window_size_ [current:" << send_window_size_ << "]" - << " by " << delta_window_size << " bytes"; send_window_size_ -= delta_window_size; + + net_log_.AddEvent(NetLog::TYPE_SPDY_STREAM_SEND_WINDOW_UPDATE, + new NetLogSpdyStreamWindowUpdateParameter(stream_id_, + -delta_window_size, send_window_size_)); } void SpdyStream::IncreaseRecvWindowSize(int delta_window_size) { @@ -158,20 +184,20 @@ void SpdyStream::IncreaseRecvWindowSize(int delta_window_size) { if (recv_window_size_ > 0) DCHECK(new_window_size > 0); - LOG(INFO) << "Increasing stream " << stream_id_ - << " recv_window_size_ [current:" << recv_window_size_ << "]" - << " by " << delta_window_size << " bytes"; recv_window_size_ = new_window_size; + net_log_.AddEvent(NetLog::TYPE_SPDY_STREAM_RECV_WINDOW_UPDATE, + new NetLogSpdyStreamWindowUpdateParameter(stream_id_, + delta_window_size, recv_window_size_)); session_->SendWindowUpdate(stream_id_, delta_window_size); } void SpdyStream::DecreaseRecvWindowSize(int delta_window_size) { DCHECK_GE(delta_window_size, 1); - LOG(INFO) << "Decreasing stream " << stream_id_ - << " recv_window_size_ [current:" << recv_window_size_ << "]" - << " by " << delta_window_size << " bytes"; recv_window_size_ -= delta_window_size; + net_log_.AddEvent(NetLog::TYPE_SPDY_STREAM_RECV_WINDOW_UPDATE, + new NetLogSpdyStreamWindowUpdateParameter(stream_id_, + -delta_window_size, recv_window_size_)); // Since we never decrease the initial window size, we should never hit // a negative |recv_window_size_|, if we do, it's a flow-control violation. @@ -190,7 +216,6 @@ void SpdyStream::SetRequestTime(base::Time t) { int SpdyStream::OnResponseReceived(const spdy::SpdyHeaderBlock& response) { int rv = OK; - LOG(INFO) << "Received response for stream " << stream_id_; metrics_.StartStream(); @@ -218,8 +243,6 @@ int SpdyStream::OnResponseReceived(const spdy::SpdyHeaderBlock& response) { void SpdyStream::OnDataReceived(const char* data, int length) { DCHECK_GE(length, 0); - LOG(INFO) << "SpdyStream: Data (" << length << " bytes) received for " - << stream_id_; if (!delegate_ || continue_buffering_data_) { // It should be valid for this to happen in the server push case. @@ -339,20 +362,16 @@ int SpdyStream::DoLoop(int result) { // State machine 1: Send headers and body. case STATE_SEND_HEADERS: CHECK_EQ(OK, result); - net_log_.BeginEvent(NetLog::TYPE_SPDY_STREAM_SEND_HEADERS, NULL); result = DoSendHeaders(); break; case STATE_SEND_HEADERS_COMPLETE: - net_log_.EndEvent(NetLog::TYPE_SPDY_STREAM_SEND_HEADERS, NULL); result = DoSendHeadersComplete(result); break; case STATE_SEND_BODY: CHECK_EQ(OK, result); - net_log_.BeginEvent(NetLog::TYPE_SPDY_STREAM_SEND_BODY, NULL); result = DoSendBody(); break; case STATE_SEND_BODY_COMPLETE: - net_log_.EndEvent(NetLog::TYPE_SPDY_STREAM_SEND_BODY, NULL); result = DoSendBodyComplete(result); break; // This is an intermediary waiting state. This state is reached when all |