1aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// 2aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// Copyright (C) 2009 The Android Open Source Project 3aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// 4aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// Licensed under the Apache License, Version 2.0 (the "License"); 5aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// you may not use this file except in compliance with the License. 6aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// You may obtain a copy of the License at 7aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// 8aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// http://www.apache.org/licenses/LICENSE-2.0 9aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// 10aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// Unless required by applicable law or agreed to in writing, software 11aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// distributed under the License is distributed on an "AS IS" BASIS, 12aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// See the License for the specific language governing permissions and 14aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// limitations under the License. 15aea4c1cea20dda7ae7e85fc8924a2d784f70d806Alex Deymo// 1649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 178b01f44bf61c5cceb83b2ff4f2c0070a9ab946d7Alex Deymo#ifndef UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H_ 188b01f44bf61c5cceb83b2ff4f2c0070a9ab946d7Alex Deymo#define UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H_ 1949fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 2049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com#include <map> 21c1c17b4ed6a3896b6343e737fd89682fa0c8436bAlex Deymo#include <memory> 2249fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com#include <string> 23d2779df63aaad8b65fc5d4badee7dbc9bed7f2b6Alex Vakulenko#include <utility> 247f9aea2748370b0a26e1d5c36db7d8bbf3ba1245Bruno Rocha 2549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com#include <curl/curl.h> 267f9aea2748370b0a26e1d5c36db7d8bbf3ba1245Bruno Rocha 2705735a1879a553153458aae0a25fa5d42e3e408fBen Chan#include <base/logging.h> 2805735a1879a553153458aae0a25fa5d42e3e408fBen Chan#include <base/macros.h> 293f39d5cc753905874d8d93bef94f857b8808f19eAlex Vakulenko#include <brillo/message_loops/message_loop.h> 3005735a1879a553153458aae0a25fa5d42e3e408fBen Chan 318b01f44bf61c5cceb83b2ff4f2c0070a9ab946d7Alex Deymo#include "update_engine/certificate_checker.h" 3239910dcd1d68987ccee7c3031dc269233a8490bbAlex Deymo#include "update_engine/common/hardware_interface.h" 3339910dcd1d68987ccee7c3031dc269233a8490bbAlex Deymo#include "update_engine/common/http_fetcher.h" 344348879380222dc8c74b0976e527bf3da66ba08fJay Srinivasan 3549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com// This is a concrete implementation of HttpFetcher that uses libcurl to do the 3649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com// http work. 3749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 3849fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.comnamespace chromeos_update_engine { 3949fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 4049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.comclass LibcurlHttpFetcher : public HttpFetcher { 4149fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com public: 424348879380222dc8c74b0976e527bf3da66ba08fJay Srinivasan LibcurlHttpFetcher(ProxyResolver* proxy_resolver, 4333e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo HardwareInterface* hardware); 4449fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 4549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Cleans up all internal state. Does not notify delegate 46610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo ~LibcurlHttpFetcher() override; 4749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 48610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void SetOffset(off_t offset) override { bytes_downloaded_ = offset; } 49e4ad2508de4d69d7a90d3ce441efe2c82c55bd1dGilad Arnold 50610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void SetLength(size_t length) override { download_length_ = length; } 51610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void UnsetLength() override { SetLength(0); } 523fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes 5349fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Begins the transfer if it hasn't already begun. 54610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void BeginTransfer(const std::string& url) override; 5549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 569ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov // If the transfer is in progress, aborts the transfer early. The transfer 579ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov // cannot be resumed. 58610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void TerminateTransfer() override; 5949fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 606f10c5f7c550b1bd6df1d9a04b5e75e03f943639Alex Deymo // Pass the headers to libcurl. 616f10c5f7c550b1bd6df1d9a04b5e75e03f943639Alex Deymo void SetHeader(const std::string& header_name, 626f10c5f7c550b1bd6df1d9a04b5e75e03f943639Alex Deymo const std::string& header_value) override; 636f10c5f7c550b1bd6df1d9a04b5e75e03f943639Alex Deymo 6449fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Suspend the transfer by calling curl_easy_pause(CURLPAUSE_ALL). 65610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void Pause() override; 6649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 6749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Resume the transfer by calling curl_easy_pause(CURLPAUSE_CONT). 68610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void Unpause() override; 6949fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 7049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Libcurl sometimes asks to be called back after some time while 7149fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // leaving that time unspecified. In that case, we pick a reasonable 7249fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // default of one second, but it can be overridden here. This is 7349fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // primarily useful for testing. 7449fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // From http://curl.haxx.se/libcurl/c/curl_multi_timeout.html: 7549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // if libcurl returns a -1 timeout here, it just means that libcurl 7649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // currently has no stored timeout value. You must not wait too long 7749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // (more than a few seconds perhaps) before you call 7849fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // curl_multi_perform() again. 79610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void set_idle_seconds(int seconds) override { idle_seconds_ = seconds; } 80b83371f6d7fc12a66d33eac614c0fae3aa0978baDarin Petkov 81b83371f6d7fc12a66d33eac614c0fae3aa0978baDarin Petkov // Sets the retry timeout. Useful for testing. 82610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void set_retry_seconds(int seconds) override { retry_seconds_ = seconds; } 83fc7a0cec794ab43e66b6781ddb7f498b0ce257b9Darin Petkov 84a092955cdf763260563a774f6a68e1bfb38c5a8bDarin Petkov void set_no_network_max_retries(int retries) { 85a092955cdf763260563a774f6a68e1bfb38c5a8bDarin Petkov no_network_max_retries_ = retries; 86a092955cdf763260563a774f6a68e1bfb38c5a8bDarin Petkov } 87a092955cdf763260563a774f6a68e1bfb38c5a8bDarin Petkov 8833e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo void set_server_to_check(ServerToCheck server_to_check) { 8933e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo server_to_check_ = server_to_check; 9033e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo } 9133e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo 92610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo size_t GetBytesDownloaded() override { 9348085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold return static_cast<size_t>(bytes_downloaded_); 9448085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold } 9548085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold 96610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void set_low_speed_limit(int low_speed_bps, int low_speed_sec) override { 9734135a9f24c72137aa85378b57e7698162c687f2David Zeuthen low_speed_limit_bps_ = low_speed_bps; 9834135a9f24c72137aa85378b57e7698162c687f2David Zeuthen low_speed_time_seconds_ = low_speed_sec; 9934135a9f24c72137aa85378b57e7698162c687f2David Zeuthen } 10034135a9f24c72137aa85378b57e7698162c687f2David Zeuthen 101610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void set_connect_timeout(int connect_timeout_seconds) override { 10234135a9f24c72137aa85378b57e7698162c687f2David Zeuthen connect_timeout_seconds_ = connect_timeout_seconds; 10334135a9f24c72137aa85378b57e7698162c687f2David Zeuthen } 10434135a9f24c72137aa85378b57e7698162c687f2David Zeuthen 105610277efc6f7e5239158dfa4bb3b1021804326e0Alex Deymo void set_max_retry_count(int max_retry_count) override { 10634135a9f24c72137aa85378b57e7698162c687f2David Zeuthen max_retry_count_ = max_retry_count; 10734135a9f24c72137aa85378b57e7698162c687f2David Zeuthen } 10834135a9f24c72137aa85378b57e7698162c687f2David Zeuthen 10949fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com private: 110f3ed8e7d4ad456a3c841d8a530f308b6fcb2a4ccAndrew de los Reyes // Callback for when proxy resolution has completed. This begins the 111f3ed8e7d4ad456a3c841d8a530f308b6fcb2a4ccAndrew de los Reyes // transfer. 112f3ed8e7d4ad456a3c841d8a530f308b6fcb2a4ccAndrew de los Reyes void ProxiesResolved(); 1134348879380222dc8c74b0976e527bf3da66ba08fJay Srinivasan 1143fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // Asks libcurl for the http response code and stores it in the object. 1153fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes void GetHttpResponseCode(); 1163fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes 1179bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold // Checks whether stored HTTP response is within the success range. 11848085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold inline bool IsHttpResponseSuccess() { 11948085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold return (http_response_code_ >= 200 && http_response_code_ < 300); 12048085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold } 12148085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold 1229bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold // Checks whether stored HTTP response is within the error range. This 1239bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold // includes both errors with the request (4xx) and server errors (5xx). 1249bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold inline bool IsHttpResponseError() { 1259bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold return (http_response_code_ >= 400 && http_response_code_ < 600); 1269bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold } 1279bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold 128c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // Resumes a transfer where it left off. This will use the 129c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // HTTP Range: header to make a new connection from where the last 130c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // left off. 131c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com virtual void ResumeTransfer(const std::string& url); 13249fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 13360ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo void TimeoutCallback(); 13460ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo void RetryTimeoutCallback(); 13549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 13649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Calls into curl_multi_perform to let libcurl do its work. Returns after 13749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // curl_multi_perform is finished, which may actually be after more than 1380b3db6b6040f53eb9859e614f7fe4c681213d33aAlex Deymo // one call to curl_multi_perform. This method will set up the message 139f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // loop with sources for future work that libcurl will do, if any, or complete 140f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // the transfer and finish the action if no work left to do. 14149fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // This method will not block. 142cb319330c529b0394f6efb416dbe7b03bf38b19bAndrew de los Reyes void CurlPerformOnce(); 14349fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 14429b815316519829f133b39dd1cae7ab6224c9da2Alex Deymo // Sets up message loop sources as needed by libcurl. This is generally 14549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // the file descriptor of the socket and a timer in case nothing happens 14649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // on the fds. 14729b815316519829f133b39dd1cae7ab6224c9da2Alex Deymo void SetupMessageLoopSources(); 14849fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 14949fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Callback called by libcurl when new data has arrived on the transfer 15049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com size_t LibcurlWrite(void *ptr, size_t size, size_t nmemb); 15149fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com static size_t StaticLibcurlWrite(void *ptr, size_t size, 15249fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com size_t nmemb, void *stream) { 15349fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com return reinterpret_cast<LibcurlHttpFetcher*>(stream)-> 15449fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com LibcurlWrite(ptr, size, nmemb); 15549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com } 15649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 15749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Cleans up the following if they are non-null: 15829b815316519829f133b39dd1cae7ab6224c9da2Alex Deymo // curl(m) handles, fd_task_maps_, timeout_id_. 15949fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com void CleanUp(); 16049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 1619ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov // Force terminate the transfer. This will invoke the delegate's (if any) 1629ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov // TransferTerminated callback so, after returning, this fetcher instance may 1639ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov // be destroyed. 1649ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov void ForceTransferTermination(); 1659ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov 166b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan // Sets the curl options for HTTP URL. 167b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan void SetCurlOptionsForHttp(); 168b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan 169b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan // Sets the curl options for HTTPS URL. 170b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan void SetCurlOptionsForHttps(); 171b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan 17256ccb072b55a48099c634a9dfb24e3af2b6213caAlex Deymo // Sets the curl options for file URI. 17356ccb072b55a48099c634a9dfb24e3af2b6213caAlex Deymo void SetCurlOptionsForFile(); 17456ccb072b55a48099c634a9dfb24e3af2b6213caAlex Deymo 17559d9e0142388f23dae84f7b480d24f1f71b80cfaGilad Arnold // Convert a proxy URL into a curl proxy type, if applicable. Returns true iff 17659d9e0142388f23dae84f7b480d24f1f71b80cfaGilad Arnold // conversion was successful, false otherwise (in which case nothing is 17759d9e0142388f23dae84f7b480d24f1f71b80cfaGilad Arnold // written to |out_type|). 17859d9e0142388f23dae84f7b480d24f1f71b80cfaGilad Arnold bool GetProxyType(const std::string& proxy, curl_proxytype* out_type); 17959d9e0142388f23dae84f7b480d24f1f71b80cfaGilad Arnold 180c1c17b4ed6a3896b6343e737fd89682fa0c8436bAlex Deymo // Hardware interface used to query dev-mode and official build settings. 181c1c17b4ed6a3896b6343e737fd89682fa0c8436bAlex Deymo HardwareInterface* hardware_; 182c1c17b4ed6a3896b6343e737fd89682fa0c8436bAlex Deymo 18349fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Handles for the libcurl library 18460ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo CURLM* curl_multi_handle_{nullptr}; 18560ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo CURL* curl_handle_{nullptr}; 18660ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo struct curl_slist* curl_http_headers_{nullptr}; 18749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 1886f10c5f7c550b1bd6df1d9a04b5e75e03f943639Alex Deymo // The extra headers that will be sent on each request. 1896f10c5f7c550b1bd6df1d9a04b5e75e03f943639Alex Deymo std::map<std::string, std::string> extra_headers_; 1906f10c5f7c550b1bd6df1d9a04b5e75e03f943639Alex Deymo 19160e1415b31b58bc17017d29c8e06f6e5452fdf4eDarin Petkov // Lists of all read(0)/write(1) file descriptors that we're waiting on from 19229b815316519829f133b39dd1cae7ab6224c9da2Alex Deymo // the message loop. libcurl may open/close descriptors and switch their 19360e1415b31b58bc17017d29c8e06f6e5452fdf4eDarin Petkov // directions so maintain two separate lists so that watch conditions can be 19460e1415b31b58bc17017d29c8e06f6e5452fdf4eDarin Petkov // set appropriately. 1953f39d5cc753905874d8d93bef94f857b8808f19eAlex Vakulenko std::map<int, brillo::MessageLoop::TaskId> fd_task_maps_[2]; 19649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 19760ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo // The TaskId of the timer we're waiting on. kTaskIdNull if we are not waiting 19860ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo // on it. 1993f39d5cc753905874d8d93bef94f857b8808f19eAlex Vakulenko brillo::MessageLoop::TaskId timeout_id_{brillo::MessageLoop::kTaskIdNull}; 20049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 20129b815316519829f133b39dd1cae7ab6224c9da2Alex Deymo bool transfer_in_progress_{false}; 202f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo bool transfer_paused_{false}; 203f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo 204f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // Whether it should ignore transfer failures for the purpose of retrying the 205f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // connection. 206f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo bool ignore_failure_{false}; 207f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo 208f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // Whether we should restart the transfer once Unpause() is called. This can 209f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // be caused because either the connection dropped while pause or the proxy 210f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // was resolved and we never started the transfer in the first place. 211f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo bool restart_transfer_on_unpause_{false}; 21249fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 213c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // The transfer size. -1 if not known. 21460ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo off_t transfer_size_{0}; 215c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com 216c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // How many bytes have been downloaded and sent to the delegate. 21760ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo off_t bytes_downloaded_{0}; 218c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com 219e4ad2508de4d69d7a90d3ce441efe2c82c55bd1dGilad Arnold // The remaining maximum number of bytes to download. Zero represents an 220e4ad2508de4d69d7a90d3ce441efe2c82c55bd1dGilad Arnold // unspecified length. 22160ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo size_t download_length_{0}; 222e4ad2508de4d69d7a90d3ce441efe2c82c55bd1dGilad Arnold 223c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // If we resumed an earlier transfer, data offset that we used for the 224c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // new connection. 0 otherwise. 2253fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // In this class, resume refers to resuming a dropped HTTP connection, 2263fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // not to resuming an interrupted download. 22760ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo off_t resume_offset_{0}; 228b83371f6d7fc12a66d33eac614c0fae3aa0978baDarin Petkov 22932f2357356546d3a4d1184fdbb6b664d620c6af1Jay Srinivasan // Number of resumes performed so far and the max allowed. 23060ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int retry_count_{0}; 23160ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int max_retry_count_{kDownloadMaxRetryCount}; 232c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com 233b83371f6d7fc12a66d33eac614c0fae3aa0978baDarin Petkov // Seconds to wait before retrying a resume. 23460ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int retry_seconds_{20}; 235b83371f6d7fc12a66d33eac614c0fae3aa0978baDarin Petkov 236a092955cdf763260563a774f6a68e1bfb38c5a8bDarin Petkov // Number of resumes due to no network (e.g., HTTP response code 0). 23760ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int no_network_retry_count_{0}; 23860ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int no_network_max_retries_{0}; 239a092955cdf763260563a774f6a68e1bfb38c5a8bDarin Petkov 240b83371f6d7fc12a66d33eac614c0fae3aa0978baDarin Petkov // Seconds to wait before asking libcurl to "perform". 24160ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int idle_seconds_{1}; 242fc7a0cec794ab43e66b6781ddb7f498b0ce257b9Darin Petkov 2433fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // If true, we are currently performing a write callback on the delegate. 24460ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo bool in_write_callback_{false}; 245a092955cdf763260563a774f6a68e1bfb38c5a8bDarin Petkov 2464516810fe41a39c0c55d2095679898787259ae38Andrew de los Reyes // If true, we have returned at least one byte in the write callback 2474516810fe41a39c0c55d2095679898787259ae38Andrew de los Reyes // to the delegate. 24860ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo bool sent_byte_{false}; 249fc7a0cec794ab43e66b6781ddb7f498b0ce257b9Darin Petkov 2503fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // We can't clean everything up while we're in a write callback, so 2513fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // if we get a terminate request, queue it until we can handle it. 25260ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo bool terminate_requested_{false}; 2533fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes 25433e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo // The ServerToCheck used when checking this connection's certificate. If no 25533e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo // certificate check needs to be performed, this should be set to 25633e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo // ServerToCheck::kNone. 25733e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo ServerToCheck server_to_check_{ServerToCheck::kNone}; 2587f9aea2748370b0a26e1d5c36db7d8bbf3ba1245Bruno Rocha 25960ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int low_speed_limit_bps_{kDownloadLowSpeedLimitBps}; 26060ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int low_speed_time_seconds_{kDownloadLowSpeedTimeSeconds}; 26160ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int connect_timeout_seconds_{kDownloadConnectTimeoutSeconds}; 26234135a9f24c72137aa85378b57e7698162c687f2David Zeuthen int num_max_retries_; 26334135a9f24c72137aa85378b57e7698162c687f2David Zeuthen 26449fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com DISALLOW_COPY_AND_ASSIGN(LibcurlHttpFetcher); 26549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com}; 26649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 26749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com} // namespace chromeos_update_engine 26849fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 2698b01f44bf61c5cceb83b2ff4f2c0070a9ab946d7Alex Deymo#endif // UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H_ 270