| /system/libvintf/ |
| utils.cpp | 23 static FileFetcher fetcher; member in namespace:android::vintf::details
24 FileFetcher* gFetcher = &fetcher;
|
| /system/libvintf/test/ |
| vintf_object_tests.cpp | 170 MockFileFetcher* fetcher = static_cast<MockFileFetcher*>(gFetcher); local
172 ON_CALL(*fetcher, fetch(StrEq("/vendor/manifest.xml"), _))
178 ON_CALL(*fetcher, fetch(StrEq("/system/manifest.xml"), _))
184 ON_CALL(*fetcher, fetch(StrEq("/vendor/compatibility_matrix.xml"), _))
190 ON_CALL(*fetcher, fetch(StrEq("/system/compatibility_matrix.xml"), _))
201 static MockFileFetcher &fetcher() { function
215 Mock::VerifyAndClear(&fetcher());
225 EXPECT_CALL(fetcher(), fetch(StrEq("/vendor/manifest.xml"), _));
226 EXPECT_CALL(fetcher(), fetch(StrEq("/system/manifest.xml"), _));
227 EXPECT_CALL(fetcher(), fetch(StrEq("/vendor/compatibility_matrix.xml"), _))
445 NiceMock<MockFileFetcher> fetcher; local
[all...] |
| /system/update_engine/common/ |
| http_fetcher_unittest.cc | 192 // Class hierarchy for HTTP fetcher test wrappers.
369 // Infrastructure for type tests of HTTP fetcher.
415 void ReceivedBytes(HttpFetcher* /* fetcher */,
423 void TransferComplete(HttpFetcher* fetcher, bool successful) override {
425 EXPECT_EQ(kHttpResponseNotFound, fetcher->http_response_code());
427 EXPECT_EQ(kHttpResponseOk, fetcher->http_response_code());
434 void TransferTerminated(HttpFetcher* fetcher) override {
459 unique_ptr<HttpFetcher> fetcher(this->test_.NewSmallFetcher());
460 fetcher->set_delegate(&delegate);
467 fetcher.get()
[all...] |
| multi_range_http_fetcher.cc | 89 void MultiRangeHttpFetcher::ReceivedBytes(HttpFetcher* fetcher,
93 CHECK_EQ(fetcher, base_fetcher_.get());
107 // Terminates the current fetcher. Waits for its TransferTerminated
113 fetcher->TerminateTransfer();
118 void MultiRangeHttpFetcher::TransferEnded(HttpFetcher* fetcher,
121 CHECK_EQ(fetcher, base_fetcher_.get());
123 http_response_code_ = fetcher->http_response_code();
165 void MultiRangeHttpFetcher::TransferComplete(HttpFetcher* fetcher,
168 TransferEnded(fetcher, successful);
171 void MultiRangeHttpFetcher::TransferTerminated(HttpFetcher* fetcher) {
[all...] |
| multi_range_http_fetcher.h | 30 // from those offsets, using the same bash fetcher for all ranges. Thus, the
31 // fetcher must support beginning a transfer after one has stopped. Pass -1
47 // Takes ownership of the passed in fetcher.
92 // These functions are overloaded in LibcurlHttp fetcher for testing purposes.
149 void ReceivedBytes(HttpFetcher* fetcher,
154 void TransferEnded(HttpFetcher* fetcher, bool successful);
156 void TransferComplete(HttpFetcher* fetcher, bool successful) override;
157 void TransferTerminated(HttpFetcher* fetcher) override;
166 // If true, the next fetcher needs to be started when TransferTerminated is
167 // received from the current fetcher
[all...] |
| http_fetcher.h | 88 // Begins the transfer to the specified URL. This fetcher instance should not
113 // These two function are overloaded in LibcurlHttp fetcher to speed
130 // Get the total number of bytes downloaded by fetcher.
190 virtual void ReceivedBytes(HttpFetcher* fetcher,
194 // Called if the fetcher seeks to a particular offset.
200 // situations. It's OK to destroy the |fetcher| object in this callback.
201 virtual void TransferComplete(HttpFetcher* fetcher, bool successful) = 0;
202 virtual void TransferTerminated(HttpFetcher* fetcher) {}
|
| /packages/apps/Car/Media/src/com/android/car/media/drawer/ |
| MediaDrawerController.java | 83 MediaItemsFetcher fetcher; local
85 fetcher = createMediaQueueItemsFetcher();
87 fetcher = createMediaBrowserItemFetcher(item.getMediaId(),
90 setupAdapterAndSwitch(fetcher, item.getDescription().getTitle());
118 * @param fetcher The {@link MediaItemsFetcher} that is responsible for fetching the items to be
122 private void setupAdapterAndSwitch(MediaItemsFetcher fetcher, CharSequence title) {
124 subAdapter.setFetcher(fetcher);
|
| MediaDrawerAdapter.java | 28 * {@link MediaItemsFetcher}. The current fetcher being used can be updated at runtime.
65 * Switch the {@link MediaItemsFetcher} being used to fetch items. The new fetcher is kicked-off
66 * and the drawer's content's will be updated to show newly loaded items. Any old fetcher is
69 * @param fetcher New {@link MediaItemsFetcher} to use for display Drawer items.
71 void setFetcher(MediaItemsFetcher fetcher) {
75 mCurrentFetcher = fetcher;
|
| /system/update_engine/payload_consumer/ |
| download_action.h | 99 void ReceivedBytes(HttpFetcher* fetcher,
102 void TransferComplete(HttpFetcher* fetcher, bool successful) override;
103 void TransferTerminated(HttpFetcher* fetcher) override;
|
| download_action.cc | 272 // Tweak timeouts on the HTTP fetcher if we're downloading from a
276 LOG(INFO) << "Tweaking HTTP fetcher since we're downloading via p2p";
311 void DownloadAction::ReceivedBytes(HttpFetcher* fetcher,
333 // the TransferTerminated callback. Otherwise, this and the HTTP fetcher
349 void DownloadAction::TransferComplete(HttpFetcher* fetcher, bool successful) {
386 void DownloadAction::TransferTerminated(HttpFetcher* fetcher) {
392 TransferComplete(fetcher, true);
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
| DecodeJob.java | 37 private final DataFetcher<A> fetcher; field in class:DecodeJob
48 public DecodeJob(EngineKey resultKey, int width, int height, DataFetcher<A> fetcher,
51 this(resultKey, width, height, fetcher, loadProvider, transformation, transcoder, diskCache, diskCacheStrategy,
56 DecodeJob(EngineKey resultKey, int width, int height, DataFetcher<A> fetcher,
62 this.fetcher = fetcher;
132 fetcher.cancel();
169 final A data = fetcher.loadData(priority);
178 fetcher.cleanup();
|
| Engine.java | 126 * @param fetcher The fetcher to use to retrieve data not in the disk cache.
140 public <T, Z, R> LoadStatus load(Key signature, int width, int height, DataFetcher<T> fetcher,
146 final String id = fetcher.getId();
187 DecodeJob<T, Z, R> decodeJob = new DecodeJob<T, Z, R>(key, width, height, fetcher, loadProvider, transformation,
|
| /packages/apps/Dialer/java/com/android/voicemail/impl/ |
| StatusCheckTask.java | 87 try (StatusSmsFetcher fetcher = new StatusSmsFetcher(getContext(), getPhoneAccountHandle())) {
88 config.getProtocol().requestStatus(config, fetcher.getSentIntent());
89 // Both the fetcher and OmtpMessageReceiver will be triggered, but
92 data = fetcher.get();
|
| ActivationTask.java | 191 try (StatusSmsFetcher fetcher = new StatusSmsFetcher(getContext(), phoneAccountHandle)) {
192 protocol.startActivation(helper, fetcher.getSentIntent());
193 // Both the fetcher and OmtpMessageReceiver will be triggered, but
196 data = fetcher.get();
|
| /frameworks/av/drm/mediacas/plugins/clearkey/tests/ |
| ClearKeyFetcherTest.cpp | 87 ClearKeyFetcher fetcher(std::move(license_fetcher_));
91 ClearKeyFetcher fetcher(std::move(license_fetcher_));
92 EXPECT_EQ(OK, fetcher.Init());
95 EXPECT_EQ(OK, fetcher.ObtainKey(ecm_, &asset_id, &keys));
|
| /external/autotest/client/bin/ |
| harness_autoserv.py | 38 # set up the package fetcher for direct-from-autoserv fetches
39 fetcher = AutoservFetcher(self.job.pkgmgr, self)
40 self.job.pkgmgr.add_repository(fetcher)
109 # fetcher: see crosbug.com/35080.
|
| /system/update_engine/ |
| omaha_request_action.h | 166 void ReceivedBytes(HttpFetcher *fetcher,
169 void TransferComplete(HttpFetcher *fetcher, bool successful) override;
|
| libcurl_http_fetcher.cc | 78 LibcurlHttpFetcher* fetcher = static_cast<LibcurlHttpFetcher*>(clientp); local
80 for (size_t t = 0; t < arraysize(fetcher->fd_task_maps_); ++t) {
81 const auto fd_task_pair = fetcher->fd_task_maps_[t].find(item);
82 if (fd_task_pair != fetcher->fd_task_maps_[t].end()) {
88 fetcher->fd_task_maps_[t].erase(item);
111 << "Destroying the fetcher while a transfer is in progress.";
414 // the fetcher is unpaused.
556 LOG(ERROR) << "Fetcher already paused.";
571 LOG(ERROR) << "Resume attempted when fetcher not paused.";
|
| update_attempter_android.cc | 212 HttpFetcher* fetcher = download_action_->http_fetcher(); local
214 fetcher->SetHeader("Authorization", headers[kPayloadPropertyAuthorization]);
216 fetcher->SetHeader("User-Agent", headers[kPayloadPropertyUserAgent]);
|
| update_attempter_unittest.cc | 216 unique_ptr<MockHttpFetcher> fetcher(new MockHttpFetcher("", 0, nullptr));
217 fetcher->FailTransfer(503); // Sets the HTTP response code.
218 DownloadAction action(prefs_, nullptr, nullptr, nullptr, fetcher.release());
236 unique_ptr<MockHttpFetcher> fetcher(new MockHttpFetcher("", 0, nullptr));
237 fetcher->FailTransfer(500); // Sets the HTTP response code.
239 std::move(fetcher), false);
[all...] |
| omaha_request_action_unittest.cc | 365 MockHttpFetcher* fetcher = new MockHttpFetcher(http_response.data(), local
369 fetcher->FailTransfer(fail_http_response_code);
375 brillo::make_unique_ptr(fetcher),
414 *out_post_data = fetcher->post_data();
427 MockHttpFetcher* fetcher = new MockHttpFetcher(http_response.data(), local
434 brillo::make_unique_ptr(fetcher),
448 *out_post_data = fetcher->post_data();
699 MockHttpFetcher* fetcher = local
702 &fake_system_state_, nullptr, brillo::make_unique_ptr(fetcher), false);
712 // Check that the headers were set in the fetcher during the action. Note tha
[all...] |
| /external/glide/library/src/main/java/com/bumptech/glide/load/data/ |
| MediaStoreThumbFetcher.java | 54 ThumbnailStreamOpener fetcher = factory.build(mediaStoreUri, width, height); local
56 if (fetcher != null) {
57 inputStream = fetcher.open(context, mediaStoreUri);
|
| /frameworks/av/media/libstagefright/httplive/ |
| LiveSession.cpp | 585 // Otherwise, we check if mPacketSources2 overlaps with what old fetcher
588 // lastEnqueueMeta == NULL means old fetcher stopped at a discontinuity
593 // no need to resume old fetcher if new fetcher started in different
606 // (old fetcher might still need to resumeUntil the start time of new fetcher)
682 ALOGV("fetcher-%d %s",
706 ALOGV("%zu fetcher(s) left", mContinuationCounter);
749 const sp<PlaylistFetcher> &fetcher = mFetcherInfos.valueAt(i).mFetcher; local
750 if (fetcher != NULL)
1246 sp<PlaylistFetcher> &fetcher = mFetcherInfos.editValueAt(index).mFetcher; local
1576 sp<PlaylistFetcher> &fetcher = mFetcherInfos.editValueAt(i).mFetcher; local
1847 sp<PlaylistFetcher> fetcher = addFetcher(uri.c_str()); local
[all...] |
| /system/tools/hidl/test/ |
| hidl_test_client.cpp | 368 sp<IFetcher> fetcher; member in class:HidlEnvironment
405 fetcher = IFetcher::getService("fetcher", mode == PASSTHROUGH /* getStub */);
406 ASSERT_NE(fetcher, nullptr);
407 ASSERT_EQ(fetcher->isRemote(), mode == BINDERIZED);
452 sp<IFetcher> fetcher; member in class:HidlTest
467 fetcher = gHidlEnvironment->fetcher;
581 "android.hardware.tests.inheritance@1.0::IFetcher/fetcher",
[all...] |
| /frameworks/support/compat/java/android/support/v4/provider/ |
| FontsContractCompat.java | 221 final Callable<Typeface> fetcher = new Callable<Typeface>() { local
234 return sBackgroundThread.postAndWait(fetcher, timeout);
261 sBackgroundThread.postAndReply(fetcher, new ReplyCallback<Typeface>() {
[all...] |
