[Page Load Metrics] PageLoadMetrics Mojofication.

chrome/renderer/page_load_metrics/page_timing_metrics_sender.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/page_timing_metrics_sender.h"
 
 #include <utility>
 
 #include "base/callback.h"
 #include "base/time/time.h"
 #include "base/timer/timer.h"
-#include "chrome/common/page_load_metrics/page_load_metrics_messages.h"
-#include "ipc/ipc_sender.h"
+#include "chrome/renderer/page_load_metrics/page_timing_sender.h"
 
 namespace page_load_metrics {
 
 namespace {
 const int kInitialTimerDelayMillis = 50;
 const int kTimerDelayMillis = 1000;
 }  // namespace
 
 PageTimingMetricsSender::PageTimingMetricsSender(
-    IPC::Sender* ipc_sender,
-    int routing_id,
+    std::unique_ptr<PageTimingSender> sender,
     std::unique_ptr<base::Timer> timer,
     mojom::PageLoadTimingPtr initial_timing)
-    : ipc_sender_(ipc_sender),
-      routing_id_(routing_id),
+    : sender_(std::move(sender)),
       timer_(std::move(timer)),
       last_timing_(std::move(initial_timing)),
-      metadata_(mojom::PageLoadMetadata()) {
+      metadata_(mojom::PageLoadMetadata::New()) {
   if (!IsEmpty(*last_timing_)) {
     EnsureSendTimer();
   }
 }
 
 // On destruction, we want to send any data we have if we have a timer
 // currently running (and thus are talking to a browser process)
 PageTimingMetricsSender::~PageTimingMetricsSender() {
   if (timer_->IsRunning()) {
     timer_->Stop();
     SendNow();
   }
 }
 
 void PageTimingMetricsSender::DidObserveLoadingBehavior(
     blink::WebLoadingBehaviorFlag behavior) {
-  if (behavior & metadata_.behavior_flags)
+  if (behavior & metadata_->behavior_flags)
     return;
-  metadata_.behavior_flags |= behavior;
+  metadata_->behavior_flags |= behavior;
   EnsureSendTimer();
 }
 
 void PageTimingMetricsSender::Send(mojom::PageLoadTimingPtr timing) {
   if (last_timing_->Equals(*timing))
     return;
 
   // We want to make sure that each PageTimingMetricsSender is associated
   // with a distinct page navigation. Because we reset the object on commit,
   // we can trash last_timing_ on a provisional load before SendNow() fires.
@@ skipping 13 matching lines @@
     int delay_ms =
         have_sent_ipc_ ? kTimerDelayMillis : kInitialTimerDelayMillis;
     timer_->Start(
         FROM_HERE, base::TimeDelta::FromMilliseconds(delay_ms),
         base::Bind(&PageTimingMetricsSender::SendNow, base::Unretained(this)));
   }
 }
 
 void PageTimingMetricsSender::SendNow() {
   have_sent_ipc_ = true;
-  ipc_sender_->Send(new PageLoadMetricsMsg_TimingUpdated(
-      routing_id_, *last_timing_, metadata_));
+  sender_->SendTiming(last_timing_, metadata_);
 }
 
 }  // namespace page_load_metrics