| /foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/http/ |
| H A D | http_media_downloader.cpp | 370 while (ringBuffer_->GetSize() < readDataInfo.wantReadLength_ && !isInterruptNeeded_.load()) { in ReadRingBuffer()
385 if (isInterruptNeeded_.load()) { in ReadRingBuffer()
420 while (hasReadSize < readDataInfo.wantReadLength_ && !isInterruptNeeded_.load()) { in ReadCacheBuffer()
433 if (isInterruptNeeded_.load()) { in ReadCacheBuffer()
489 FALSE_RETURN_V_MSG(!isInterruptNeeded_.load(), Status::END_OF_STREAM, "isInterruptNeeded"); in ReadDelegate()
501 FALSE_RETURN_V_MSG(!isInterruptNeeded_.load(), Status::END_OF_STREAM, "isInterruptNeeded"); in ReadDelegate()
749 return downloadRequest_->IsChunked(isInterruptNeeded_); in GetSeekable()
824 while (hasWriteSize < len && !isInterruptNeeded_.load() && !isInterrupt_.load()) { in SaveCacheBufferData()
848 while (!isInterrupt_.load() && !isNeedClean_.load() && !canWrite_.load() && !isInterruptNeeded_.load()) { in SaveCacheBufferData()
858 if (isInterruptNeeded_ in SaveCacheBufferData()
[all...] |
| H A D | http_media_downloader.h | 149 std::atomic<bool> isInterruptNeeded_{false};
|
| /foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/download/ |
| H A D | downloader.cpp | 117 isInterruptNeeded_ = isInterruptNeeded; in IsChunked()
165 while (!isHeaderUpdated && times_ < RETRY_TIMES && !isInterruptNeeded_ && !headerInfo_.isClosed) { in WaitHeaderUpdated()
336 FALSE_RETURN_MSG(!isDestructor_ && !isInterruptNeeded_, "not Resume. is Destructor or InterruptNeeded"); in Resume()
362 currentRequest_->isInterruptNeeded_ = true; in Stop()
385 FALSE_RETURN_V_MSG(!isDestructor_ && !isInterruptNeeded_, false, "not Seek. is Destructor or InterruptNeeded"); in Seek()
423 FALSE_RETURN_V_MSG(client_ != nullptr && !isDestructor_ && !isInterruptNeeded_, false, in Retry()
433 FALSE_RETURN_V(client_ != nullptr && !shouldStartNextRequest && !isDestructor_ && !isInterruptNeeded_, false); in Retry()
440 FALSE_RETURN_V(client_ != nullptr && !shouldStartNextRequest && !isDestructor_ && !isInterruptNeeded_, false); in Retry()
948 isInterruptNeeded_ = isInterruptNeeded; in SetInterruptState()
950 currentRequest_->isInterruptNeeded_ in SetInterruptState()
[all...] |
| H A D | downloader.h | 149 std::atomic<bool> isInterruptNeeded_{false};
209 std::atomic<bool> isInterruptNeeded_{false};
|
| /foundation/multimedia/av_codec/services/media_engine/modules/source/ |
| H A D | source.cpp | 279 if (protocol_ == "http" && isInterruptNeeded_) { in OnEvent()
329 isInterruptNeeded_ = isInterruptNeeded; in SetInterruptState()
331 plugin_->SetInterruptState(isInterruptNeeded_); in SetInterruptState()
453 plugin_->SetInterruptState(isInterruptNeeded_); in FindPlugin()
|
| H A D | source.h | 134 std::atomic<bool> isInterruptNeeded_{false};
|
| /foundation/multimedia/player_framework/services/engine/histreamer/avmetadatahelper/ |
| H A D | avmetadatahelper_impl.cpp | 86 mediaDemuxer_->SetInterruptState(isInterruptNeeded_.load()); in SetSourceInternel()
227 isInterruptNeeded_ = isInterruptNeeded; in SetInterruptState()
|
| H A D | avmetadatahelper_impl.h | 72 std::atomic<bool> isInterruptNeeded_ = false; member in OHOS::Media::AVMetadataHelperImpl
|
| /foundation/multimedia/av_codec/services/media_engine/modules/demuxer/ |
| H A D | stream_demuxer.cpp | 92 FALSE_RETURN_V_MSG_E(!isInterruptNeeded_.load(), Status::ERROR_WRONG_STATE, in GetPeekRange()
237 while (true && !isInterruptNeeded_.load()) { in ReadRetry()
249 FALSE_LOG_MSG(!isInterruptNeeded_.load(), "ReadRetry interrupted"); in ReadRetry()
410 FALSE_RETURN_V(!isInterruptNeeded_.load(), Status::ERROR_WRONG_STATE); in CallbackReadAt()
|
| H A D | base_stream_demuxer.cpp | 90 isInterruptNeeded_ = isInterruptNeeded;
in SetInterruptState()
|
| H A D | base_stream_demuxer.h | 134 std::atomic<bool> isInterruptNeeded_{false};
|
| H A D | media_demuxer.h | 280 std::atomic<bool> isInterruptNeeded_ {false};
|
| /foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/ |
| H A D | http_source_plugin.h | 81 std::atomic<bool> isInterruptNeeded_{false};
|
| H A D | http_source_plugin.cpp | 237 downloader_->SetInterruptState(isInterruptNeeded_); in SetDownloaderBySource()
319 isInterruptNeeded_ = isInterruptNeeded; in SetInterruptState()
|
| /foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/hls/ |
| H A D | hls_playlist_downloader.cpp | 100 while (times < RETRY_TIMES && !isInterruptNeeded_) { in GetSeekable()
107 if (times >= RETRY_TIMES || isInterruptNeeded_) { in GetSeekable()
|
| H A D | hls_media_downloader.cpp | 442 FALSE_RETURN_V_MSG(!isInterruptNeeded_.load(), Status::END_OF_STREAM, "eos, isInterruptNeeded"); in ReadDelegate()
670 while (hasWriteSize < len && !isInterruptNeeded_.load() && !isInterrupt_) { in SaveCacheBufferData()
696 while (!isInterrupt_ && !canWrite_.load() && !isInterruptNeeded_.load()) { in SaveCacheBufferData()
706 if (isInterruptNeeded_.load() || isInterrupt_) { in SaveCacheBufferData()
1342 isInterruptNeeded_ = isInterruptNeeded; in SetInterruptState()
1343 if (isInterruptNeeded_) { in SetInterruptState()
1540 while (sleepTime < ONE_SECONDS && !isInterruptNeeded_.load()) { in CheckBufferingOneSeconds()
1655 isBuffering_.load(), isInterruptNeeded_.load()); in WaitForBufferingEnd()
1656 return !isBuffering_.load() || isInterruptNeeded_.load(); in WaitForBufferingEnd()
|
| H A D | playlist_downloader.h | 118 std::atomic<bool> isInterruptNeeded_{false};
|
| H A D | playlist_downloader.cpp | 325 isInterruptNeeded_ = isInterruptNeeded; in SetInterruptState()
|
| H A D | hls_media_downloader.h | 202 std::atomic<bool> isInterruptNeeded_{false};
|
| /foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/dash/ |
| H A D | dash_media_downloader.h | 110 std::atomic<bool> isInterruptNeeded_{false};
|
| H A D | dash_media_downloader.cpp | 102 DashReadRet ret = segmentDownloader->Read(buff, readDataInfo, isInterruptNeeded_); in Read()
202 while (!status && times < RETRY_TIMES && !isInterruptNeeded_) { in GetSeekable()
213 if (times >= RETRY_TIMES || isInterruptNeeded_) { in GetSeekable()
1011 isInterruptNeeded_ = isInterruptNeeded; in SetInterruptState()
|
| H A D | dash_mpd_downloader.h | 255 std::atomic<bool> isInterruptNeeded_{false};
|
| /foundation/multimedia/av_codec/test/unittest/http_source_test/ |
| H A D | http_source_plugin_unit_test.cpp | 381 EXPECT_EQ(httpSourcePlugin->isInterruptNeeded_, isInterruptNeeded); in HWTEST_F()
388 EXPECT_EQ(httpSourcePlugin->isInterruptNeeded_, isInterruptNeeded); in HWTEST_F()
|
| /foundation/multimedia/av_codec/interfaces/inner_api/native/ |
| H A D | decoder_surface_filter.h | 163 std::atomic<bool> isInterruptNeeded_{false};
|
| /foundation/multimedia/av_codec/services/media_engine/filters/ |
| H A D | decoder_surface_filter.cpp | 391 if (prerollDone_.load() || isInterruptNeeded_.load()) { in DoWaitPrerollDone()
395 [this] () { return prerollDone_.load() || isInterruptNeeded_.load(); }); in DoWaitPrerollDone()
501 isInterruptNeeded_ = isInterruptNeeded; in SetInterruptState()
|