[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/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();
-}
-
-}  // namespace
-
 // Explicitly register static JNI functions.
 bool CronetUrlRequestAdapterRegisterJni(JNIEnv* env) {
   return RegisterNativesImpl(env);
 }
 
 static jlong CreateRequestAdapter(JNIEnv* env,
                                   const JavaParamRef<jobject>& jurl_request,
                                   jlong jurl_request_context_adapter,
                                   const JavaParamRef<jstring>& jurl_string,
                                   jint jpriority,
@@ skipping 347 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(),
+      MetricsUtil::ConvertTime(start_ticks, start_ticks, start_time),
+      MetricsUtil::ConvertTime(metrics.connect_timing.dns_start, start_ticks,
+                               start_time),
+      MetricsUtil::ConvertTime(metrics.connect_timing.dns_end, start_ticks,
+                               start_time),
+      MetricsUtil::ConvertTime(metrics.connect_timing.connect_start,
+                               start_ticks, start_time),
+      MetricsUtil::ConvertTime(metrics.connect_timing.connect_end, start_ticks,
+                               start_time),
+      MetricsUtil::ConvertTime(metrics.connect_timing.ssl_start, start_ticks,
+                               start_time),
+      MetricsUtil::ConvertTime(metrics.connect_timing.ssl_end, start_ticks,
+                               start_time),
+      MetricsUtil::ConvertTime(metrics.send_start, start_ticks, start_time),
+      MetricsUtil::ConvertTime(metrics.send_end, start_ticks, start_time),
+      MetricsUtil::ConvertTime(metrics.push_start, start_ticks, start_time),
+      MetricsUtil::ConvertTime(metrics.push_end, start_ticks, start_time),
+      MetricsUtil::ConvertTime(metrics.receive_headers_end, start_ticks,
+                               start_time),
+      MetricsUtil::ConvertTime(base::TimeTicks::Now(), start_ticks, start_time),
       // TODO(mgersh): report total bytes sent
       metrics.socket_reused, 0, url_request_->GetTotalReceivedBytes());
 }
 
 net::URLRequest* CronetURLRequestAdapter::GetURLRequestForTesting() {
   return url_request_.get();
 }
 
 }  // namespace cronet