Introduce net::HttpServerPropertiesManager to manage server-specific properties.

chrome/browser/net/http_server_properties_manager.h

+// Copyright (c) 2011 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 CHROME_BROWSER_NET_HTTP_SERVER_PROPERTIES_MANAGER_H_
+#define CHROME_BROWSER_NET_HTTP_SERVER_PROPERTIES_MANAGER_H_
+#pragma once
+
+#include <string>
+#include <vector>
+
+#include "base/basictypes.h"
+#include "base/compiler_specific.h"
+#include "base/memory/scoped_ptr.h"
+#include "base/memory/weak_ptr.h"
+#include "base/task.h"
+#include "chrome/browser/prefs/pref_change_registrar.h"
+#include "content/common/notification_observer.h"
+#include "net/base/host_port_pair.h"
+#include "net/http/http_server_properties.h"
+
+class NotificationDetails;
+class NotificationSource;
+class PrefService;
+
+namespace base {
+class ListValue;
+}
+
+namespace chrome_browser_net {
+
+////////////////////////////////////////////////////////////////////////////////
+//  HttpServerPropertiesManager
+
+// The manager for creating and updating an HttpServerProperties (for example it
+// tracks if a server supports SPDY or not).
+//
+// This class interacts with both the UI thread, where notifications of pref
+// changes are received from, and the IO thread, which owns it (in the
+// ProfileIOData) and checks for SpdyServers (from ChromeNetworkDelegate).
+//
+// It must be constructed on the UI thread, to set up |ui_method_factory_| and
+// the prefs listeners.
+//
+// ShutdownOnUIThread must be called from UI before destruction, to release
+// the prefs listeners on the UI thread. This is done from ProfileIOData.
+//
+// Update tasks from the UI thread can post safely to the IO thread, since the
+// destruction order of Profile and ProfileIOData guarantees that if this
+// exists in UI, then a potential destruction on IO will come after any task
+// posted to IO from that method on UI. This is used to go through IO before
+// the actual update starts, and grab a WeakPtr.
+class HttpServerPropertiesManager
+    : public net::HttpServerProperties,
+      public NotificationObserver {
+ public:
+  // Create an instance of the HttpServerPropertiesManager. The lifetime of the
+  // PrefService objects must be longer than that of the
+  // HttpServerPropertiesManager object. Get SPDY Server preferences from
+  // |prefs| object. Must be constructed on the UI thread.
+  explicit HttpServerPropertiesManager(PrefService* pref_service);
+  virtual ~HttpServerPropertiesManager();
+
+  // Prepare for shutdown. Must be called on the UI thread, before destruction.
+  void ShutdownOnUIThread();
+
+  // Returns true if |server| supports SPDY.
+  virtual bool SupportsSpdy(const net::HostPortPair& host_port_pair);
+
+  // Add |server| as the SPDY server which supports SPDY protocol into the
+  // persisitent store. Should only be called from IO thread.
+  virtual void SetSupportsSpdy(const net::HostPortPair& host_port_pair,
+                               bool support_spdy);
+
+  // Register |prefs| SPDY preferences.
+  static void RegisterPrefs(PrefService* prefs);
+
+ protected:
+  // These are used to delay updating the spdy servers in |spdy_servers_table_|
+  // while the preferences are changing, and execute only one update per
+  // simultaneous prefs changes.
+  void ScheduleUpdateOnUI();
+  virtual void PostUpdateTaskOnUI(Task* task);  // Virtual for testing.
+  virtual void UpdateCacheFromPrefs();  // Virtual for testing.
+
+  // Starts the |spdy_servers| update on the IO thread. Protected for testing.
+  void UpdateCacheFromPrefsOnIO(StringVector* spdy_servers, bool support_spdy);
+
+  // These are used to delay updating the preferences when spdy servers_ are
+  // changing, and execute only one update per simultaneous spdy server changes.
+  void ScheduleUpdateOnIO();
+  virtual void PostUpdateTaskOnIO(Task* task);  // Virtual for testing.
+  virtual void UpdatePrefsFromCache();  // Virtual for testing.
+
+  // Update |prefs::kSpdyServers| preferences with |spdy_server_list| on UI
+  // thread. Protected for testing.
+  void SetSpdyServersInPrefsOnUI(base::ListValue* spdy_server_list);
+
+ private:
+  // Callback for preference changes.
+  virtual void Observe(int type,
+                       const NotificationSource& source,
+                       const NotificationDetails& details);
+
+  // ---------
+  // UI thread
+  // ---------
+
+  // Used to post update tasks to the UI thread.
+  ScopedRunnableMethodFactory<HttpServerPropertiesManager> ui_method_factory_;
+
+  // Used to track the spdy servers changes.
+  PrefChangeRegistrar pref_change_registrar_;
+  PrefService* pref_service_;  // Weak.
+
+  // ---------
+  // IO thread
+  // ---------
+
+  // Used to post update tasks to the IO thread.
+  ScopedRunnableMethodFactory<HttpServerPropertiesManager> io_method_factory_;
+
+  // Used to get |weak_ptr_| to self on the IO thread.
+  base::WeakPtrFactory<HttpServerPropertiesManager> io_weak_ptr_factory_;
+
+  DISALLOW_COPY_AND_ASSIGN(HttpServerPropertiesManager);
+};
+
+}  // namespace chrome_browser_net
+
+#endif  // CHROME_BROWSER_NET_HTTP_SERVER_PROPERTIES_MANAGER_H_