1 files changed, 55 insertions, 6 deletions

diff --git a/net/spdy/spdy_session.cc b/net/spdy/spdy_session.cc
index 55c0b65..85c825b 100644
--- a/net/spdy/spdy_session.cc
+++ b/net/spdy/spdy_session.cc
@@ -213,6 +213,31 @@ class NetLogSpdySynParameter : public NetLog::EventParameters {
   DISALLOW_COPY_AND_ASSIGN(NetLogSpdySynParameter);
 };
 
+class NetLogSpdySettingsParameter : public NetLog::EventParameters {
+ public:
+  explicit NetLogSpdySettingsParameter(const spdy::SpdySettings& settings)
+      : settings_(settings) {}
+
+  Value* ToValue() const {
+    DictionaryValue* dict = new DictionaryValue();
+    ListValue* settings = new ListValue();
+    for (spdy::SpdySettings::const_iterator it = settings_.begin();
+         it != settings_.end(); ++it) {
+      settings->Append(new StringValue(
+          StringPrintf("[%u:%u]", it->first.id(), it->second)));
+    }
+    dict->Set(L"settings", settings);
+    return dict;
+  }
+
+ private:
+  ~NetLogSpdySettingsParameter() {}
+
+  const spdy::SpdySettings settings_;
+
+  DISALLOW_COPY_AND_ASSIGN(NetLogSpdySettingsParameter);
+};
+
 }  // namespace
 
 // static
@@ -220,7 +245,7 @@ bool SpdySession::use_ssl_ = true;
 
 SpdySession::SpdySession(const HostPortPair& host_port_pair,
                          HttpNetworkSession* session,
-                         const BoundNetLog& net_log)
+                         NetLog* net_log)
     : ALLOW_THIS_IN_INITIALIZER_LIST(
           connect_callback_(this, &SpdySession::OnTCPConnect)),
       ALLOW_THIS_IN_INITIALIZER_LIST(
@@ -245,7 +270,11 @@ SpdySession::SpdySession(const HostPortPair& host_port_pair,
       streams_pushed_and_claimed_count_(0),
       streams_abandoned_count_(0),
       in_session_pool_(true),
-      net_log_(net_log) {
+      net_log_(BoundNetLog::Make(net_log, NetLog::SOURCE_SPDY_SESSION)) {
+  net_log_.BeginEvent(
+      NetLog::TYPE_SPDY_SESSION,
+      new NetLogStringParameter("host_port", host_port_pair_.ToString()));
+
   // TODO(mbelshe): consider randomization of the stream_hi_water_mark.
 
   spdy_framer_.set_visitor(this);
@@ -277,6 +306,8 @@ SpdySession::~SpdySession() {
   UMA_HISTOGRAM_CUSTOM_COUNTS("Net.SpdyStreamsAbandonedPerSession",
       streams_abandoned_count_,
       0, 300, 50);
+
+  net_log_.EndEvent(NetLog::TYPE_SPDY_SESSION, NULL);
 }
 
 void SpdySession::InitializeWithSSLSocket(ClientSocketHandle* connection) {
@@ -520,7 +551,6 @@ void SpdySession::OnTCPConnect(int result) {
         socket, "" /* request_->url.HostNoBrackets() */ , ssl_config_);
     connection_->set_socket(socket);
     is_secure_ = true;
-    // TODO(willchan): Plumb NetLog into SPDY code.
     int status = connection_->socket()->Connect(&ssl_connect_callback_);
     if (status != ERR_IO_PENDING)
       OnSSLConnect(status);
@@ -1023,11 +1053,9 @@ void SpdySession::OnSyn(const spdy::SpdySynStreamControlFrame& frame,
   } else {
     stream = new SpdyStream(this, stream_id, true);
 
-    // TODO(willchan): Rename this event to SPDY_SESSION_PUSHED_SYN_STREAM once
-    // my other CL gets finished.
     if (net_log_.HasListener()) {
       net_log_.AddEvent(
-          NetLog::TYPE_SPDY_STREAM_PUSHED_SYN_STREAM,
+          NetLog::TYPE_SPDY_SESSION_PUSHED_SYN_STREAM,
           new NetLogSpdySynParameter(
               headers, static_cast<spdy::SpdyControlFlags>(frame.flags()),
               stream_id));
@@ -1167,6 +1195,12 @@ void SpdySession::OnFin(const spdy::SpdyRstStreamControlFrame& frame) {
   scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
   CHECK_EQ(stream->stream_id(), stream_id);
   CHECK(!stream->cancelled());
+
+  const BoundNetLog& log = stream->net_log();
+  log.AddEvent(
+      NetLog::TYPE_SPDY_STREAM_RST_STREAM,
+      new NetLogIntegerParameter("status", frame.status()));
+
   if (frame.status() == 0) {
     stream->OnDataReceived(NULL, 0);
   } else {
@@ -1182,6 +1216,13 @@ void SpdySession::OnFin(const spdy::SpdyRstStreamControlFrame& frame) {
 void SpdySession::OnGoAway(const spdy::SpdyGoAwayControlFrame& frame) {
   LOG(INFO) << "Spdy GOAWAY for session[" << this << "] for " <<
       host_port_pair().ToString();
+
+  net_log_.AddEvent(
+      NetLog::TYPE_SPDY_SESSION_GOAWAY,
+      new NetLogIntegerParameter(
+          "last_accepted_stream_id",
+          frame.last_accepted_stream_id()));
+
   RemoveFromPool();
 
   // TODO(willchan): Cancel any streams that are past the GoAway frame's
@@ -1198,6 +1239,10 @@ void SpdySession::OnSettings(const spdy::SpdySettingsControlFrame& frame) {
     SpdySettingsStorage* settings_storage = session_->mutable_spdy_settings();
     settings_storage->Set(host_port_pair_, settings);
   }
+
+  net_log_.AddEvent(
+      NetLog::TYPE_SPDY_SESSION_RECV_SETTINGS,
+      new NetLogSpdySettingsParameter(settings));
 }
 
 void SpdySession::SendSettings() {
@@ -1206,6 +1251,10 @@ void SpdySession::SendSettings() {
   if (settings.empty())
     return;
 
+  net_log_.AddEvent(
+      NetLog::TYPE_SPDY_SESSION_SEND_SETTINGS,
+      new NetLogSpdySettingsParameter(settings));
+
   // Create the SETTINGS frame and send it.
   scoped_ptr<spdy::SpdySettingsControlFrame> settings_frame(
       spdy_framer_.CreateSettings(settings));