Add a way to send the resource percentage signal to the RC.

components/offline_pages/core/background/request_coordinator.h

 // Copyright 2016 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.
 
 #ifndef COMPONENTS_OFFLINE_PAGES_CORE_BACKGROUND_REQUEST_COORDINATOR_H_
 #define COMPONENTS_OFFLINE_PAGES_CORE_BACKGROUND_REQUEST_COORDINATOR_H_
 
 #include <memory>
 #include <set>
 #include <string>
 #include <vector>
 
 #include "base/callback.h"
 #include "base/macros.h"
 #include "base/memory/weak_ptr.h"
 #include "base/observer_list.h"
 #include "base/supports_user_data.h"
 #include "base/time/time.h"
 #include "base/timer/timer.h"
 #include "components/keyed_service/core/keyed_service.h"
 #include "components/offline_pages/core/background/connection_notifier.h"
 #include "components/offline_pages/core/background/device_conditions.h"
 #include "components/offline_pages/core/background/request_coordinator_event_logger.h"
 #include "components/offline_pages/core/background/request_notifier.h"
 #include "components/offline_pages/core/background/request_queue.h"
+#include "components/offline_pages/core/background/resource_data_type.h"
+#include "components/offline_pages/core/background/resource_tracker_observer.h"
 #include "components/offline_pages/core/background/scheduler.h"
 #include "net/nqe/network_quality_estimator.h"
 #include "url/gurl.h"
 
 namespace offline_pages {
 
 struct ClientId;
 class OfflinerPolicy;
 class Offliner;
 class SavePageRequest;
 class ClientPolicyController;
 
 // Coordinates queueing and processing save page later requests.
 class RequestCoordinator : public KeyedService,
                            public RequestNotifier,
-                           public base::SupportsUserData {
+                           public base::SupportsUserData,
+                           public ResourceTrackerObserver {
  public:
   // Nested observer class.  To make sure that no events are missed, the client
   // code should first register for notifications, then |GetAllRequests|, and
   // ignore all events before the return from |GetAllRequests|, and consume
   // events after the return callback from |GetAllRequests|.
   class Observer {
    public:
     virtual ~Observer() = default;
 
     virtual void OnAdded(const SavePageRequest& request) = 0;
@@ skipping 122 matching lines @@
   // A way to set the callback which would be called if processing will be
   // triggered immediately internally by the coordinator. Used by testing
   // harness to determine if a request has been processed.
   void SetInternalStartProcessingCallbackForTest(
       const base::Callback<void(bool)> callback) {
     internal_start_processing_callback_ = callback;
   }
 
   void StartImmediatelyForTest() { StartImmediatelyIfConnected(); }
 
+  // Implementation of ResourceTrackerObserver interface
+  // When we are notified of a resource load starting or ending, pass the
+  // information along to the offliner.
+  void ObserveResourceTracking(const ResourceDataType type,
+                               int64_t started_count,
+                               int64_t completed_count) override;
+
   // Observers implementing the RequestCoordinator::Observer interface can
   // register here to get notifications of changes to request state.  This
   // pointer is not owned, and it is the callers responsibility to remove the
   // observer before the observer is deleted.
   void AddObserver(RequestCoordinator::Observer* observer);
 
   void RemoveObserver(RequestCoordinator::Observer* observer);
 
   // Implement RequestNotifier
   void NotifyAdded(const SavePageRequest& request) override;
@@ skipping 284 matching lines @@
   std::deque<int64_t> prioritized_requests_;
   // Allows us to pass a weak pointer to callbacks.
   base::WeakPtrFactory<RequestCoordinator> weak_ptr_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(RequestCoordinator);
 };
 
 }  // namespace offline_pages
 
 #endif  // COMPONENTS_OFFLINE_PAGES_CORE_BACKGROUND_REQUEST_COORDINATOR_H_