Move HttpStreamFactoryImpl::JobController UMA to a schedule upload

net/http/http_stream_factory_impl_unittest.cc

 // 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.
 
 #include "net/http/http_stream_factory_impl.h"
 
 #include <stdint.h>
 
 #include <memory>
 #include <string>
@@ skipping 1300 matching lines @@
         histogram_tester.ExpectUniqueSample(
             "Net.PreconnectSkippedToProxyServers", 1, 1);
       } else {
         histogram_tester.ExpectTotalCount("Net.PreconnectSkippedToProxyServers",
                                           0);
       }
     }
   }
 }
 
+TEST_F(HttpStreamFactoryTest, OnMetricsFinalizeTest) {
+  base::HistogramTester histogram_tester;
+  // Make the request hang.
+  MockRead reads[] = {MockRead(SYNCHRONOUS, ERR_IO_PENDING)};
+  SequencedSocketData data(reads, arraysize(reads), nullptr, 0);
+  SpdySessionDependencies session_deps;
+  session_deps.socket_factory->AddSocketDataProvider(&data);
+  HttpNetworkSession::Params params =
+      SpdySessionDependencies::CreateSessionParams(&session_deps);
+  std::unique_ptr<HttpNetworkSession> session(new HttpNetworkSession(params));
+  HttpRequestInfo request_info;
+  request_info.method = "GET";
+  request_info.url = GURL("http://www.example.com");
+  SSLConfig ssl_config;
+  StreamRequestWaiter waiter;
+  std::unique_ptr<HttpStreamRequest> request(
+      session->http_stream_factory()->RequestStream(
+          request_info, DEFAULT_PRIORITY, ssl_config, ssl_config, &waiter,
+          /* enable_ip_based_pooling = */ true,
+          /* enable_alternative_services = */ true, NetLogWithSource()));
+  NetworkChangeNotifier::FinalizingMetricsLogRecord();
+  // Notification is asynchronous.
+  base::RunLoop().RunUntilIdle();
+  // There are two HttpStreamFactoryImpl in HttpNetworkSession
+  // (|http_stream_factory_| and |http_stream_factory_for_websocket_|), so there
+  // will be two samples logged per FinalizingMetricsLogRecord().
+  histogram_tester.ExpectBucketCount("Net.JobControllerSet.CountOfPreconnect",
+                                     0, 2);
+  histogram_tester.ExpectBucketCount(
+      "Net.JobControllerSet.CountOfNonPreconnectAltJob", 0, 2);
+  histogram_tester.ExpectBucketCount(
+      "Net.JobControllerSet.CountOfNonPreconnectMainJob", 0, 1);
+  // HttpNetworkSession's |http_stream_factory_| reports 1 count to 1 bucket.
+  histogram_tester.ExpectBucketCount(
+      "Net.JobControllerSet.CountOfNonPreconnectMainJob", 1, 1);
+}
+
 // Verify that preconnect to a HTTP2 proxy server with a privacy mode different
 // than that of the in-flight preconnect job succeeds.
 TEST_F(HttpStreamFactoryTest, ProxyServerPreconnectDifferentPrivacyModes) {
   int num_streams = 1;
   base::HistogramTester histogram_tester;
   GURL url = GURL("http://www.google.com");
   std::unique_ptr<ProxyService> proxy_service =
       ProxyService::CreateFixedFromPacResult("HTTPS myproxy.org:443");
 
   // Set up the proxy server as a server that supports request priorities.
@@ skipping 1432 matching lines @@
       session->GetTransportSocketPool(
           HttpNetworkSession::WEBSOCKET_SOCKET_POOL)));
   EXPECT_EQ(1, GetSocketPoolGroupCount(
       session->GetSSLSocketPool(HttpNetworkSession::WEBSOCKET_SOCKET_POOL)));
   EXPECT_TRUE(waiter.used_proxy_info().is_direct());
 }
 
 }  // namespace
 
 }  // namespace net