OLD | NEW |
1 // Copyright (c) 2009 The Chromium OS Authors. All rights reserved. | 1 // Copyright (c) 2009 The Chromium OS 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 CHROMEOS_PLATFORM_UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H__ | 5 #ifndef CHROMEOS_PLATFORM_UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H__ |
6 #define CHROMEOS_PLATFORM_UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H__ | 6 #define CHROMEOS_PLATFORM_UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H__ |
7 | 7 |
8 #include <map> | 8 #include <map> |
9 #include <string> | 9 #include <string> |
10 #include <curl/curl.h> | 10 #include <curl/curl.h> |
(...skipping 30 matching lines...) Expand all Loading... |
41 terminate_requested_(false) {} | 41 terminate_requested_(false) {} |
42 | 42 |
43 // Cleans up all internal state. Does not notify delegate | 43 // Cleans up all internal state. Does not notify delegate |
44 ~LibcurlHttpFetcher(); | 44 ~LibcurlHttpFetcher(); |
45 | 45 |
46 void SetOffset(off_t offset) { bytes_downloaded_ = offset; } | 46 void SetOffset(off_t offset) { bytes_downloaded_ = offset; } |
47 | 47 |
48 // Begins the transfer if it hasn't already begun. | 48 // Begins the transfer if it hasn't already begun. |
49 virtual void BeginTransfer(const std::string& url); | 49 virtual void BeginTransfer(const std::string& url); |
50 | 50 |
51 // If the transfer is in progress, aborts the transfer early. | 51 // If the transfer is in progress, aborts the transfer early. The transfer |
52 // The transfer cannot be resumed. | 52 // cannot be resumed. |
53 virtual void TerminateTransfer(); | 53 virtual void TerminateTransfer(); |
54 | 54 |
55 // Suspend the transfer by calling curl_easy_pause(CURLPAUSE_ALL). | 55 // Suspend the transfer by calling curl_easy_pause(CURLPAUSE_ALL). |
56 virtual void Pause(); | 56 virtual void Pause(); |
57 | 57 |
58 // Resume the transfer by calling curl_easy_pause(CURLPAUSE_CONT). | 58 // Resume the transfer by calling curl_easy_pause(CURLPAUSE_CONT). |
59 virtual void Unpause(); | 59 virtual void Unpause(); |
60 | 60 |
61 // Libcurl sometimes asks to be called back after some time while | 61 // Libcurl sometimes asks to be called back after some time while |
62 // leaving that time unspecified. In that case, we pick a reasonable | 62 // leaving that time unspecified. In that case, we pick a reasonable |
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
129 static size_t StaticLibcurlWrite(void *ptr, size_t size, | 129 static size_t StaticLibcurlWrite(void *ptr, size_t size, |
130 size_t nmemb, void *stream) { | 130 size_t nmemb, void *stream) { |
131 return reinterpret_cast<LibcurlHttpFetcher*>(stream)-> | 131 return reinterpret_cast<LibcurlHttpFetcher*>(stream)-> |
132 LibcurlWrite(ptr, size, nmemb); | 132 LibcurlWrite(ptr, size, nmemb); |
133 } | 133 } |
134 | 134 |
135 // Cleans up the following if they are non-null: | 135 // Cleans up the following if they are non-null: |
136 // curl(m) handles, io_channels_, timeout_source_. | 136 // curl(m) handles, io_channels_, timeout_source_. |
137 void CleanUp(); | 137 void CleanUp(); |
138 | 138 |
| 139 // Force terminate the transfer. This will invoke the delegate's (if any) |
| 140 // TransferTerminated callback so, after returning, this fetcher instance may |
| 141 // be destroyed. |
| 142 void ForceTransferTermination(); |
| 143 |
139 // Returns whether or not the current network connection is considered | 144 // Returns whether or not the current network connection is considered |
140 // expensive. | 145 // expensive. |
141 bool ConnectionIsExpensive() const; | 146 bool ConnectionIsExpensive() const; |
142 | 147 |
143 // Returns whether or not the current build is official. | 148 // Returns whether or not the current build is official. |
144 bool IsOfficialBuild() const; | 149 bool IsOfficialBuild() const; |
145 | 150 |
146 // Handles for the libcurl library | 151 // Handles for the libcurl library |
147 CURLM *curl_multi_handle_; | 152 CURLM *curl_multi_handle_; |
148 CURL *curl_handle_; | 153 CURL *curl_handle_; |
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
197 // We can't clean everything up while we're in a write callback, so | 202 // We can't clean everything up while we're in a write callback, so |
198 // if we get a terminate request, queue it until we can handle it. | 203 // if we get a terminate request, queue it until we can handle it. |
199 bool terminate_requested_; | 204 bool terminate_requested_; |
200 | 205 |
201 DISALLOW_COPY_AND_ASSIGN(LibcurlHttpFetcher); | 206 DISALLOW_COPY_AND_ASSIGN(LibcurlHttpFetcher); |
202 }; | 207 }; |
203 | 208 |
204 } // namespace chromeos_update_engine | 209 } // namespace chromeos_update_engine |
205 | 210 |
206 #endif // CHROMEOS_PLATFORM_UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H__ | 211 #endif // CHROMEOS_PLATFORM_UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H__ |
OLD | NEW |