[Page Load Metrics] PageLoadMetrics Mojofication.

chrome/renderer/page_load_metrics/metrics_render_frame_observer.cc

 // Copyright 2015 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/renderer/page_load_metrics/metrics_render_frame_observer.h"
 
 #include <string>
 
+#include "base/feature_list.h"
 #include "base/memory/ptr_util.h"
 #include "base/time/time.h"
 #include "base/timer/timer.h"
+#include "chrome/common/chrome_features.h"
+#include "chrome/common/page_load_metrics/page_load_metrics_messages.h"
 #include "chrome/renderer/page_load_metrics/page_timing_metrics_sender.h"
+#include "chrome/renderer/page_load_metrics/page_timing_sender.h"
 #include "chrome/renderer/page_load_metrics/renderer_page_track_decider.h"
 #include "chrome/renderer/searchbox/search_bouncer.h"
+#include "content/public/common/associated_interface_provider.h"
 #include "content/public/renderer/render_frame.h"
 #include "third_party/WebKit/public/web/WebDataSource.h"
 #include "third_party/WebKit/public/web/WebDocument.h"
 #include "third_party/WebKit/public/web/WebLocalFrame.h"
 #include "third_party/WebKit/public/web/WebPerformance.h"
 #include "url/gurl.h"
 
 namespace page_load_metrics {
 
 namespace {
 
 base::TimeDelta ClampDelta(double event, double start) {
   if (event - start < 0)
     event = start;
   return base::Time::FromDoubleT(event) - base::Time::FromDoubleT(start);
 }
 
+class LegacyIPCPageTimingSender : public PageTimingSender {
+ public:
+  LegacyIPCPageTimingSender(content::RenderFrame* render_frame,
+                            const int routing_id)
+      : render_frame_(render_frame), routing_id_(routing_id) {}
+  ~LegacyIPCPageTimingSender() override {}
+
+  void SendTiming(const mojom::PageLoadTimingPtr& timing,
+                  const mojom::PageLoadMetadataPtr& metadata) override {
+    DCHECK(render_frame_);
+    render_frame_->Send(
+        new PageLoadMetricsMsg_TimingUpdated(routing_id_, *timing, *metadata));
+  }
+
+ private:
+  content::RenderFrame* const render_frame_;

[Bryan McQuade, 2017/05/20 00:29:46]

ah, thanks, it's been a while - you got the const placement right here. :)

+  const int routing_id_;
+};
+
+class MojoIPCPageTimingSender : public PageTimingSender {
+ public:
+  explicit MojoIPCPageTimingSender(content::RenderFrame* render_frame) {
+    DCHECK(render_frame);
+    render_frame->GetRemoteAssociatedInterfaces()->GetInterface(
+        &page_load_metrics_);
+  }
+  ~MojoIPCPageTimingSender() override {}
+  void SendTiming(const mojom::PageLoadTimingPtr& timing,
+                  const mojom::PageLoadMetadataPtr& metadata) override {
+    DCHECK(page_load_metrics_);
+    page_load_metrics_->UpdateTiming(timing->Clone(), metadata->Clone());
+  }
+
+ private:
+  // Use associated interface to make sure mojo messages are ordered with regard
+  // to legacy IPC messages.
+  mojom::PageLoadMetricsAssociatedPtr page_load_metrics_;
+};
+
 }  //  namespace
 
 MetricsRenderFrameObserver::MetricsRenderFrameObserver(
     content::RenderFrame* render_frame)
     : content::RenderFrameObserver(render_frame) {}
 
 MetricsRenderFrameObserver::~MetricsRenderFrameObserver() {}
 
 void MetricsRenderFrameObserver::DidChangePerformanceTiming() {
   SendMetrics();
@@ skipping 22 matching lines @@
 
   // Make sure to release the sender for a previous navigation, if we have one.
   page_timing_metrics_sender_.reset();
 
   // We only create a PageTimingMetricsSender if the page meets the criteria for
   // sending and recording metrics. Once page_timing_metrics_sender_ is
   // non-null, we will send metrics for the current page at some later time, as
   // those metrics become available.
   if (ShouldSendMetrics()) {
     page_timing_metrics_sender_ = base::MakeUnique<PageTimingMetricsSender>(
-        this, routing_id(), CreateTimer(), GetTiming());
+        CreatePageTimingSender(), CreateTimer(), GetTiming());
   }
 }
 
 void MetricsRenderFrameObserver::SendMetrics() {
   if (!page_timing_metrics_sender_)
     return;
   if (HasNoRenderFrame())
     return;
   page_timing_metrics_sender_->Send(GetTiming());
 }
@@ skipping 75 matching lines @@
     timing->style_sheet_timing->update_style_duration_before_fcp =
         base::TimeDelta::FromSecondsD(perf.UpdateStyleDurationBeforeFCP());
   }
   return timing;
 }
 
 std::unique_ptr<base::Timer> MetricsRenderFrameObserver::CreateTimer() const {
   return base::WrapUnique(new base::OneShotTimer);
 }
 
+std::unique_ptr<PageTimingSender>
+MetricsRenderFrameObserver::CreatePageTimingSender() {
+  if (base::FeatureList::IsEnabled(features::kPageLoadMetricsMojofication)) {
+    return base::WrapUnique<PageTimingSender>(
+        new MojoIPCPageTimingSender(render_frame()));
+  }
+  return base::WrapUnique<PageTimingSender>(
+      new LegacyIPCPageTimingSender(render_frame(), routing_id()));
+}
+
 bool MetricsRenderFrameObserver::HasNoRenderFrame() const {
   bool no_frame = !render_frame() || !render_frame()->GetWebFrame();
   DCHECK(!no_frame);
   return no_frame;
 }
 
 void MetricsRenderFrameObserver::OnDestruct() {
   delete this;
 }
 
 }  // namespace page_load_metrics