| OLD | NEW |
| 1 // Copyright 2012 The Chromium Authors. All rights reserved. | 1 // Copyright 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef COMPONENTS_SYNC_CORE_HTTP_BRIDGE_H_ | 5 #ifndef COMPONENTS_SYNC_CORE_HTTP_BRIDGE_H_ |
| 6 #define COMPONENTS_SYNC_CORE_HTTP_BRIDGE_H_ | 6 #define COMPONENTS_SYNC_CORE_HTTP_BRIDGE_H_ |
| 7 | 7 |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | 9 |
| 10 #include <memory> | 10 #include <memory> |
| 11 #include <string> | 11 #include <string> |
| 12 | 12 |
| 13 #include "base/compiler_specific.h" | 13 #include "base/compiler_specific.h" |
| 14 #include "base/macros.h" | 14 #include "base/macros.h" |
| 15 #include "base/memory/ref_counted.h" | 15 #include "base/memory/ref_counted.h" |
| 16 #include "base/synchronization/lock.h" | 16 #include "base/synchronization/lock.h" |
| 17 #include "base/synchronization/waitable_event.h" | 17 #include "base/synchronization/waitable_event.h" |
| 18 #include "base/threading/thread_checker.h" | 18 #include "base/threading/thread_checker.h" |
| 19 #include "base/timer/timer.h" | 19 #include "base/timer/timer.h" |
| 20 #include "components/sync/base/cancelation_observer.h" | 20 #include "components/sync/base/cancelation_observer.h" |
| 21 #include "components/sync/base/sync_export.h" | |
| 22 #include "components/sync/core/http_post_provider_factory.h" | 21 #include "components/sync/core/http_post_provider_factory.h" |
| 23 #include "components/sync/core/http_post_provider_interface.h" | 22 #include "components/sync/core/http_post_provider_interface.h" |
| 24 #include "components/sync/core/network_time_update_callback.h" | 23 #include "components/sync/core/network_time_update_callback.h" |
| 25 #include "net/url_request/url_fetcher_delegate.h" | 24 #include "net/url_request/url_fetcher_delegate.h" |
| 26 #include "net/url_request/url_request_context.h" | 25 #include "net/url_request/url_request_context.h" |
| 27 #include "net/url_request/url_request_context_getter.h" | 26 #include "net/url_request/url_request_context_getter.h" |
| 28 #include "url/gurl.h" | 27 #include "url/gurl.h" |
| 29 | 28 |
| 30 class HttpBridgeTest; | 29 class HttpBridgeTest; |
| 31 | 30 |
| 32 namespace net { | 31 namespace net { |
| 33 class HttpResponseHeaders; | 32 class HttpResponseHeaders; |
| 34 class HttpUserAgentSettings; | 33 class HttpUserAgentSettings; |
| 35 class URLFetcher; | 34 class URLFetcher; |
| 36 class URLRequestJobFactory; | 35 class URLRequestJobFactory; |
| 37 } | 36 } |
| 38 | 37 |
| 39 namespace syncer { | 38 namespace syncer { |
| 40 | 39 |
| 41 class CancelationSignal; | 40 class CancelationSignal; |
| 42 | 41 |
| 43 // A bridge between the syncer and Chromium HTTP layers. | 42 // A bridge between the syncer and Chromium HTTP layers. |
| 44 // Provides a way for the sync backend to use Chromium directly for HTTP | 43 // Provides a way for the sync backend to use Chromium directly for HTTP |
| 45 // requests rather than depending on a third party provider (e.g libcurl). | 44 // requests rather than depending on a third party provider (e.g libcurl). |
| 46 // This is a one-time use bridge. Create one for each request you want to make. | 45 // This is a one-time use bridge. Create one for each request you want to make. |
| 47 // It is RefCountedThreadSafe because it can PostTask to the io loop, and thus | 46 // It is RefCountedThreadSafe because it can PostTask to the io loop, and thus |
| 48 // needs to stick around across context switches, etc. | 47 // needs to stick around across context switches, etc. |
| 49 class SYNC_EXPORT HttpBridge : public base::RefCountedThreadSafe<HttpBridge>, | 48 class HttpBridge : public base::RefCountedThreadSafe<HttpBridge>, |
| 50 public HttpPostProviderInterface, | 49 public HttpPostProviderInterface, |
| 51 public net::URLFetcherDelegate { | 50 public net::URLFetcherDelegate { |
| 52 public: | 51 public: |
| 53 HttpBridge(const std::string& user_agent, | 52 HttpBridge(const std::string& user_agent, |
| 54 const scoped_refptr<net::URLRequestContextGetter>& context, | 53 const scoped_refptr<net::URLRequestContextGetter>& context, |
| 55 const NetworkTimeUpdateCallback& network_time_update_callback, | 54 const NetworkTimeUpdateCallback& network_time_update_callback, |
| 56 const BindToTrackerCallback& bind_to_tracker_callback); | 55 const BindToTrackerCallback& bind_to_tracker_callback); |
| 57 | 56 |
| 58 // HttpPostProvider implementation. | 57 // HttpPostProvider implementation. |
| 59 void SetExtraRequestHeaders(const char* headers) override; | 58 void SetExtraRequestHeaders(const char* headers) override; |
| 60 void SetURL(const char* url, int port) override; | 59 void SetURL(const char* url, int port) override; |
| 61 void SetPostPayload(const char* content_type, | 60 void SetPostPayload(const char* content_type, |
| (...skipping 118 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 180 // Callback for updating network time. | 179 // Callback for updating network time. |
| 181 NetworkTimeUpdateCallback network_time_update_callback_; | 180 NetworkTimeUpdateCallback network_time_update_callback_; |
| 182 | 181 |
| 183 // A callback to tag Sync request to be able to record data use of this | 182 // A callback to tag Sync request to be able to record data use of this |
| 184 // service by data_use_measurement component. | 183 // service by data_use_measurement component. |
| 185 BindToTrackerCallback bind_to_tracker_callback_; | 184 BindToTrackerCallback bind_to_tracker_callback_; |
| 186 | 185 |
| 187 DISALLOW_COPY_AND_ASSIGN(HttpBridge); | 186 DISALLOW_COPY_AND_ASSIGN(HttpBridge); |
| 188 }; | 187 }; |
| 189 | 188 |
| 190 class SYNC_EXPORT HttpBridgeFactory : public HttpPostProviderFactory, | 189 class HttpBridgeFactory : public HttpPostProviderFactory, |
| 191 public CancelationObserver { | 190 public CancelationObserver { |
| 192 public: | 191 public: |
| 193 HttpBridgeFactory( | 192 HttpBridgeFactory( |
| 194 const scoped_refptr<net::URLRequestContextGetter>& | 193 const scoped_refptr<net::URLRequestContextGetter>& |
| 195 baseline_context_getter, | 194 baseline_context_getter, |
| 196 const NetworkTimeUpdateCallback& network_time_update_callback, | 195 const NetworkTimeUpdateCallback& network_time_update_callback, |
| 197 CancelationSignal* cancelation_signal); | 196 CancelationSignal* cancelation_signal); |
| 198 ~HttpBridgeFactory() override; | 197 ~HttpBridgeFactory() override; |
| 199 | 198 |
| 200 // HttpPostProviderFactory: | 199 // HttpPostProviderFactory: |
| 201 void Init(const std::string& user_agent, | 200 void Init(const std::string& user_agent, |
| (...skipping 22 matching lines...) Expand all Loading... |
| 224 // A callback to tag Sync request to be able to record data use of this | 223 // A callback to tag Sync request to be able to record data use of this |
| 225 // service by data_use_measurement component. | 224 // service by data_use_measurement component. |
| 226 BindToTrackerCallback bind_to_tracker_callback_; | 225 BindToTrackerCallback bind_to_tracker_callback_; |
| 227 | 226 |
| 228 DISALLOW_COPY_AND_ASSIGN(HttpBridgeFactory); | 227 DISALLOW_COPY_AND_ASSIGN(HttpBridgeFactory); |
| 229 }; | 228 }; |
| 230 | 229 |
| 231 } // namespace syncer | 230 } // namespace syncer |
| 232 | 231 |
| 233 #endif // COMPONENTS_SYNC_CORE_HTTP_BRIDGE_H_ | 232 #endif // COMPONENTS_SYNC_CORE_HTTP_BRIDGE_H_ |
| OLD | NEW |