Home
last modified time | relevance | path

Searched refs:BlockingQueue (Results 1 - 25 of 28) sorted by relevance

12

/foundation/multimedia/media_foundation/engine/plugin/plugins/codec_adapter/
H A Dcodec_buffer_pool.h47 Status UseBuffers(OHOS::Media::BlockingQueue<std::shared_ptr<Buffer>>& bufQue, MemoryType bufMemType,
67 OHOS::Media::BlockingQueue<uint32_t> freeBufferId_;
H A Dcodec_buffer_pool.cpp35 Status CodecBufferPool::UseBuffers(OHOS::Media::BlockingQueue<std::shared_ptr<Buffer>>& bufQue, MemoryType bufMemType, in UseBuffers()
H A Dhdi_codec_adapter.h80 std::shared_ptr<OHOS::Media::BlockingQueue<std::shared_ptr<Buffer>>> outBufQue_{};
H A Dhdi_codec_adapter.cpp210 OHOS::Media::BlockingQueue<std::shared_ptr<Buffer>> inBufQue("TempInBufferQue", inBufferCnt_); in Prepare()
394 outBufQue_ = std::make_shared<BlockingQueue<std::shared_ptr<Buffer>>>("hdiAdapterOutQueue", outBufferCnt_); in ConfigOmx()
/foundation/multimedia/media_foundation/interface/inner_api/osal/task/
H A Dblocking_queue.h31 class BlockingQueue { class
33 explicit BlockingQueue(std::string name, size_t capacity = 10) // 10 means default queue size in BlockingQueue() function in OHOS::Media::BlockingQueue
37 ~BlockingQueue() = default;
162 static constexpr OHOS::HiviewDFX::HiLogLabel LABEL = { LOG_CORE, LOG_DOMAIN_FOUNDATION, "BlockingQueue" };
/foundation/multimedia/media_foundation/engine/include/foundation/utils/
H A Dblocking_queue.h32 class BlockingQueue { class
34 explicit BlockingQueue(std::string name, size_t capacity = DEFAULT_QUEUE_SIZE) in BlockingQueue() function in OHOS::Media::BlockingQueue
38 ~BlockingQueue() = default;
/foundation/multimedia/media_foundation/engine/include/pipeline/filters/codec/video_encoder/
H A Dvideo_encoder_filter.h113 std::shared_ptr<OHOS::Media::BlockingQueue<AVBufferPtr>> inBufQue_ {nullptr};
114 std::shared_ptr<OHOS::Media::BlockingQueue<AVBufferPtr>> outBufQue_ {nullptr};
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/
H A Dblocking_queue.h30 class BlockingQueue { class
32 explicit BlockingQueue(const std::string& name, size_t capacity = 0) in BlockingQueue() function in OHOS::CameraStandard::DeferredProcessing::BlockingQueue
36 ~BlockingQueue() = default;
/foundation/multimedia/camera_framework/services/camera_service/include/avcodec/
H A Daudio_capturer_session.h46 BlockingQueue<sptr<AudioRecord>> audioBufferQueue_;
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/task_manager/task_group/
H A Dbase_task_group.h56 BlockingQueue<std::any> que_;
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_source/hls/
H A Dhls_media_downloader.h67 std::shared_ptr<BlockingQueue<PlayInfo>> playList_;
H A Dhls_media_downloader.cpp45 playList_ = std::make_shared<BlockingQueue<PlayInfo>>("PlayList", 50); // 50
/foundation/multimedia/media_foundation/engine/scene/recorder/internal/
H A Dstate_machine.h89 Media::BlockingQueue<Job> jobs_;
/foundation/multimedia/media_foundation/engine/scene/player/internal/
H A Dstate_machine.h85 Media::BlockingQueue<Job> jobs_;
/foundation/multimedia/media_foundation/engine/pipeline/filters/codec/
H A Dasync_mode.h72 std::shared_ptr<OHOS::Media::BlockingQueue<OHOS::Media::AVBufferPtr>> inBufQue_ {nullptr};
H A Dasync_mode.cpp325 inBufQue_ = std::make_shared<BlockingQueue<AVBufferPtr>>("asyncFilterInBufQue", GetInBufferPoolSize()); in Prepare()
/foundation/multimedia/media_foundation/engine/plugin/plugins/ffmpeg_adapter/video_encoder/
H A Dvideo_ffmpeg_encoder_plugin.h126 OHOS::Media::BlockingQueue<std::shared_ptr<Buffer>> outBufferQ_;
/foundation/multimedia/media_foundation/engine/include/pipeline/filters/sink/video_sink/
H A Dvideo_sink_filter.h93 std::shared_ptr<OHOS::Media::BlockingQueue<AVBufferPtr>> inBufQueue_ {nullptr};
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_source/download/
H A Ddownloader.h140 std::shared_ptr<BlockingQueue<std::shared_ptr<DownloadRequest>>> requestQue_;
H A Ddownloader.cpp123 requestQue_ = std::make_shared<BlockingQueue<std::shared_ptr<DownloadRequest>>>(name_ + "RequestQue", in move()
/foundation/multimedia/media_foundation/engine/plugin/plugins/ffmpeg_adapter/video_decoder/
H A Dvideo_ffmpeg_decoder_plugin.h146 OHOS::Media::BlockingQueue<std::shared_ptr<Buffer>> outBufferQ_;
/foundation/multimedia/media_foundation/engine/pipeline/filters/codec/video_encoder/
H A Dvideo_encoder_filter.cpp128 outBufQue_ = std::make_shared<BlockingQueue<AVBufferPtr>>("vdecFilterOutBufQue", DEFAULT_OUT_BUFFER_POOL_SIZE); in Prepare()
137 inBufQue_ = std::make_shared<BlockingQueue<AVBufferPtr>>("vecFilterInBufQue", DEFAULT_IN_BUFFER_POOL_SIZE); in Prepare()
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/download/
H A Ddownloader.h200 std::shared_ptr<BlockingQueue<std::shared_ptr<DownloadRequest>>> requestQue_;
/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/hls/
H A Dhls_media_downloader.h169 std::shared_ptr<BlockingQueue<PlayInfo>> playList_;
/foundation/multimedia/media_foundation/engine/pipeline/filters/sink/video_sink/
H A Dvideo_sink_filter.cpp72 inBufQueue_ = std::make_shared<BlockingQueue<AVBufferPtr>>("VideoSinkInBufQue", VSINK_DEFAULT_BUFFER_NUM); in Init()

Completed in 12 milliseconds

12