Move over another legacy "LoadLog-style" event generator to routing its messa...

chrome/browser/net/passive_log_collector.cc

 // Copyright (c) 2010 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/net/passive_log_collector.h"
 
 #include <algorithm>
 
 #include "base/string_util.h"
 #include "chrome/browser/chrome_thread.h"
@@ skipping 47 matching lines @@
   switch (entry.source.type) {
     case net::NetLog::SOURCE_URL_REQUEST:
       url_request_tracker_.OnAddEntry(entry);
       break;
     case net::NetLog::SOURCE_SOCKET_STREAM:
       socket_stream_tracker_.OnAddEntry(entry);
       break;
     case net::NetLog::SOURCE_CONNECT_JOB:
       connect_job_tracker_.OnAddEntry(entry);
       break;
+    case net::NetLog::SOURCE_INIT_PROXY_RESOLVER:
+      init_proxy_resolver_tracker_.OnAddEntry(entry);
+      break;
     default:
       // Drop all other logged events.
       break;
   }
 }
 
 void PassiveLogCollector::Clear() {
   connect_job_tracker_.Clear();
   url_request_tracker_.Clear();
   socket_stream_tracker_.Clear();
@@ skipping 231 matching lines @@
     AppendToRequestInfo(*connect_job_info, is_unbounded(), live_entry);
   } else {
     // If we couldn't find the information for the ConnectJob, append a
     // generic message instead.
     net::NetLog::Entry e(entry);
     e.type = net::NetLog::Entry::TYPE_STRING;
     e.string = StringPrintf("Used ConnectJob id=%d", connect_job_id);
     AddEntryToRequestInfo(e, is_unbounded(), live_entry);
   }
 }
+
+//----------------------------------------------------------------------------
+// InitProxyResolverTracker
+//----------------------------------------------------------------------------
+
+PassiveLogCollector::InitProxyResolverTracker::InitProxyResolverTracker() {}
+
+void PassiveLogCollector::InitProxyResolverTracker::OnAddEntry(
+    const net::NetLog::Entry& entry) {
+  if (entry.type == net::NetLog::Entry::TYPE_EVENT &&
+      entry.event.type == net::NetLog::TYPE_INIT_PROXY_RESOLVER &&
+      entry.event.phase == net::NetLog::PHASE_BEGIN) {
+    // If this is the start of a new InitProxyResolver, overwrite the old data.
+    entries_.clear();
+    entries_.push_back(entry);
+  } else {
+    // Otherwise append it to the log for the latest InitProxyResolver.
+    if (!entries_.empty() && entries_[0].source.id != entry.source.id) {
+      // If this entry doesn't match what we think was the latest
+      // InitProxyResolver, drop it. (This shouldn't happen, but we will guard
+      // against it).
+      return;
+    }
+    entries_.push_back(entry);
+  }
+
+  // Safety net: INIT_PROXY_RESOLVER shouldn't generate many messages, but in
+  // case something goes wrong, avoid exploding the memory usage.
+  if (entries_.size() > kMaxNumEntriesPerLog)
+    entries_.clear();
+}
+