HomeSort by relevance Sort by last modified time
    Searched refs:fetcher (Results 1 - 25 of 84) sorted by null

1 2 3 4

  /system/update_engine/common/
http_fetcher_unittest.cc 194 // Class hierarchy for HTTP fetcher test wrappers.
371 // Infrastructure for type tests of HTTP fetcher.
417 void ReceivedBytes(HttpFetcher* /* fetcher */,
425 void TransferComplete(HttpFetcher* fetcher, bool successful) override {
427 EXPECT_EQ(kHttpResponseNotFound, fetcher->http_response_code());
429 EXPECT_EQ(kHttpResponseOk, fetcher->http_response_code());
436 void TransferTerminated(HttpFetcher* fetcher) override {
462 unique_ptr<HttpFetcher> fetcher(this->test_.NewSmallFetcher());
463 fetcher->set_delegate(&delegate);
470 fetcher.get()
    [all...]
multi_range_http_fetcher.cc 88 void MultiRangeHttpFetcher::ReceivedBytes(HttpFetcher* fetcher,
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,
120 CHECK_EQ(fetcher, base_fetcher_.get());
122 http_response_code_ = fetcher->http_response_code();
164 void MultiRangeHttpFetcher::TransferComplete(HttpFetcher* fetcher,
167 TransferEnded(fetcher, successful);
170 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 89 // 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) {}
  /system/update_engine/payload_consumer/
download_action.h 98 void ReceivedBytes(HttpFetcher* fetcher,
101 void TransferComplete(HttpFetcher* fetcher, bool successful) override;
102 void TransferTerminated(HttpFetcher* fetcher) override;
download_action.cc 220 // 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,
279 // the TransferTerminated callback. Otherwise, this and the HTTP fetcher
295 void DownloadAction::TransferComplete(HttpFetcher* fetcher, bool successful) {
321 void DownloadAction::TransferTerminated(HttpFetcher *fetcher) {
  /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,
  /system/update_engine/
update_attempter_android.cc 205 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->AddRange(base_offset_)
    [all...]
omaha_request_action.h 165 void ReceivedBytes(HttpFetcher *fetcher,
168 void TransferComplete(HttpFetcher *fetcher, bool successful) override;
update_attempter_unittest.cc 223 unique_ptr<MockHttpFetcher> fetcher(new MockHttpFetcher("", 0, nullptr));
224 fetcher->FailTransfer(503); // Sets the HTTP response code.
225 DownloadAction action(prefs_, nullptr, nullptr, nullptr, fetcher.release());
244 unique_ptr<MockHttpFetcher> fetcher(new MockHttpFetcher("", 0, nullptr));
245 fetcher->FailTransfer(500); // Sets the HTTP response code.
247 std::move(fetcher), false);
    [all...]
update_attempter.cc 1392 MultiRangeHttpFetcher* fetcher = local
    [all...]
omaha_request_action_unittest.cc 316 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();
    [all...]
omaha_request_action.cc 654 void OmahaRequestAction::ReceivedBytes(HttpFetcher *fetcher,
    [all...]
  /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.
  /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 582 // Otherwise, we check if mPacketSources2 overlaps with what old fetcher
585 // lastEnqueueMeta == NULL means old fetcher stopped at a discontinuity
590 // no need to resume old fetcher if new fetcher started in different
603 // (old fetcher might still need to resumeUntil the start time of new fetcher)
673 ALOGV("fetcher-%d %s",
697 ALOGV("%zu fetcher(s) left", mContinuationCounter);
740 const sp<PlaylistFetcher> &fetcher = mFetcherInfos.valueAt(i).mFetcher; local
741 if (fetcher != NULL)
1234 sp<PlaylistFetcher> &fetcher = mFetcherInfos.editValueAt(index).mFetcher; local
1561 sp<PlaylistFetcher> &fetcher = mFetcherInfos.editValueAt(i).mFetcher; local
1832 sp<PlaylistFetcher> fetcher = addFetcher(uri.c_str()); local
    [all...]
  /packages/services/Telephony/src/com/android/phone/vvm/omtp/
ActivationTask.java 174 try (StatusSmsFetcher fetcher = new StatusSmsFetcher(getContext(), subId)) {
176 // Both the fetcher and OmtpMessageReceiver will be triggered, but
179 data = fetcher.get();
  /cts/tests/tests/accounts/src/android/accounts/cts/
AccountManagerTest.java 166 private void validateSuccessfulTokenFetchingLifecycle(TokenFetcher fetcher, String tokenType)
168 Account account = fetcher.getAccount();
174 Bundle actual = fetcher.fetch(tokenType);
183 actual = fetcher.fetch(tokenType);
201 actual = fetcher.fetch(tokenType);
213 actual = fetcher.fetch(tokenType);
    [all...]
  /frameworks/base/core/java/android/app/
SystemServiceRegistry.java 791 ServiceFetcher<?> fetcher = SYSTEM_SERVICE_FETCHERS.get(name); local
    [all...]
  /external/autotest/client/common_lib/
base_packages.py 449 for fetcher in reversed(repositories):
457 fetcher.fetch_pkg_file(pkg_name, dest_path)
    [all...]
  /external/jemalloc/bin/
jeprof.in     [all...]
  /prebuilts/gradle-plugin/com/android/tools/sdklib/22.8.0/
sdklib-22.8.0.jar 
  /prebuilts/gradle-plugin/com/android/tools/sdklib/22.9.2/
sdklib-22.9.2.jar 
  /prebuilts/gradle-plugin/com/android/tools/sdklib/23.0.1/
sdklib-23.0.1.jar 

Completed in 1159 milliseconds

1 2 3 4