| /system/update_engine/common/ |
| D | http_fetcher_unittest.cc | 445 void TransferComplete(HttpFetcher* fetcher, bool successful) override { in TransferComplete() argument
447 EXPECT_EQ(kHttpResponseNotFound, fetcher->http_response_code()); in TransferComplete()
449 EXPECT_EQ(kHttpResponseOk, fetcher->http_response_code()); in TransferComplete()
456 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 …]
|
| D | multi_range_http_fetcher.cc | 87 bool MultiRangeHttpFetcher::ReceivedBytes(HttpFetcher* fetcher, in ReceivedBytes() argument
91 CHECK_EQ(fetcher, base_fetcher_.get()); in ReceivedBytes()
114 fetcher->TerminateTransfer(); in ReceivedBytes()
121 void MultiRangeHttpFetcher::TransferEnded(HttpFetcher* fetcher, in TransferEnded() argument
124 CHECK_EQ(fetcher, base_fetcher_.get()); in TransferEnded()
126 http_response_code_ = fetcher->http_response_code(); in TransferEnded()
168 void MultiRangeHttpFetcher::TransferComplete(HttpFetcher* fetcher, in TransferComplete() argument
171 TransferEnded(fetcher, successful); in TransferComplete()
174 void MultiRangeHttpFetcher::TransferTerminated(HttpFetcher* fetcher) { in TransferTerminated() argument
176 TransferEnded(fetcher, false); in TransferTerminated()
|
| D | multi_range_http_fetcher.h | 153 bool ReceivedBytes(HttpFetcher* fetcher,
158 void TransferEnded(HttpFetcher* fetcher, bool successful);
160 void TransferComplete(HttpFetcher* fetcher, bool successful) override;
161 void TransferTerminated(HttpFetcher* fetcher) override;
|
| D | download_action.h | 99 bool ReceivedBytes(HttpFetcher* fetcher,
103 void TransferComplete(HttpFetcher* fetcher, bool successful) override;
104 void TransferTerminated(HttpFetcher* fetcher) override;
|
| D | http_fetcher.h | 188 virtual bool ReceivedBytes(HttpFetcher* fetcher,
199 virtual void TransferComplete(HttpFetcher* fetcher, bool successful) = 0;
200 virtual void TransferTerminated(HttpFetcher* fetcher) {} in TransferTerminated() argument
|
| /system/core/fs_mgr/libsnapshot/ |
| D | utility.cpp | 224 auto fetcher = IPropertyFetcher::GetInstance(); in GetLegacyCompressionEnabledProperty() local
225 return fetcher->GetBoolProperty("ro.virtual_ab.compression.enabled", false); in GetLegacyCompressionEnabledProperty()
229 auto fetcher = IPropertyFetcher::GetInstance(); in GetUserspaceSnapshotsEnabledProperty() local
230 return fetcher->GetBoolProperty("ro.virtual_ab.userspace.snapshots.enabled", false); in GetUserspaceSnapshotsEnabledProperty()
234 auto fetcher = IPropertyFetcher::GetInstance(); in IsVendorFromAndroid12() local
238 fetcher->GetProperty("ro.vendor.build.version.release_or_codename", UNKNOWN); in IsVendorFromAndroid12()
266 auto fetcher = IPropertyFetcher::GetInstance(); in GetIouringEnabledProperty() local
267 return fetcher->GetBoolProperty("ro.virtual_ab.io_uring.enabled", false); in GetIouringEnabledProperty()
271 auto fetcher = IPropertyFetcher::GetInstance(); in GetXorCompressionEnabledProperty() local
272 return fetcher->GetBoolProperty("ro.virtual_ab.compression.xor.enabled", false); in GetXorCompressionEnabledProperty()
[all …]
|
| D | snapshot_test.cpp | 155 auto fetcher = std::make_unique<SnapshotTestPropertyFetcher>("_a", std::move(properties)); in SetupProperties() local
156 IPropertyFetcher::OverrideForTesting(std::move(fetcher)); in SetupProperties()
|
| /system/core/fs_mgr/liblp/ |
| D | property_fetcher.cpp | 43 void IPropertyFetcher::OverrideForTesting(std::unique_ptr<IPropertyFetcher>&& fetcher) { in OverrideForTesting() argument
44 GetInstanceAllocation()->swap(fetcher); in OverrideForTesting()
45 fetcher.reset(); in OverrideForTesting()
|
| /system/libvintf/test/ |
| D | vintf_object_tests.cpp | 434 MockFileSystem& fetcher() { in fetcher() function in android::vintf::testing::VintfObjectTestBase
445 EXPECT_CALL(fetcher(), listFiles(_, _, _)).Times(AnyNumber()) in useEmptyFileSystem()
447 EXPECT_CALL(fetcher(), fetch(_, _)).Times(AnyNumber()) in useEmptyFileSystem()
458 ON_CALL(fetcher(), fetch(StrEq(kVendorLegacyManifest), _)) in setupMockFetcher()
465 ON_CALL(fetcher(), fetch(StrEq(kSystemManifest), _)) in setupMockFetcher()
472 ON_CALL(fetcher(), fetch(StrEq(kVendorLegacyMatrix), _)) in setupMockFetcher()
478 ON_CALL(fetcher(), fetch(StrEq(kSystemLegacyMatrix), _)) in setupMockFetcher()
497 Mock::VerifyAndClear(&fetcher()); in TearDown()
501 EXPECT_CALL(fetcher(), fetch(StrEq(kVendorLegacyManifest), _)).Times(times); in expectVendorManifest()
505 EXPECT_CALL(fetcher(), fetch(StrEq(kSystemManifest), _)).Times(times); in expectSystemManifest()
[all …]
|
| /system/update_engine/ |
| D | download_action.cc | 215 bool DownloadAction::ReceivedBytes(HttpFetcher* fetcher, in ReceivedBytes() argument
245 void DownloadAction::TransferComplete(HttpFetcher* fetcher, bool successful) { in TransferComplete() argument
280 void DownloadAction::TransferTerminated(HttpFetcher* fetcher) { in TransferTerminated() argument
286 TransferComplete(fetcher, true); in TransferTerminated()
|
| D | libcurl_http_fetcher.cc | 84 LibcurlHttpFetcher* fetcher = static_cast<LibcurlHttpFetcher*>(clientp); in LibcurlCloseSocketCallback() local
86 for (size_t t = 0; t < base::size(fetcher->fd_controller_maps_); ++t) { in LibcurlCloseSocketCallback()
87 fetcher->fd_controller_maps_[t].erase(item); in LibcurlCloseSocketCallback()
|
| /system/update_engine/aosp/ |
| D | update_attempter_android.cc | 362 HttpFetcher* fetcher = nullptr; in ApplyPayload() local
365 fetcher = new FileFetcher(); in ApplyPayload()
378 fetcher = libcurl_fetcher; in ApplyPayload()
383 fetcher->SetHeader("Authorization", headers[kPayloadPropertyAuthorization]); in ApplyPayload()
385 fetcher->SetHeader("User-Agent", headers[kPayloadPropertyUserAgent]); in ApplyPayload()
390 fetcher->SetProxies({headers[kPayloadPropertyNetworkProxy]}); in ApplyPayload()
406 BuildUpdateActions(fetcher); in ApplyPayload()
893 void UpdateAttempterAndroid::BuildUpdateActions(HttpFetcher* fetcher) { in BuildUpdateActions() argument
907 fetcher, // passes ownership in BuildUpdateActions()
|
| D | update_attempter_android.h | 165 void BuildUpdateActions(HttpFetcher* fetcher);
|
| /system/core/fastboot/device/ |
| D | commands.cpp | 761 PartitionFetcher fetcher(device, args); in Fetch() local
762 if (fetcher.Open()) { in Fetch()
763 fetcher.Fetch(); in Fetch()
765 CHECK(fetcher.ret_.has_value()); in Fetch()
766 return *fetcher.ret_; in Fetch()
|
| /system/tools/hidl/test/hidl_test/ |
| D | hidl_test_client.cpp | 348 sp<IFetcher> fetcher; member in HidlEnvironment
392 fetcher = IFetcher::getService("fetcher", mode == PASSTHROUGH /* getStub */); in getServices()
393 ASSERT_NE(fetcher, nullptr); in getServices()
394 ASSERT_EQ(fetcher->isRemote(), mode == BINDERIZED); in getServices()
444 sp<IFetcher> fetcher; member in HidlTest
460 fetcher = gHidlEnvironment->fetcher; in SetUp()
1785 Return<sp<IGrandparent>> ret = fetcher->getGrandparent(true); in TEST_F()
1791 Return<sp<IGrandparent>> ret = fetcher->getGrandparent(false); in TEST_F()
1797 Return<sp<IParent>> ret = fetcher->getParent(true); in TEST_F()
1803 Return<sp<IParent>> ret = fetcher->getParent(false); in TEST_F()
[all …]
|