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 1714c0da88a93aa7b1aa71d5e7e923b537f0d419f3Alex Deymo#ifndef UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H_ 1814c0da88a93aa7b1aa71d5e7e923b537f0d419f3Alex 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 3114c0da88a93aa7b1aa71d5e7e923b537f0d419f3Alex 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 60fdd6dec9c4be2fbd667cf874c4cc6f4ffecaeef9Alex Deymo // Pass the headers to libcurl. 61fdd6dec9c4be2fbd667cf874c4cc6f4ffecaeef9Alex Deymo void SetHeader(const std::string& header_name, 62fdd6dec9c4be2fbd667cf874c4cc6f4ffecaeef9Alex Deymo const std::string& header_value) override; 63fdd6dec9c4be2fbd667cf874c4cc6f4ffecaeef9Alex 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: 11013e9518b53bbbc138bf20ac1e50be17b25fda6a7Alex Deymo // libcurl's CURLOPT_CLOSESOCKETFUNCTION callback function. Called when 11113e9518b53bbbc138bf20ac1e50be17b25fda6a7Alex Deymo // closing a socket created with the CURLOPT_OPENSOCKETFUNCTION callback. 11213e9518b53bbbc138bf20ac1e50be17b25fda6a7Alex Deymo static int LibcurlCloseSocketCallback(void* clientp, curl_socket_t item); 11313e9518b53bbbc138bf20ac1e50be17b25fda6a7Alex Deymo 114f3ed8e7d4ad456a3c841d8a530f308b6fcb2a4ccAndrew de los Reyes // Callback for when proxy resolution has completed. This begins the 115f3ed8e7d4ad456a3c841d8a530f308b6fcb2a4ccAndrew de los Reyes // transfer. 116f3ed8e7d4ad456a3c841d8a530f308b6fcb2a4ccAndrew de los Reyes void ProxiesResolved(); 1174348879380222dc8c74b0976e527bf3da66ba08fJay Srinivasan 1183fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // Asks libcurl for the http response code and stores it in the object. 1193fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes void GetHttpResponseCode(); 1203fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes 1219bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold // Checks whether stored HTTP response is within the success range. 12248085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold inline bool IsHttpResponseSuccess() { 12348085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold return (http_response_code_ >= 200 && http_response_code_ < 300); 12448085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold } 12548085ba58516e94f045d3ab7e26c8f36e6a6936fGilad Arnold 1269bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold // Checks whether stored HTTP response is within the error range. This 1279bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold // includes both errors with the request (4xx) and server errors (5xx). 1289bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold inline bool IsHttpResponseError() { 1299bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold return (http_response_code_ >= 400 && http_response_code_ < 600); 1309bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold } 1319bedeb51f80c9547269eef6c2ec09596033bb818Gilad Arnold 132c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // Resumes a transfer where it left off. This will use the 133c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // HTTP Range: header to make a new connection from where the last 134c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // left off. 135c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com virtual void ResumeTransfer(const std::string& url); 13649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 13760ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo void TimeoutCallback(); 13860ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo void RetryTimeoutCallback(); 13949fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 14049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Calls into curl_multi_perform to let libcurl do its work. Returns after 14149fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // curl_multi_perform is finished, which may actually be after more than 1420b3db6b6040f53eb9859e614f7fe4c681213d33aAlex Deymo // one call to curl_multi_perform. This method will set up the message 143f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // loop with sources for future work that libcurl will do, if any, or complete 144f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // the transfer and finish the action if no work left to do. 14549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // This method will not block. 146cb319330c529b0394f6efb416dbe7b03bf38b19bAndrew de los Reyes void CurlPerformOnce(); 14749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 14829b815316519829f133b39dd1cae7ab6224c9da2Alex Deymo // Sets up message loop sources as needed by libcurl. This is generally 14949fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // the file descriptor of the socket and a timer in case nothing happens 15049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // on the fds. 15129b815316519829f133b39dd1cae7ab6224c9da2Alex Deymo void SetupMessageLoopSources(); 15249fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 15349fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Callback called by libcurl when new data has arrived on the transfer 15449fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com size_t LibcurlWrite(void *ptr, size_t size, size_t nmemb); 15549fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com static size_t StaticLibcurlWrite(void *ptr, size_t size, 15649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com size_t nmemb, void *stream) { 15749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com return reinterpret_cast<LibcurlHttpFetcher*>(stream)-> 15849fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com LibcurlWrite(ptr, size, nmemb); 15949fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com } 16049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 16149fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Cleans up the following if they are non-null: 16229b815316519829f133b39dd1cae7ab6224c9da2Alex Deymo // curl(m) handles, fd_task_maps_, timeout_id_. 16349fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com void CleanUp(); 16449fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 1659ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov // Force terminate the transfer. This will invoke the delegate's (if any) 1669ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov // TransferTerminated callback so, after returning, this fetcher instance may 1679ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov // be destroyed. 1689ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov void ForceTransferTermination(); 1699ce452b6acd95899e9adb17c2935012625163dc6Darin Petkov 170b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan // Sets the curl options for HTTP URL. 171b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan void SetCurlOptionsForHttp(); 172b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan 173b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan // Sets the curl options for HTTPS URL. 174b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan void SetCurlOptionsForHttps(); 175b3f5540ee27bd53a28e3a3f87e2f5e80fb2a4876Jay Srinivasan 17656ccb072b55a48099c634a9dfb24e3af2b6213caAlex Deymo // Sets the curl options for file URI. 17756ccb072b55a48099c634a9dfb24e3af2b6213caAlex Deymo void SetCurlOptionsForFile(); 17856ccb072b55a48099c634a9dfb24e3af2b6213caAlex Deymo 17959d9e0142388f23dae84f7b480d24f1f71b80cfaGilad Arnold // Convert a proxy URL into a curl proxy type, if applicable. Returns true iff 18059d9e0142388f23dae84f7b480d24f1f71b80cfaGilad Arnold // conversion was successful, false otherwise (in which case nothing is 18159d9e0142388f23dae84f7b480d24f1f71b80cfaGilad Arnold // written to |out_type|). 18259d9e0142388f23dae84f7b480d24f1f71b80cfaGilad Arnold bool GetProxyType(const std::string& proxy, curl_proxytype* out_type); 18359d9e0142388f23dae84f7b480d24f1f71b80cfaGilad Arnold 184c1c17b4ed6a3896b6343e737fd89682fa0c8436bAlex Deymo // Hardware interface used to query dev-mode and official build settings. 185c1c17b4ed6a3896b6343e737fd89682fa0c8436bAlex Deymo HardwareInterface* hardware_; 186c1c17b4ed6a3896b6343e737fd89682fa0c8436bAlex Deymo 18749fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com // Handles for the libcurl library 18860ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo CURLM* curl_multi_handle_{nullptr}; 18960ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo CURL* curl_handle_{nullptr}; 19060ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo struct curl_slist* curl_http_headers_{nullptr}; 19149fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 192fdd6dec9c4be2fbd667cf874c4cc6f4ffecaeef9Alex Deymo // The extra headers that will be sent on each request. 193fdd6dec9c4be2fbd667cf874c4cc6f4ffecaeef9Alex Deymo std::map<std::string, std::string> extra_headers_; 194fdd6dec9c4be2fbd667cf874c4cc6f4ffecaeef9Alex Deymo 19560e1415b31b58bc17017d29c8e06f6e5452fdf4eDarin Petkov // Lists of all read(0)/write(1) file descriptors that we're waiting on from 19629b815316519829f133b39dd1cae7ab6224c9da2Alex Deymo // the message loop. libcurl may open/close descriptors and switch their 19760e1415b31b58bc17017d29c8e06f6e5452fdf4eDarin Petkov // directions so maintain two separate lists so that watch conditions can be 19860e1415b31b58bc17017d29c8e06f6e5452fdf4eDarin Petkov // set appropriately. 1993f39d5cc753905874d8d93bef94f857b8808f19eAlex Vakulenko std::map<int, brillo::MessageLoop::TaskId> fd_task_maps_[2]; 20049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 20160ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo // The TaskId of the timer we're waiting on. kTaskIdNull if we are not waiting 20260ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo // on it. 2033f39d5cc753905874d8d93bef94f857b8808f19eAlex Vakulenko brillo::MessageLoop::TaskId timeout_id_{brillo::MessageLoop::kTaskIdNull}; 20449fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 20529b815316519829f133b39dd1cae7ab6224c9da2Alex Deymo bool transfer_in_progress_{false}; 206f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo bool transfer_paused_{false}; 207f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo 208f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // Whether it should ignore transfer failures for the purpose of retrying the 209f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // connection. 210f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo bool ignore_failure_{false}; 211f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo 212f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // Whether we should restart the transfer once Unpause() is called. This can 213f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // be caused because either the connection dropped while pause or the proxy 214f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo // was resolved and we never started the transfer in the first place. 215f28585764e91b7c25a7c2856ff645c8bb22d64a9Alex Deymo bool restart_transfer_on_unpause_{false}; 21649fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 217c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // The transfer size. -1 if not known. 21860ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo off_t transfer_size_{0}; 219c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com 220c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // How many bytes have been downloaded and sent to the delegate. 22160ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo off_t bytes_downloaded_{0}; 222c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com 223e4ad2508de4d69d7a90d3ce441efe2c82c55bd1dGilad Arnold // The remaining maximum number of bytes to download. Zero represents an 224e4ad2508de4d69d7a90d3ce441efe2c82c55bd1dGilad Arnold // unspecified length. 22560ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo size_t download_length_{0}; 226e4ad2508de4d69d7a90d3ce441efe2c82c55bd1dGilad Arnold 227c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // If we resumed an earlier transfer, data offset that we used for the 228c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com // new connection. 0 otherwise. 2293fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // In this class, resume refers to resuming a dropped HTTP connection, 2303fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // not to resuming an interrupted download. 23160ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo off_t resume_offset_{0}; 232b83371f6d7fc12a66d33eac614c0fae3aa0978baDarin Petkov 23332f2357356546d3a4d1184fdbb6b664d620c6af1Jay Srinivasan // Number of resumes performed so far and the max allowed. 23460ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int retry_count_{0}; 23560ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int max_retry_count_{kDownloadMaxRetryCount}; 236c98a7edf648aad88b3f66df3b5a7d43d6a6d7fa9adlr@google.com 237b83371f6d7fc12a66d33eac614c0fae3aa0978baDarin Petkov // Seconds to wait before retrying a resume. 23860ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int retry_seconds_{20}; 239b83371f6d7fc12a66d33eac614c0fae3aa0978baDarin Petkov 240b20de692d8a258eeea7b88619e722b19edb5408fAlex Deymo // When waiting for a retry, the task id of the retry callback. 241b20de692d8a258eeea7b88619e722b19edb5408fAlex Deymo brillo::MessageLoop::TaskId retry_task_id_{brillo::MessageLoop::kTaskIdNull}; 242b20de692d8a258eeea7b88619e722b19edb5408fAlex Deymo 243a092955cdf763260563a774f6a68e1bfb38c5a8bDarin Petkov // Number of resumes due to no network (e.g., HTTP response code 0). 24460ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int no_network_retry_count_{0}; 24560ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int no_network_max_retries_{0}; 246a092955cdf763260563a774f6a68e1bfb38c5a8bDarin Petkov 247b83371f6d7fc12a66d33eac614c0fae3aa0978baDarin Petkov // Seconds to wait before asking libcurl to "perform". 24860ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int idle_seconds_{1}; 249fc7a0cec794ab43e66b6781ddb7f498b0ce257b9Darin Petkov 2503fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // If true, we are currently performing a write callback on the delegate. 25160ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo bool in_write_callback_{false}; 252a092955cdf763260563a774f6a68e1bfb38c5a8bDarin Petkov 2534516810fe41a39c0c55d2095679898787259ae38Andrew de los Reyes // If true, we have returned at least one byte in the write callback 2544516810fe41a39c0c55d2095679898787259ae38Andrew de los Reyes // to the delegate. 25560ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo bool sent_byte_{false}; 256fc7a0cec794ab43e66b6781ddb7f498b0ce257b9Darin Petkov 2573fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // We can't clean everything up while we're in a write callback, so 2583fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes // if we get a terminate request, queue it until we can handle it. 25960ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo bool terminate_requested_{false}; 2603fd5d30433509859bfdcc0b650e242981410c6a7Andrew de los Reyes 26133e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo // The ServerToCheck used when checking this connection's certificate. If no 26233e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo // certificate check needs to be performed, this should be set to 26333e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo // ServerToCheck::kNone. 26433e91e78bfe98c063b0c3b6d590976e275685686Alex Deymo ServerToCheck server_to_check_{ServerToCheck::kNone}; 2657f9aea2748370b0a26e1d5c36db7d8bbf3ba1245Bruno Rocha 26660ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int low_speed_limit_bps_{kDownloadLowSpeedLimitBps}; 26760ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int low_speed_time_seconds_{kDownloadLowSpeedTimeSeconds}; 26860ca1a7bca7cc804ec80b510483081ef894de4cdAlex Deymo int connect_timeout_seconds_{kDownloadConnectTimeoutSeconds}; 26934135a9f24c72137aa85378b57e7698162c687f2David Zeuthen 27049fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com DISALLOW_COPY_AND_ASSIGN(LibcurlHttpFetcher); 27149fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com}; 27249fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 27349fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com} // namespace chromeos_update_engine 27449fdf1889b965be25f929eeebc5b60cd40b9043rspangler@google.com 27514c0da88a93aa7b1aa71d5e7e923b537f0d419f3Alex Deymo#endif // UPDATE_ENGINE_LIBCURL_HTTP_FETCHER_H_ 276