Add function to get network stack state from a URLRequestContext.

chrome/browser/resources/net_internals/browser_bridge.js

 // Copyright (c) 2012 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.
 
+// Populated by constants from the browser.  Used only by this file.
+var NetInfoSources = null;
+
 /**
  * This class provides a "bridge" for communicating between the javascript and
  * the browser.
  */
 var BrowserBridge = (function() {
   'use strict';
 
   /**
    * Delay in milliseconds between updates of certain browser information.
    */
@@ skipping 11 matching lines @@
     this.constantsObservers_ = [];
     this.crosONCFileParseObservers_ = [];
     this.storeDebugLogsObservers_ = [];
     this.setNetworkDebugModeObservers_ = [];
     // Unprocessed data received before the constants.  This serves to protect
     // against passing along data before having information on how to interpret
     // it.
     this.earlyReceivedData_ = [];
 
     this.pollableDataHelpers_ = {};
-    this.pollableDataHelpers_.proxySettings =
-        new PollableDataHelper('onProxySettingsChanged',
-                               this.sendGetProxySettings.bind(this));
-    this.pollableDataHelpers_.badProxies =
-        new PollableDataHelper('onBadProxiesChanged',
-                               this.sendGetBadProxies.bind(this));
-    this.pollableDataHelpers_.httpCacheInfo =
-        new PollableDataHelper('onHttpCacheInfoChanged',
-                               this.sendGetHttpCacheInfo.bind(this));
-    this.pollableDataHelpers_.hostResolverInfo =
-        new PollableDataHelper('onHostResolverInfoChanged',
-                               this.sendGetHostResolverInfo.bind(this));
-    this.pollableDataHelpers_.socketPoolInfo =
-        new PollableDataHelper('onSocketPoolInfoChanged',
-                               this.sendGetSocketPoolInfo.bind(this));
+
+    // Add PollableDataHelpers for NetInfoSources, which retrieve information
+    // directly from the network stack.
+    this.addNetInfoPollableDataHelper('proxySettings',
+                                      'onProxySettingsChanged');
+    this.addNetInfoPollableDataHelper('badProxies', 'onBadProxiesChanged');
+    this.addNetInfoPollableDataHelper('hostResolverInfo',
+                                      'onHostResolverInfoChanged');
+    this.addNetInfoPollableDataHelper('socketPoolInfo',
+                                      'onSocketPoolInfoChanged');
+    this.addNetInfoPollableDataHelper('spdySessionInfo',
+                                      'onSpdySessionInfoChanged');
+    this.addNetInfoPollableDataHelper('spdyStatus', 'onSpdyStatusChanged');
+    this.addNetInfoPollableDataHelper('spdyAlternateProtocolMappings',
+                                      'onSpdyAlternateProtocolMappingsChanged');
+    this.addNetInfoPollableDataHelper('quicInfo', 'onQuicInfoChanged');
+    this.addNetInfoPollableDataHelper('httpCacheInfo',
+                                      'onHttpCacheInfoChanged');
+
+    // Add other PollableDataHelpers.
     this.pollableDataHelpers_.sessionNetworkStats =
-      new PollableDataHelper('onSessionNetworkStatsChanged',
-                             this.sendGetSessionNetworkStats.bind(this));
+        new PollableDataHelper('onSessionNetworkStatsChanged',
+                               this.sendGetSessionNetworkStats.bind(this));
     this.pollableDataHelpers_.historicNetworkStats =
-      new PollableDataHelper('onHistoricNetworkStatsChanged',
-                             this.sendGetHistoricNetworkStats.bind(this));
-    this.pollableDataHelpers_.quicInfo =
-        new PollableDataHelper('onQuicInfoChanged',
-                               this.sendGetQuicInfo.bind(this));
-    this.pollableDataHelpers_.spdySessionInfo =
-        new PollableDataHelper('onSpdySessionInfoChanged',
-                               this.sendGetSpdySessionInfo.bind(this));
-    this.pollableDataHelpers_.spdyStatus =
-        new PollableDataHelper('onSpdyStatusChanged',
-                               this.sendGetSpdyStatus.bind(this));
-    this.pollableDataHelpers_.spdyAlternateProtocolMappings =
-        new PollableDataHelper('onSpdyAlternateProtocolMappingsChanged',
-                               this.sendGetSpdyAlternateProtocolMappings.bind(
-                                   this));
+        new PollableDataHelper('onHistoricNetworkStatsChanged',
+                               this.sendGetHistoricNetworkStats.bind(this));
     if (cr.isWindows) {
       this.pollableDataHelpers_.serviceProviders =
           new PollableDataHelper('onServiceProvidersChanged',
                                  this.sendGetServiceProviders.bind(this));
     }
     this.pollableDataHelpers_.prerenderInfo =
         new PollableDataHelper('onPrerenderInfoChanged',
                                this.sendGetPrerenderInfo.bind(this));
     this.pollableDataHelpers_.extensionInfo =
         new PollableDataHelper('onExtensionInfoChanged',
@@ skipping 53 matching lines @@
         this.pollIntervalId_ = null;
       }
 
       if (intervalMs > 0) {
         this.pollIntervalId_ =
             window.setInterval(this.checkForUpdatedInfo.bind(this, false),
                                intervalMs);
       }
     },
 
-    sendGetProxySettings: function() {
-      // The browser will call receivedProxySettings on completion.
-      this.send('getProxySettings');
+    sendGetNetInfo: function(netInfoSource) {
+      // If don't have constants yet, don't do anything yet.
+      if (NetInfoSources)
+        this.send('getNetInfo', [NetInfoSources[netInfoSource]]);
     },
 
     sendReloadProxySettings: function() {
       this.send('reloadProxySettings');
     },
 
-    sendGetBadProxies: function() {
-      // The browser will call receivedBadProxies on completion.
-      this.send('getBadProxies');
-    },
-
-    sendGetHostResolverInfo: function() {
-      // The browser will call receivedHostResolverInfo on completion.
-      this.send('getHostResolverInfo');
-    },
-
     sendClearBadProxies: function() {
       this.send('clearBadProxies');
     },
 
     sendClearHostResolverCache: function() {
       this.send('clearHostResolverCache');
     },
 
     sendClearBrowserCache: function() {
       this.send('clearBrowserCache');
@@ skipping 15 matching lines @@
     sendHSTSAdd: function(domain, sts_include_subdomains,
                           pkp_include_subdomains, pins) {
       this.send('hstsAdd', [domain, sts_include_subdomains,
                             pkp_include_subdomains, pins]);
     },
 
     sendHSTSDelete: function(domain) {
       this.send('hstsDelete', [domain]);
     },
 
-    sendGetHttpCacheInfo: function() {
-      this.send('getHttpCacheInfo');
-    },
-
-    sendGetSocketPoolInfo: function() {
-      this.send('getSocketPoolInfo');
-    },
-
     sendGetSessionNetworkStats: function() {
       this.send('getSessionNetworkStats');
     },
 
     sendGetHistoricNetworkStats: function() {
       this.send('getHistoricNetworkStats');
     },
 
     sendCloseIdleSockets: function() {
       this.send('closeIdleSockets');
     },
 
     sendFlushSocketPools: function() {
       this.send('flushSocketPools');
     },
 
-    sendGetQuicInfo: function() {
-      this.send('getQuicInfo');
-    },
-
-    sendGetSpdySessionInfo: function() {
-      this.send('getSpdySessionInfo');
-    },
-
-    sendGetSpdyStatus: function() {
-      this.send('getSpdyStatus');
-    },
-
-    sendGetSpdyAlternateProtocolMappings: function() {
-      this.send('getSpdyAlternateProtocolMappings');
-    },
-
     sendGetServiceProviders: function() {
       this.send('getServiceProviders');
     },
 
     sendGetPrerenderInfo: function() {
       this.send('getPrerenderInfo');
     },
 
     sendGetExtensionInfo: function() {
       this.send('getExtensionInfo');
@@ skipping 50 matching lines @@
       if (this.earlyReceivedData_ != null) {
         for (var i = 0; i < this.earlyReceivedData_.length; i++) {
           var command = this.earlyReceivedData_[i];
           this[command.command](command.params);
         }
         this.earlyReceivedData_ = null;
       }
     },
 
     receivedConstants: function(constants) {
+      NetInfoSources = constants.netInfoSources;
       for (var i = 0; i < this.constantsObservers_.length; i++)
         this.constantsObservers_[i].onReceivedConstants(constants);
+      // May have been waiting for the constants to be received before getting
+      // information for the currently displayed tab.
+      this.checkForUpdatedInfo();
     },
 
     receivedLogEntries: function(logEntries) {
       EventsTracker.getInstance().addLogEntries(logEntries);
     },
 
-    receivedProxySettings: function(proxySettings) {
-      this.pollableDataHelpers_.proxySettings.update(proxySettings);
-    },
-
-    receivedBadProxies: function(badProxies) {
-      this.pollableDataHelpers_.badProxies.update(badProxies);
-    },
-
-    receivedHostResolverInfo: function(hostResolverInfo) {
-      this.pollableDataHelpers_.hostResolverInfo.update(hostResolverInfo);
-    },
-
-    receivedSocketPoolInfo: function(socketPoolInfo) {
-      this.pollableDataHelpers_.socketPoolInfo.update(socketPoolInfo);
+    receivedNetInfo: function(netInfo) {
+      // Dispatch |netInfo| to the various PollableDataHelpers listening to
+      // each field it contains.
+      //
+      // Currently information is only received from one source at a time, but
+      // the API does allow for data from more that one to be requested at once.
+      for (var source in netInfo)
+        this.pollableDataHelpers_[source].update(netInfo[source]);
     },
 
     receivedSessionNetworkStats: function(sessionNetworkStats) {
       this.pollableDataHelpers_.sessionNetworkStats.update(sessionNetworkStats);
     },
 
     receivedHistoricNetworkStats: function(historicNetworkStats) {
       this.pollableDataHelpers_.historicNetworkStats.update(
           historicNetworkStats);
     },
 
-    receivedQuicInfo: function(quicInfo) {
-      this.pollableDataHelpers_.quicInfo.update(quicInfo);
-    },
-
-    receivedSpdySessionInfo: function(spdySessionInfo) {
-      this.pollableDataHelpers_.spdySessionInfo.update(spdySessionInfo);
-    },
-
-    receivedSpdyStatus: function(spdyStatus) {
-      this.pollableDataHelpers_.spdyStatus.update(spdyStatus);
-    },
-
-    receivedSpdyAlternateProtocolMappings:
-        function(spdyAlternateProtocolMappings) {
-      this.pollableDataHelpers_.spdyAlternateProtocolMappings.update(
-          spdyAlternateProtocolMappings);
-    },
-
     receivedServiceProviders: function(serviceProviders) {
       this.pollableDataHelpers_.serviceProviders.update(serviceProviders);
     },
 
     receivedStartConnectionTestSuite: function() {
       for (var i = 0; i < this.connectionTestsObservers_.length; i++)
         this.connectionTestsObservers_[i].onStartedConnectionTestSuite();
     },
 
     receivedStartConnectionTestExperiment: function(experiment) {
@@ skipping 28 matching lines @@
     receivedStoreDebugLogs: function(status) {
       for (var i = 0; i < this.storeDebugLogsObservers_.length; i++)
         this.storeDebugLogsObservers_[i].onStoreDebugLogs(status);
     },
 
     receivedSetNetworkDebugMode: function(status) {
       for (var i = 0; i < this.setNetworkDebugModeObservers_.length; i++)
         this.setNetworkDebugModeObservers_[i].onSetNetworkDebugMode(status);
     },
 
-    receivedHttpCacheInfo: function(info) {
-      this.pollableDataHelpers_.httpCacheInfo.update(info);
-    },
-
     receivedPrerenderInfo: function(prerenderInfo) {
       this.pollableDataHelpers_.prerenderInfo.update(prerenderInfo);
     },
 
     receivedExtensionInfo: function(extensionInfo) {
       this.pollableDataHelpers_.extensionInfo.update(extensionInfo);
     },
 
     getSystemLogCallback: function(systemLog) {
       this.pollableDataHelpers_.systemLog.update(systemLog);
@@ skipping 285 matching lines @@
     },
 
     /**
      * Calls all startUpdate functions and, if |callback| is non-null,
      * calls it with the results of all updates.
      */
     updateAllInfo: function(callback) {
       if (callback)
         new UpdateAllObserver(callback, this.pollableDataHelpers_);
       this.checkForUpdatedInfo(true);
-    }
+    },
+
+    /**
+     * Adds a PollableDataHelper that listens to the specified NetInfoSource.
+     */
+    addNetInfoPollableDataHelper: function(sourceName, observerMethodName) {
+      this.pollableDataHelpers_[sourceName] = new PollableDataHelper(
+          observerMethodName, this.sendGetNetInfo.bind(this, sourceName));
+    },
   };
 
   /**
    * This is a helper class used by BrowserBridge, to keep track of:
    *   - the list of observers interested in some piece of data.
    *   - the last known value of that piece of data.
    *   - the name of the callback method to invoke on observers.
    *   - the update function.
    * @constructor
    */
@@ skipping 119 matching lines @@
       helper.removeObserver(this);
       --this.observingCount_;
       this.updatedData_[name] = data;
       if (this.observingCount_ == 0)
         this.callback_(this.updatedData_);
     }
   };
 
   return BrowserBridge;
 })();