Home
last modified time | relevance | path

Searched refs:fetcher (Results 1 – 15 of 15) sorted by relevance

/system/update_engine/common/
Dhttp_fetcher_unittest.cc444 void TransferComplete(HttpFetcher* fetcher, bool successful) override { in TransferComplete() argument
446 EXPECT_EQ(kHttpResponseNotFound, fetcher->http_response_code()); in TransferComplete()
448 EXPECT_EQ(kHttpResponseOk, fetcher->http_response_code()); in TransferComplete()
455 void TransferTerminated(HttpFetcher* fetcher) override { in TransferTerminated() argument
479 unique_ptr<HttpFetcher> fetcher(this->test_.NewSmallFetcher()); in TYPED_TEST() local
480 fetcher->set_delegate(&delegate); in TYPED_TEST()
487 fetcher.get(), in TYPED_TEST()
495 unique_ptr<HttpFetcher> fetcher(this->test_.NewLargeFetcher()); in TYPED_TEST() local
496 fetcher->set_delegate(&delegate); in TYPED_TEST()
504 StartTransfer, fetcher.get(), this->test_.BigUrl(server->GetPort()))); in TYPED_TEST()
[all …]
Dmulti_range_http_fetcher.cc89 bool MultiRangeHttpFetcher::ReceivedBytes(HttpFetcher* fetcher, in ReceivedBytes() argument
93 CHECK_EQ(fetcher, base_fetcher_.get()); in ReceivedBytes()
116 fetcher->TerminateTransfer(); in ReceivedBytes()
123 void MultiRangeHttpFetcher::TransferEnded(HttpFetcher* fetcher, in TransferEnded() argument
126 CHECK_EQ(fetcher, base_fetcher_.get()); in TransferEnded()
128 http_response_code_ = fetcher->http_response_code(); in TransferEnded()
170 void MultiRangeHttpFetcher::TransferComplete(HttpFetcher* fetcher, in TransferComplete() argument
173 TransferEnded(fetcher, successful); in TransferComplete()
176 void MultiRangeHttpFetcher::TransferTerminated(HttpFetcher* fetcher) { in TransferTerminated() argument
178 TransferEnded(fetcher, false); in TransferTerminated()
Dmulti_range_http_fetcher.h147 bool ReceivedBytes(HttpFetcher* fetcher,
152 void TransferEnded(HttpFetcher* fetcher, bool successful);
154 void TransferComplete(HttpFetcher* fetcher, bool successful) override;
155 void TransferTerminated(HttpFetcher* fetcher) override;
Dhttp_fetcher.h190 virtual bool ReceivedBytes(HttpFetcher* fetcher,
201 virtual void TransferComplete(HttpFetcher* fetcher, bool successful) = 0;
202 virtual void TransferTerminated(HttpFetcher* fetcher) {} in TransferTerminated() argument
/system/libvintf/test/
Dvintf_object_tests.cpp353 MockFileSystem& fetcher() { in fetcher() function in android::vintf::testing::VintfObjectTestBase
365 ON_CALL(fetcher(), listFiles(StrEq(kVendorManifestFragmentDir), _, _)) in setupMockFetcher()
367 ON_CALL(fetcher(), listFiles(StrEq(kSystemManifestFragmentDir), _, _)) in setupMockFetcher()
369 ON_CALL(fetcher(), listFiles(StrEq(kOdmManifestFragmentDir), _, _)) in setupMockFetcher()
371 ON_CALL(fetcher(), listFiles(StrEq(kProductManifestFragmentDir), _, _)) in setupMockFetcher()
375 ON_CALL(fetcher(), in setupMockFetcher()
378 ON_CALL(fetcher(), fetch(StrEq(kOdmVintfDir + "manifest_" + productModel + ".xml"), _)) in setupMockFetcher()
381 ON_CALL(fetcher(), fetch(StrEq(kOdmLegacyManifest), _)) in setupMockFetcher()
383 ON_CALL(fetcher(), fetch(StrEq(kOdmManifest), _)) in setupMockFetcher()
385 ON_CALL(fetcher(), fetch(StrEq(kVendorManifest), _)) in setupMockFetcher()
[all …]
/system/update_engine/payload_consumer/
Ddownload_action.h97 bool ReceivedBytes(HttpFetcher* fetcher,
101 void TransferComplete(HttpFetcher* fetcher, bool successful) override;
102 void TransferTerminated(HttpFetcher* fetcher) override;
Ddownload_action.cc320 bool DownloadAction::ReceivedBytes(HttpFetcher* fetcher, in ReceivedBytes() argument
361 void DownloadAction::TransferComplete(HttpFetcher* fetcher, bool successful) { in TransferComplete() argument
416 void DownloadAction::TransferTerminated(HttpFetcher* fetcher) { in TransferTerminated() argument
422 TransferComplete(fetcher, true); in TransferTerminated()
/system/update_engine/
Dupdate_attempter_android.cc260 HttpFetcher* fetcher = nullptr; in ApplyPayload() local
263 fetcher = new FileFetcher(); in ApplyPayload()
271 fetcher = libcurl_fetcher; in ApplyPayload()
276 fetcher->SetHeader("Authorization", headers[kPayloadPropertyAuthorization]); in ApplyPayload()
278 fetcher->SetHeader("User-Agent", headers[kPayloadPropertyUserAgent]); in ApplyPayload()
280 BuildUpdateActions(fetcher); in ApplyPayload()
622 void UpdateAttempterAndroid::BuildUpdateActions(HttpFetcher* fetcher) { in BuildUpdateActions() argument
635 fetcher, // passes ownership in BuildUpdateActions()
Domaha_request_action.h172 bool ReceivedBytes(HttpFetcher* fetcher,
176 void TransferComplete(HttpFetcher* fetcher, bool successful) override;
Dlibcurl_http_fetcher.cc78 LibcurlHttpFetcher* fetcher = static_cast<LibcurlHttpFetcher*>(clientp); in LibcurlCloseSocketCallback() local
80 for (size_t t = 0; t < arraysize(fetcher->fd_task_maps_); ++t) { in LibcurlCloseSocketCallback()
81 const auto fd_task_pair = fetcher->fd_task_maps_[t].find(item); in LibcurlCloseSocketCallback()
82 if (fd_task_pair != fetcher->fd_task_maps_[t].end()) { in LibcurlCloseSocketCallback()
88 fetcher->fd_task_maps_[t].erase(item); in LibcurlCloseSocketCallback()
Dupdate_attempter_android.h111 void BuildUpdateActions(HttpFetcher* fetcher);
Dupdate_attempter_unittest.cc231 unique_ptr<MockHttpFetcher> fetcher(new MockHttpFetcher("", 0, nullptr)); in TEST_F() local
232 fetcher->FailTransfer(503); // Sets the HTTP response code. in TEST_F()
237 fetcher.release(), in TEST_F()
337 unique_ptr<MockHttpFetcher> fetcher(new MockHttpFetcher("", 0, nullptr)); in TEST_F() local
338 fetcher->FailTransfer(500); // Sets the HTTP response code. in TEST_F()
340 &fake_system_state_, nullptr, std::move(fetcher), false); in TEST_F()
Domaha_request_action_unittest.cc269 auto fetcher = static_cast<const MockHttpFetcher*>( in ActionCompleted() local
274 fetcher->GetHeader("X-Goog-Update-Interactivity")); in ActionCompleted()
275 EXPECT_EQ(kTestAppId, fetcher->GetHeader("X-Goog-Update-AppId")); in ActionCompleted()
276 EXPECT_NE("", fetcher->GetHeader("X-Goog-Update-Updater")); in ActionCompleted()
278 post_data_ = fetcher->post_data(); in ActionCompleted()
419 auto fetcher = std::make_unique<MockHttpFetcher>( in TestUpdateCheck() local
422 fetcher->FailTransfer(fail_http_response_code); in TestUpdateCheck()
429 &fake_system_state_, nullptr, std::move(fetcher), ping_only); in TestUpdateCheck()
Domaha_request_action.cc863 bool OmahaRequestAction::ReceivedBytes(HttpFetcher* fetcher, in ReceivedBytes() argument
1211 void OmahaRequestAction::TransferComplete(HttpFetcher* fetcher, in TransferComplete() argument
/system/tools/hidl/test/hidl_test/
Dhidl_test_client.cpp367 sp<IFetcher> fetcher; member in HidlEnvironment
408 fetcher = IFetcher::getService("fetcher", mode == PASSTHROUGH /* getStub */); in getServices()
409 ASSERT_NE(fetcher, nullptr); in getServices()
410 ASSERT_EQ(fetcher->isRemote(), mode == BINDERIZED); in getServices()
472 sp<IFetcher> fetcher; member in HidlTest
491 fetcher = gHidlEnvironment->fetcher; in SetUp()
1809 Return<sp<IGrandparent>> ret = fetcher->getGrandparent(true); in TEST_F()
1815 Return<sp<IGrandparent>> ret = fetcher->getGrandparent(false); in TEST_F()
1821 Return<sp<IParent>> ret = fetcher->getParent(true); in TEST_F()
1827 Return<sp<IParent>> ret = fetcher->getParent(false); in TEST_F()
[all …]