Reporting: Implement serializer.

net/reporting/reporting_context.cc

 // Copyright 2017 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/reporting/reporting_context.h"
 
 #include <memory>
 
 #include "base/memory/ptr_util.h"
 #include "base/observer_list.h"
 #include "base/time/clock.h"
 #include "base/time/default_clock.h"
 #include "base/time/default_tick_clock.h"
 #include "base/time/tick_clock.h"
 #include "base/time/time.h"
+#include "base/timer/timer.h"
 #include "net/base/backoff_entry.h"
 #include "net/reporting/reporting_cache.h"
 #include "net/reporting/reporting_delegate.h"
 #include "net/reporting/reporting_delivery_agent.h"
 #include "net/reporting/reporting_endpoint_manager.h"
 #include "net/reporting/reporting_observer.h"
+#include "net/reporting/reporting_persister.h"
 #include "net/reporting/reporting_policy.h"
 
 namespace net {
 
 class URLRequestContext;
 
 namespace {
 
 class ReportingContextImpl : public ReportingContext {
  public:
@@ skipping 13 matching lines @@
 std::unique_ptr<ReportingContext> ReportingContext::Create(
     const ReportingPolicy& policy,
     std::unique_ptr<ReportingDelegate> delegate,
     URLRequestContext* request_context) {
   return base::MakeUnique<ReportingContextImpl>(policy, std::move(delegate),
                                                 request_context);
 }
 
 ReportingContext::~ReportingContext() {}
 
+void ReportingContext::Initialize() {
+  DCHECK(!initialized_);
+
+  for (auto& observer : observers_)
+    observer.OnContextInitializing();
+
+  initialized_ = true;
+
+  for (auto& observer : observers_)
+    observer.OnContextInitialized();
+}
+
 void ReportingContext::AddObserver(ReportingObserver* observer) {
   DCHECK(!observers_.HasObserver(observer));
   observers_.AddObserver(observer);
 }
 
 void ReportingContext::RemoveObserver(ReportingObserver* observer) {
   DCHECK(observers_.HasObserver(observer));
   observers_.RemoveObserver(observer);
 }
 
 void ReportingContext::NotifyCacheUpdated() {
+  if (!initialized_)
+    return;
+
   for (auto& observer : observers_)
     observer.OnCacheUpdated();
 }
 
 ReportingContext::ReportingContext(const ReportingPolicy& policy,
                                    std::unique_ptr<ReportingDelegate> delegate,
                                    std::unique_ptr<base::Clock> clock,
                                    std::unique_ptr<base::TickClock> tick_clock,
                                    std::unique_ptr<ReportingUploader> uploader)
     : policy_(policy),
       delegate_(std::move(delegate)),
       clock_(std::move(clock)),
       tick_clock_(std::move(tick_clock)),
       uploader_(std::move(uploader)),
+      initialized_(false),
       cache_(base::MakeUnique<ReportingCache>(this)),
       endpoint_manager_(base::MakeUnique<ReportingEndpointManager>(this)),
-      delivery_agent_(base::MakeUnique<ReportingDeliveryAgent>(this)) {}
+      delivery_agent_(base::MakeUnique<ReportingDeliveryAgent>(this)),
+      persister_(ReportingPersister::Create(this)) {}
 
 }  // namespace net