[Cronet] Pass metrics information from C++ BidirectionalStream to Java

components/cronet/android/cronet_url_request_adapter.cc

 // Copyright 2014 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 "components/cronet/android/cronet_url_request_adapter.h"
 
 #include <limits>
 #include <utility>
 #include <vector>
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "components/cronet/android/cronet_url_request_context_adapter.h"
 #include "components/cronet/android/io_buffer_with_byte_buffer.h"
+#include "components/cronet/android/metrics_util.h"
 #include "components/cronet/android/url_request_error.h"
 #include "jni/CronetUrlRequest_jni.h"
 #include "net/base/load_flags.h"
 #include "net/base/load_states.h"
 #include "net/base/net_errors.h"
 #include "net/base/request_priority.h"
 #include "net/cert/cert_status_flags.h"
 #include "net/http/http_response_headers.h"
 #include "net/http/http_status_code.h"
 #include "net/http/http_util.h"
 #include "net/proxy/proxy_server.h"
 #include "net/quic/core/quic_protocol.h"
 #include "net/ssl/ssl_info.h"
 #include "net/url_request/redirect_info.h"
 #include "net/url_request/url_request_context.h"
 
 using base::android::ConvertUTF8ToJavaString;
 using base::android::JavaParamRef;
 
 namespace cronet {
 
 namespace {
 
-// Converts timing metrics stored as TimeTicks into the format expected by the
-// Java layer: ms since Unix epoch, or -1 for null
-int64_t ConvertTime(const base::TimeTicks& ticks,
-                    const base::TimeTicks& start_ticks,
-                    const base::Time& start_time) {
-  if (ticks.is_null() || start_ticks.is_null()) {
-    return -1;
-  }
-  DCHECK(!start_time.is_null());
-  return (start_time + (ticks - start_ticks)).ToJavaTime();
-}
-
 // Returns the string representation of the HostPortPair of the proxy server
 // that was used to fetch the response.
 std::string GetProxy(const net::HttpResponseInfo& info) {
   if (!info.proxy_server.is_valid() || info.proxy_server.is_direct())
     return net::HostPortPair().ToString();
   return info.proxy_server.host_port_pair().ToString();
 }
 
 }  // namespace
 
@@ skipping 353 matching lines @@
 
 void CronetURLRequestAdapter::MaybeReportMetrics(JNIEnv* env) const {
   if (!enable_metrics_) {
     return;
   }
   net::LoadTimingInfo metrics;
   url_request_->GetLoadTimingInfo(&metrics);
   base::Time start_time = metrics.request_start_time;
   base::TimeTicks start_ticks = metrics.request_start;
   Java_CronetUrlRequest_onMetricsCollected(
-      env, owner_.obj(), ConvertTime(start_ticks, start_ticks, start_time),
-      ConvertTime(metrics.connect_timing.dns_start, start_ticks, start_time),
-      ConvertTime(metrics.connect_timing.dns_end, start_ticks, start_time),
-      ConvertTime(metrics.connect_timing.connect_start, start_ticks,
-                  start_time),
-      ConvertTime(metrics.connect_timing.connect_end, start_ticks, start_time),
-      ConvertTime(metrics.connect_timing.ssl_start, start_ticks, start_time),
-      ConvertTime(metrics.connect_timing.ssl_end, start_ticks, start_time),
-      ConvertTime(metrics.send_start, start_ticks, start_time),
-      ConvertTime(metrics.send_end, start_ticks, start_time),
-      ConvertTime(metrics.push_start, start_ticks, start_time),
-      ConvertTime(metrics.push_end, start_ticks, start_time),
-      ConvertTime(metrics.receive_headers_end, start_ticks, start_time),
-      ConvertTime(base::TimeTicks::Now(), start_ticks, start_time),
+      env, owner_.obj(),
+      metrics_util::ConvertTime(start_ticks, start_ticks, start_time),
+      metrics_util::ConvertTime(metrics.connect_timing.dns_start, start_ticks,
+                                start_time),
+      metrics_util::ConvertTime(metrics.connect_timing.dns_end, start_ticks,
+                                start_time),
+      metrics_util::ConvertTime(metrics.connect_timing.connect_start,
+                                start_ticks, start_time),
+      metrics_util::ConvertTime(metrics.connect_timing.connect_end, start_ticks,
+                                start_time),
+      metrics_util::ConvertTime(metrics.connect_timing.ssl_start, start_ticks,
+                                start_time),
+      metrics_util::ConvertTime(metrics.connect_timing.ssl_end, start_ticks,
+                                start_time),
+      metrics_util::ConvertTime(metrics.send_start, start_ticks, start_time),
+      metrics_util::ConvertTime(metrics.send_end, start_ticks, start_time),
+      metrics_util::ConvertTime(metrics.push_start, start_ticks, start_time),
+      metrics_util::ConvertTime(metrics.push_end, start_ticks, start_time),
+      metrics_util::ConvertTime(metrics.receive_headers_end, start_ticks,
+                                start_time),
+      metrics_util::ConvertTime(base::TimeTicks::Now(), start_ticks,
+                                start_time),
       metrics.socket_reused, url_request_->GetTotalSentBytes(),
       url_request_->GetTotalReceivedBytes());
 }
 
 net::URLRequest* CronetURLRequestAdapter::GetURLRequestForTesting() {
   return url_request_.get();
 }
 
 }  // namespace cronet