Searched defs:fetcher (Results 1 - 7 of 7) sorted by relevance

/system/update_engine/common/
H A Dmulti_range_http_fetcher.cc88 void MultiRangeHttpFetcher::ReceivedBytes(HttpFetcher* fetcher, argument
92 CHECK_EQ(fetcher, base_fetcher_.get());
106 // Terminates the current fetcher. Waits for its TransferTerminated
112 fetcher->TerminateTransfer();
117 void MultiRangeHttpFetcher::TransferEnded(HttpFetcher* fetcher, argument
120 CHECK_EQ(fetcher, base_fetcher_.get());
122 http_response_code_ = fetcher->http_response_code();
164 void MultiRangeHttpFetcher::TransferComplete(HttpFetcher* fetcher, argument
167 TransferEnded(fetcher, successful);
170 void MultiRangeHttpFetcher::TransferTerminated(HttpFetcher* fetcher) { argument
[all...]
H A Dhttp_fetcher.h89 // Begins the transfer to the specified URL. This fetcher instance should not
114 // These two function are overloaded in LibcurlHttp fetcher to speed
131 // Get the total number of bytes downloaded by fetcher.
186 virtual void ReceivedBytes(HttpFetcher* fetcher,
190 // Called if the fetcher seeks to a particular offset.
196 // situations. It's OK to destroy the |fetcher| object in this callback.
197 virtual void TransferComplete(HttpFetcher* fetcher, bool successful) = 0;
198 virtual void TransferTerminated(HttpFetcher* fetcher) {} argument
/system/update_engine/payload_consumer/
H A Ddownload_action.cc220 // Tweak timeouts on the HTTP fetcher if we're downloading from a
224 LOG(INFO) << "Tweaking HTTP fetcher since we're downloading via p2p";
259 void DownloadAction::ReceivedBytes(HttpFetcher* fetcher, argument
279 // the TransferTerminated callback. Otherwise, this and the HTTP fetcher
295 void DownloadAction::TransferComplete(HttpFetcher* fetcher, bool successful) { argument
321 void DownloadAction::TransferTerminated(HttpFetcher *fetcher) { argument
/system/update_engine/
H A Dupdate_attempter_android.cc205 HttpFetcher* fetcher = download_action_->http_fetcher(); local
207 fetcher->SetHeader("Authorization", headers[kPayloadPropertyAuthorization]);
209 fetcher->SetHeader("User-Agent", headers[kPayloadPropertyUserAgent]);
486 MultiRangeHttpFetcher* fetcher = local
488 fetcher->ClearRanges();
495 fetcher->AddRange(base_offset_,
505 fetcher->AddRange(base_offset_ + resume_offset);
507 fetcher->AddRange(base_offset_ + resume_offset,
512 fetcher->AddRange(base_offset_, install_plan_.payload_size);
516 fetcher
[all...]
H A Domaha_request_action_unittest.cc316 MockHttpFetcher* fetcher = new MockHttpFetcher(http_response.data(), local
320 fetcher->FailTransfer(fail_http_response_code);
326 brillo::make_unique_ptr(fetcher),
365 *out_post_data = fetcher->post_data();
378 MockHttpFetcher* fetcher = new MockHttpFetcher(http_response.data(), local
385 brillo::make_unique_ptr(fetcher),
400 *out_post_data = fetcher->post_data();
H A Dupdate_attempter.cc1392 MultiRangeHttpFetcher* fetcher = local
1394 fetcher->ClearRanges();
1401 fetcher->AddRange(0, manifest_metadata_size + manifest_signature_size);
1410 fetcher->AddRange(resume_offset);
1413 fetcher->AddRange(0);
H A Domaha_request_action.cc654 void OmahaRequestAction::ReceivedBytes(HttpFetcher *fetcher, argument
896 void OmahaRequestAction::TransferComplete(HttpFetcher *fetcher, argument

Completed in 328 milliseconds