Send traffic-management headers from extension updater.

extensions/browser/updater/extension_downloader.h

 // Copyright (c) 2012 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 EXTENSIONS_BROWSER_UPDATER_EXTENSION_DOWNLOADER_H_
 #define EXTENSIONS_BROWSER_UPDATER_EXTENSION_DOWNLOADER_H_
 
 #include <deque>
 #include <map>
 #include <memory>
@@ skipping 54 matching lines @@
   // ExtensionDownloader.
   ExtensionDownloader(ExtensionDownloaderDelegate* delegate,
                       net::URLRequestContextGetter* request_context);
   ~ExtensionDownloader() override;
 
   // Adds |extension| to the list of extensions to check for updates.
   // Returns false if the |extension| can't be updated due to invalid details.
   // In that case, no callbacks will be performed on the |delegate_|.
   // The |request_id| is passed on as is to the various |delegate_| callbacks.
   // This is used for example by ExtensionUpdater to keep track of when
-  // potentially concurrent update checks complete.
-  bool AddExtension(const Extension& extension, int request_id);
+  // potentially concurrent update checks complete. |fetch_priority|
+  // parameter notifies the downloader the priority of this extension update
+  // (either foreground or background).
+  bool AddExtension(const Extension& extension,
+                    int request_id,
+                    ManifestFetchData::FetchPriority fetch_priority);
 
   // Adds extension |id| to the list of extensions to check for updates.
   // Returns false if the |id| can't be updated due to invalid details.
   // In that case, no callbacks will be performed on the |delegate_|.
   // The |request_id| is passed on as is to the various |delegate_| callbacks.
   // This is used for example by ExtensionUpdater to keep track of when
   // potentially concurrent update checks complete. The |is_corrupt_reinstall|
   // parameter is used to indicate in the request that we detected corruption in
   // the local copy of the extension and we want to perform a reinstall of it.
+  // |fetch_priority| parameter notifies the downloader the priority of this
+  // extension update (either foreground or background).
   bool AddPendingExtension(const std::string& id,
                            const GURL& update_url,
                            bool is_corrupt_reinstall,
-                           int request_id);
+                           int request_id,
+                           ManifestFetchData::FetchPriority fetch_priority);
 
   // Schedules a fetch of the manifest of all the extensions added with
   // AddExtension() and AddPendingExtension().
   void StartAllPending(ExtensionCache* cache);
 
   // Schedules an update check of the blacklist.
   void StartBlacklistUpdate(const std::string& version,
                             const ManifestFetchData::PingData& ping_data,
                             int request_id);
 
@@ skipping 21 matching lines @@
   // These are needed for unit testing, to help identify the correct mock
   // URLFetcher objects.
   static const int kManifestFetcherId = 1;
   static const int kExtensionFetcherId = 2;
 
   // Update AppID for extension blacklist.
   static const char kBlacklistAppID[];
 
   static const int kMaxRetries = 10;
 
+  // Names of the header fields used for traffic management for extension
+  // updater.
+  static const char kUpdateInteractivityHeader[];
+  static const char kUpdateAppIdHeader[];
+  static const char kUpdateUpdaterHeader[];
+
+  // Header values for foreground/background update requests.
+  static const char kUpdateInteractivityForeground[];
+  static const char kUpdateInteractivityBackground[];
+
  private:
   friend class ExtensionUpdaterTest;
 
   // These counters are bumped as extensions are added to be fetched. They
   // are then recorded as UMA metrics when all the extensions have been added.
   struct URLStats {
     URLStats()
         : no_url_count(0),
           google_url_count(0),
           other_url_count(0),
@@ skipping 49 matching lines @@
 
     ExtraParams();
   };
 
   // Helper for AddExtension() and AddPendingExtension().
   bool AddExtensionData(const std::string& id,
                         const base::Version& version,
                         Manifest::Type extension_type,
                         const GURL& extension_update_url,
                         const ExtraParams& extra,
-                        int request_id);
+                        int request_id,
+                        ManifestFetchData::FetchPriority fetch_priority);
 
   // Adds all recorded stats taken so far to histogram counts.
   void ReportStats() const;
 
   // Begins an update check.
   void StartUpdateCheck(std::unique_ptr<ManifestFetchData> fetch_data);
 
   // Called by RequestQueue when a new manifest fetch request is started.
   void CreateManifestFetcher();
 
@@ skipping 64 matching lines @@
                                            const net::URLRequestStatus& status,
                                            int response_code);
 
   // OAuth2TokenService::Consumer implementation.
   void OnGetTokenSuccess(const OAuth2TokenService::Request* request,
                          const std::string& access_token,
                          const base::Time& expiration_time) override;
   void OnGetTokenFailure(const OAuth2TokenService::Request* request,
                          const GoogleServiceAuthError& error) override;
 
-  ManifestFetchData* CreateManifestFetchData(const GURL& update_url,
-                                             int request_id);
+  ManifestFetchData* CreateManifestFetchData(
+      const GURL& update_url,
+      int request_id,
+      ManifestFetchData::FetchPriority fetch_priority);
 
   // The delegate that receives the crx files downloaded by the
   // ExtensionDownloader, and that fills in optional ping and update url data.
   ExtensionDownloaderDelegate* delegate_;
 
   // The request context to use for the URLFetchers.
   scoped_refptr<net::URLRequestContextGetter> request_context_;
 
   // Collects UMA samples that are reported when ReportStats() is called.
   URLStats url_stats_;
@@ skipping 44 matching lines @@
 
   // Used to create WeakPtrs to |this|.
   base::WeakPtrFactory<ExtensionDownloader> weak_ptr_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(ExtensionDownloader);
 };
 
 }  // namespace extensions
 
 #endif  // EXTENSIONS_BROWSER_UPDATER_EXTENSION_DOWNLOADER_H_