Chromium Code Reviews| Index: libcurl_http_fetcher.cc |
| diff --git a/libcurl_http_fetcher.cc b/libcurl_http_fetcher.cc |
| index c8468125f042aabd5a67eaf765b3d02e12ed17c2..9cacf869b96f1ba40b0253e333b5d5aedd045e07 100644 |
| --- a/libcurl_http_fetcher.cc |
| +++ b/libcurl_http_fetcher.cc |
| @@ -3,11 +3,19 @@ |
| // found in the LICENSE file. |
| #include "update_engine/libcurl_http_fetcher.h" |
| + |
| #include <algorithm> |
| -#include "base/logging.h" |
| +#include <string> |
| + |
| +#include <base/logging.h> |
| + |
| +#include "update_engine/dbus_interface.h" |
| +#include "update_engine/flimflam_proxy.h" |
| +#include "update_engine/utils.h" |
| using std::max; |
| using std::make_pair; |
| +using std::string; |
| // This is a concrete implementation of HttpFetcher that uses libcurl to do the |
| // http work. |
| @@ -17,12 +25,24 @@ namespace chromeos_update_engine { |
| namespace { |
| const int kMaxRetriesCount = 20; |
| const char kCACertificatesPath[] = "/usr/share/update_engine/ca-certificates"; |
| -} |
| +} // namespace {} |
| LibcurlHttpFetcher::~LibcurlHttpFetcher() { |
| CleanUp(); |
| } |
| +// On error, returns false. |
| +bool LibcurlHttpFetcher::ConnectionIsExpensive() const { |
| + if (force_connection_type_) |
| + return forced_expensive_connection_; |
| + NetworkConnectionType type; |
| + ConcreteDbusGlib dbus_iface; |
| + TEST_AND_RETURN_FALSE(FlimFlamProxy::GetConnectionType(&dbus_iface, &type)); |
| + LOG(INFO) << "We are connected via " |
| + << FlimFlamProxy::StringForConnectionType(type); |
| + return FlimFlamProxy::IsExpensiveConnectionType(type); |
| +} |
| + |
| void LibcurlHttpFetcher::ResumeTransfer(const std::string& url) { |
| LOG(INFO) << "Starting/Resuming transfer"; |
| CHECK(!transfer_in_progress_); |
| @@ -54,7 +74,18 @@ void LibcurlHttpFetcher::ResumeTransfer(const std::string& url) { |
| CHECK_EQ(curl_easy_setopt(curl_handle_, CURLOPT_WRITEDATA, this), CURLE_OK); |
| CHECK_EQ(curl_easy_setopt(curl_handle_, CURLOPT_WRITEFUNCTION, |
| StaticLibcurlWrite), CURLE_OK); |
| - CHECK_EQ(curl_easy_setopt(curl_handle_, CURLOPT_URL, url_.c_str()), CURLE_OK); |
| + |
| + string url_to_use(url_); |
| + if (ConnectionIsExpensive()) { |
|
petkov
2010/10/21 05:15:19
If the device switches from WiFi to 3G in the midd
adlr
2010/10/21 19:41:14
This code path is called for every connection or r
|
| + LOG(INFO) << "Not initiating HTTP connection b/c we are on an expensive" |
| + << " connection"; |
| + url_to_use = ""; // Sabotage the URL |
| + } |
| + |
| + CHECK_EQ(curl_easy_setopt(curl_handle_, |
| + CURLOPT_URL, |
| + url_to_use.c_str()), |
| + CURLE_OK); |
| // If the connection drops under 10 bytes/sec for 3 minutes, reconnect. |
| CHECK_EQ(curl_easy_setopt(curl_handle_, CURLOPT_LOW_SPEED_LIMIT, 10), |