/foundation/multimedia/av_codec/test/unittest/hls_test/ |
H A D | hls_media_downloader_unit_test.cpp | 285 HlsMediaDownloader *downloader = new HlsMediaDownloader(1000);
in HWTEST_F() local 286 EXPECT_EQ(downloader->expectDuration_, static_cast<uint64_t>(1000));
in HWTEST_F() 287 delete downloader;
in HWTEST_F() 288 downloader = nullptr;
in HWTEST_F() 293 HlsMediaDownloader *downloader = new HlsMediaDownloader(10);
in HWTEST_F() local 294 EXPECT_EQ(downloader->expectDuration_, static_cast<uint64_t>(10));
in HWTEST_F() 295 delete downloader;
in HWTEST_F() 296 downloader = nullptr;
in HWTEST_F() 301 HlsMediaDownloader *downloader = new HlsMediaDownloader(10);
in HWTEST_F() local 303 downloader in HWTEST_F() 315 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(); HWTEST_F() local 331 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(10); HWTEST_F() local 354 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(10); HWTEST_F() local 396 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(10); HWTEST_F() local 421 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(10); HWTEST_F() local 449 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(10); HWTEST_F() local 477 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(); HWTEST_F() local 509 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(); HWTEST_F() local 535 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(10); HWTEST_F() local 561 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(10); HWTEST_F() local 585 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(10); HWTEST_F() local 609 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>("application/m3u8"); HWTEST_F() local 644 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>("application/m3u8"); HWTEST_F() local 671 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>(10); HWTEST_F() local 695 std::shared_ptr<HlsMediaDownloader> downloader = std::make_shared<HlsMediaDownloader>("test"); HWTEST_F() local 719 HlsMediaDownloader *downloader = new HlsMediaDownloader(); HWTEST_F() local 743 HlsMediaDownloader *downloader = new HlsMediaDownloader(); HWTEST_F() local 753 HlsMediaDownloader *downloader = new HlsMediaDownloader(); HWTEST_F() local 763 HlsMediaDownloader *downloader = new HlsMediaDownloader(); HWTEST_F() local 773 HlsMediaDownloader *downloader = new HlsMediaDownloader(); HWTEST_F() local 783 HlsMediaDownloader *downloader = new HlsMediaDownloader(10); HWTEST_F() local 799 HlsMediaDownloader *downloader = new HlsMediaDownloader(10); HWTEST_F() local [all...] |
H A D | hls_playlist_downloader_unit_test.cpp | 48 HlsPlayListDownloader downloader;
in HWTEST_F() local 52 downloader.Open(testUrl, tmpHttpHeader);
in HWTEST_F() 53 EXPECT_EQ(testUrl, downloader.GetUrl());
in HWTEST_F() 54 EXPECT_EQ(nullptr, downloader.GetMaster());
in HWTEST_F() 61 HlsPlayListDownloader downloader;
in HWTEST_F() local 62 EXPECT_EQ(0, downloader.GetDuration());
in HWTEST_F() 63 downloader.Open(testUrl, httpHeader);
in HWTEST_F() 64 EXPECT_GE(downloader.GetDuration(), 0);
in HWTEST_F() 69 HlsPlayListDownloader downloader;
in HWTEST_F() local 70 downloader in HWTEST_F() 76 HlsPlayListDownloader downloader; HWTEST_F() local 83 HlsPlayListDownloader downloader; HWTEST_F() local 92 HlsPlayListDownloader downloader; HWTEST_F() local 101 HlsPlayListDownloader downloader; HWTEST_F() local 111 HlsPlayListDownloader downloader; HWTEST_F() local 120 HlsPlayListDownloader downloader; HWTEST_F() local 131 HlsPlayListDownloader downloader; HWTEST_F() local 138 HlsPlayListDownloader downloader; HWTEST_F() local 145 HlsPlayListDownloader downloader; HWTEST_F() local 152 HlsPlayListDownloader downloader; HWTEST_F() local [all...] |
/foundation/multimedia/av_codec/test/unittest/dash_test/ |
H A D | dash_mpd_downloader_unit_test.cpp | 51 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in SetUpTestCase() 222 DashMpdDownloader downloader; in HWTEST_F() local 224 downloader.SetHdrStart(true); in HWTEST_F() 225 downloader.Open(testUrl); in HWTEST_F() 226 downloader.GetSeekable(); in HWTEST_F() 227 int usingStreamId = downloader.GetInUseVideoStreamId(); in HWTEST_F() 228 std::shared_ptr<DashStreamDescription> stream = downloader.GetStreamByStreamId(usingStreamId); in HWTEST_F() 231 downloader.Close(true); in HWTEST_F() 236 DashMpdDownloader downloader; in HWTEST_F() local 238 downloader in HWTEST_F() 247 DashMpdDownloader downloader; HWTEST_F() local 258 DashMpdDownloader downloader; HWTEST_F() local 269 DashMpdDownloader downloader; HWTEST_F() local [all...] |
H A D | dash_segment_downloader_unit_test.cpp | 82 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 109 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 139 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 163 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 209 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 245 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 295 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 328 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 351 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 407 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() [all...] |
H A D | dash_media_downloader_unit_test.cpp | 48 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in SetUpTestCase() 213 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 267 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 324 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 381 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 400 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F() 430 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in HWTEST_F()
|
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_source/monitor/ |
H A D | download_monitor.cpp | 27 DownloadMonitor::DownloadMonitor(std::shared_ptr<MediaDownloader> downloader) noexcept 28 : downloader_(std::move(downloader)) in move() 30 auto statusCallback = [this] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in move() 32 OnDownloadStatus(std::forward<decltype(downloader)>(downloader), std::forward<decltype(request)>(request)); in move() 182 // The current thread is the downloader thread, Therefore, the thread must be stopped asynchronously. in NeedRetry() 191 void DownloadMonitor::OnDownloadStatus(std::shared_ptr<Downloader>& downloader, in OnDownloadStatus() argument 194 FALSE_RETURN_MSG(downloader != nullptr, "downloader is null, url is " PUBLIC_LOG_S, request->GetUrl().c_str()); in OnDownloadStatus() 201 RetryRequest retryRequest {request, [downloader, reques in OnDownloadStatus() [all...] |
H A D | download_monitor.h | 28 #include "plugin/plugins/source/http_source/download/downloader.h" 42 explicit DownloadMonitor(std::shared_ptr<MediaDownloader> downloader) noexcept; 62 void OnDownloadStatus(std::shared_ptr<Downloader>& downloader, std::shared_ptr<DownloadRequest>& request);
|
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/monitor/ |
H A D | download_monitor.cpp | 33 DownloadMonitor::DownloadMonitor(std::shared_ptr<MediaDownloader> downloader) noexcept 34 : downloader_(std::move(downloader)) in move() 36 auto statusCallback = [this] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in move() 42 OnDownloadStatus(std::forward<decltype(downloader)>(downloader), std::forward<decltype(request)>(request)); in move() 190 MEDIA_LOG_I("Media downloader buffering timeout, don't need retry."); in NeedRetry() 229 void DownloadMonitor::OnDownloadStatus(std::shared_ptr<Downloader>& downloader, in OnDownloadStatus() argument 232 FALSE_RETURN_MSG(downloader != nullptr, "downloader is nullptr."); in OnDownloadStatus() 239 RetryRequest retryRequest {request, [downloader, reques in OnDownloadStatus() [all...] |
H A D | download_monitor.h | 29 #include "download/downloader.h" 45 explicit DownloadMonitor(std::shared_ptr<MediaDownloader> downloader) noexcept; 84 void OnDownloadStatus(std::shared_ptr<Downloader>& downloader, std::shared_ptr<DownloadRequest>& request);
|
/foundation/multimedia/av_codec/test/unittest/http_source_test/ |
H A D | http_media_downloader_unit_test.cpp | 41 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader,
in SetUpTestCase() 85 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader,
in HWTEST_F() 108 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader,
in HWTEST_F() 133 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader,
in HWTEST_F() 158 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader,
in HWTEST_F() 186 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader,
in HWTEST_F() 249 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader,
in HWTEST_F() 271 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader,
in HWTEST_F() 293 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader,
in HWTEST_F() 315 auto statusCallback = [] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader,
in HWTEST_F() [all...] |
H A D | downloader_unit_test.cpp | 16 #include "download/downloader.h" 34 std::shared_ptr<Downloader> downloader; member in OHOS::Media::Plugins::HttpPlugin::DownloaderUnitTest 47 downloader = std::make_shared<Downloader>("test"); in SetUp() 52 downloader.reset(); in TearDown() 57 EXPECT_NE(downloader->client_, nullptr); in HWTEST_F()
|
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/ |
H A D | http_source_plugin.cpp | 349 std::shared_ptr<MediaDownloader> downloader = downloader_; in SeekToTime() local 350 FALSE_RETURN_V(downloader != nullptr, Status::ERROR_NULL_POINTER); in SeekToTime() 351 FALSE_RETURN_V(downloader->GetSeekable() == Seekable::SEEKABLE, Status::ERROR_INVALID_OPERATION); in SeekToTime() 352 FALSE_RETURN_V(seekTime <= downloader->GetDuration(), Status::ERROR_INVALID_PARAMETER); in SeekToTime() 353 FALSE_RETURN_V(downloader->SeekToTime(seekTime, mode), Status::ERROR_UNKNOWN); in SeekToTime() 361 std::shared_ptr<MediaDownloader> downloader = downloader_; in CloseUri() local 362 if (downloader != nullptr) { in CloseUri() 364 downloader->Close(true); in CloseUri() 462 FALSE_RETURN_MSG(downloader_ != nullptr, "WaitForBufferingEnd downloader is nullptr"); in WaitForBufferingEnd()
|
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/ |
H A D | mod.rs | 19 mod downloader; modules 22 pub use downloader::{DownloadOperator, Downloader, DownloaderBuilder};
|
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/dash/ |
H A D | dash_media_downloader.cpp | 135 [&](const std::shared_ptr<DashSegmentDownloader> &downloader) { in GetSegmentDownloaderByType() 136 return downloader->GetStreamType() == type; in GetSegmentDownloaderByType() 203 for (auto downloader : segmentDownloaders_) { in GetSeekable() 204 status = downloader->GetStartedStatus(); in GetSeekable() 395 std::shared_ptr<DashSegmentDownloader> downloader = std::make_shared<DashSegmentDownloader>( in OpenInitSegment() local 398 downloader->SetStatusCallback(statusCallback_); in OpenInitSegment() 403 downloader->SetDownloadDoneCallback(doneCallback); in OpenInitSegment() 404 segmentDownloaders_.push_back(downloader); in OpenInitSegment() 408 downloader->SetInitSegment(initSeg); in OpenInitSegment() 410 downloader in OpenInitSegment() 750 std::shared_ptr<DashSegmentDownloader> downloader = GetSegmentDownloaderByType(streamDesc->type_); SelectAudioInternal() local 803 std::shared_ptr<DashSegmentDownloader> downloader = GetSegmentDownloaderByType(streamDesc->type_); SelectSubtitleInternal() local [all...] |
H A D | dash_segment_downloader.cpp | 979 auto realStatusCallback = [this](DownloadStatus &&status, std::shared_ptr<Downloader> &downloader,
|
H A D | dash_mpd_downloader.cpp | 776 auto realStatusCallback = [this](DownloadStatus &&status, std::shared_ptr<Downloader> &downloader, in DoOpen()
|
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/hls/ |
H A D | playlist_downloader.cpp | 65 PlayListDownloader::PlayListDownloader(std::shared_ptr<Downloader> downloader, 68 downloader_ = downloader; 80 auto realStatusCallback = [this] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in DoOpen() 213 FALSE_RETURN_V_MSG_E(downloader_ != nullptr, false, "downloader nullptr"); in SaveData()
|
H A D | playlist_downloader.h | 21 #include "download/downloader.h" 43 explicit PlayListDownloader(std::shared_ptr<Downloader> downloader,
|
H A D | m3u8.cpp | 292 auto realStatusCallback = [this](DownloadStatus &&status, std::shared_ptr<Downloader> &downloader, in DownloadKey()
|
H A D | hls_media_downloader.cpp | 155 auto realStatusCallback = [this] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in PutRequestIntoDownloader() 1031 // To avoid downloader potentially stopped by curl error caused by break readbuffer blocking in seeking in PushPlayInfo()
|
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_source/hls/ |
H A D | playlist_downloader.cpp | 48 auto realStatusCallback = [this] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in DoOpen()
|
H A D | hls_media_downloader.cpp | 64 auto realStatusCallback = [this] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in PutRequestIntoDownloader()
|
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_source/http/ |
H A D | http_media_downloader.cpp | 52 auto realStatusCallback = [this] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in Open()
|
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/http/ |
H A D | http_media_downloader.cpp | 173 auto realStatusCallback = [this] (DownloadStatus&& status, std::shared_ptr<Downloader>& downloader, in Open()
|