Index: chrome/browser/sync/glue/http_bridge.h |
=================================================================== |
--- chrome/browser/sync/glue/http_bridge.h (revision 22320) |
+++ chrome/browser/sync/glue/http_bridge.h (working copy) |
@@ -1,171 +0,0 @@ |
-// Copyright (c) 2006-2008 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. |
- |
-#ifdef CHROME_PERSONALIZATION |
- |
-#ifndef CHROME_BROWSER_SYNC_GLUE_HTTP_BRIDGE_H_ |
-#define CHROME_BROWSER_SYNC_GLUE_HTTP_BRIDGE_H_ |
- |
-#include "base/ref_counted.h" |
-#include "base/waitable_event.h" |
-#include "chrome/browser/net/url_fetcher.h" |
-#include "chrome/browser/sync/engine/syncapi.h" |
-#include "googleurl/src/gurl.h" |
-#include "net/url_request/url_request_context.h" |
-#include "testing/gtest/include/gtest/gtest_prod.h" |
- |
-class MessageLoop; |
-class HttpBridgeTest; |
- |
-namespace browser_sync { |
- |
-// A bridge between the syncer and Chromium HTTP layers. |
-// Provides a way for the sync backend to use Chromium directly for HTTP |
-// requests rather than depending on a third party provider (e.g libcurl). |
-// This is a one-time use bridge. Create one for each request you want to make. |
-// It is RefCountedThreadSafe because it can PostTask to the io loop, and thus |
-// needs to stick around across context switches, etc. |
-class HttpBridge : public base::RefCountedThreadSafe<HttpBridge>, |
- public sync_api::HttpPostProviderInterface, |
- public URLFetcher::Delegate { |
- public: |
- // A request context used for HTTP requests bridged from the sync backend. |
- // A bridged RequestContext has a dedicated in-memory cookie store and does |
- // not use a cache. Thus the same type can be used for incognito mode. |
- // TODO(timsteele): We subclass here instead of add a factory method on |
- // ChromeURLRequestContext because: |
- // 1) we want the ability to set_user_agent |
- // 2) avoids ifdefs for now |
- // 3) not sure we want to strictly follow settings for cookie policy, |
- // accept lang/charset, since changing these could break syncing. |
- class RequestContext : public URLRequestContext { |
- public: |
- // |baseline_context| is used to obtain the accept-language, |
- // accept-charsets, and proxy service information for bridged requests. |
- // Typically |baseline_context| should be the URLRequestContext of the |
- // currently active profile. |
- explicit RequestContext(const URLRequestContext* baseline_context); |
- virtual ~RequestContext(); |
- |
- // Set the user agent for requests using this context. The default is |
- // the browser's UA string. |
- void set_user_agent(const std::string& ua) { user_agent_ = ua; } |
- bool is_user_agent_set() const { return !user_agent_.empty(); } |
- |
- virtual const std::string& GetUserAgent(const GURL& url) const { |
- // If the user agent is set explicitly return that, otherwise call the |
- // base class method to return default value. |
- return user_agent_.empty() ? |
- URLRequestContext::GetUserAgent(url) : user_agent_; |
- } |
- |
- private: |
- std::string user_agent_; |
- |
- DISALLOW_COPY_AND_ASSIGN(RequestContext); |
- }; |
- |
- HttpBridge(RequestContext* context, MessageLoop* io_loop); |
- virtual ~HttpBridge(); |
- |
- // sync_api::HttpPostProvider implementation. |
- virtual void SetUserAgent(const char* user_agent); |
- virtual void SetURL(const char* url, int port); |
- virtual void SetPostPayload(const char* content_type, int content_length, |
- const char* content); |
- virtual void AddCookieForRequest(const char* cookie); |
- virtual bool MakeSynchronousPost(int* os_error_code, int* response_code); |
- virtual int GetResponseContentLength() const; |
- virtual const char* GetResponseContent() const; |
- virtual int GetResponseCookieCount() const; |
- virtual const char* GetResponseCookieAt(int cookie_number) const; |
- |
- // URLFetcher::Delegate implementation. |
- virtual void OnURLFetchComplete(const URLFetcher* source, const GURL& url, |
- const URLRequestStatus& status, |
- int response_code, |
- const ResponseCookies& cookies, |
- const std::string& data); |
- |
- protected: |
- // Protected virtual so the unit test can override to shunt network requests. |
- virtual void MakeAsynchronousPost(); |
- |
- private: |
- friend class ::HttpBridgeTest; |
- |
- // Called on the io_loop_ to issue the network request. The extra level |
- // of indirection is so that the unit test can override this behavior but we |
- // still have a function to statically pass to PostTask. |
- void CallMakeAsynchronousPost() { MakeAsynchronousPost(); } |
- |
- // A customized URLRequestContext for bridged requests. See RequestContext |
- // definition for details. |
- RequestContext* context_for_request_; |
- |
- // Our hook into the network layer is a URLFetcher. USED ONLY ON THE IO LOOP, |
- // so we can block created_on_loop_ while the fetch is in progress. |
- // NOTE: This is not a scoped_ptr for a reason. It must be deleted on the same |
- // thread that created it, which isn't the same thread |this| gets deleted on. |
- // We must manually delete url_poster_ on the io_loop_. |
- URLFetcher* url_poster_; |
- |
- // The message loop of the thread we were created on. This is the thread that |
- // will block on MakeSynchronousPost while the IO thread fetches data from |
- // the network. |
- // This should be the main syncer thread (SyncerThread) which is what blocks |
- // on network IO through curl_easy_perform. |
- MessageLoop* const created_on_loop_; |
- |
- // Member variable for the IO loop instead of asking ChromeThread directly, |
- // done this way for testability. |
- MessageLoop* const io_loop_; |
- |
- // The URL to POST to. |
- GURL url_for_request_; |
- |
- // POST payload information. |
- std::string content_type_; |
- std::string request_content_; |
- |
- // Cached response data. |
- bool request_completed_; |
- bool request_succeeded_; |
- int http_response_code_; |
- int os_error_code_; |
- ResponseCookies response_cookies_; |
- std::string response_content_; |
- |
- // A waitable event we use to provide blocking semantics to |
- // MakeSynchronousPost. We block created_on_loop_ while the io_loop_ fetches |
- // network request. |
- base::WaitableEvent http_post_completed_; |
- |
- // This is here so that the unit test subclass can force our URLFetcher to |
- // use the io_loop_ passed on construction for network requests, rather than |
- // ChromeThread::IO's message loop (which won't exist in testing). |
- bool use_io_loop_for_testing_; |
- |
- DISALLOW_COPY_AND_ASSIGN(HttpBridge); |
-}; |
- |
-class HttpBridgeFactory |
- : public sync_api::HttpPostProviderFactory { |
- public: |
- HttpBridgeFactory() : request_context_(NULL) { } |
- virtual ~HttpBridgeFactory(); |
- virtual sync_api::HttpPostProviderInterface* Create(); |
- virtual void Destroy(sync_api::HttpPostProviderInterface* http); |
- private: |
- HttpBridge::RequestContext* GetRequestContext(); |
- // We must Release() this from the IO thread. |
- HttpBridge::RequestContext* request_context_; |
- DISALLOW_COPY_AND_ASSIGN(HttpBridgeFactory); |
-}; |
- |
-} // namespace browser_sync |
- |
-#endif // CHROME_BROWSER_SYNC_GLUE_HTTP_BRIDGE_H_ |
- |
-#endif // CHROME_PERSONALIZATION |