Home
last modified time | relevance | path

Searched refs:availableInputBufferQueue_ (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/screensinkprocessor/decoder/src/
H A Dimage_sink_decoder.cpp423 availableInputBufferQueue_.push(buffer); in OnInputBufferAvailable()
465 std::queue<std::shared_ptr<Media::AVSharedMemory>>().swap(availableInputBufferQueue_); in StopInputThread()
484 !availableInputBufferQueue_.empty()); in DecodeScreenData()
491 …deoDataQueue_.empty() || availableInputIndexsQueue_.empty() || availableInputBufferQueue_.empty())… in DecodeScreenData()
518 if (availableInputBufferQueue_.empty()) { in ProcessData()
523 std::shared_ptr<Media::AVSharedMemory> inputBuffer = availableInputBufferQueue_.front(); in ProcessData()
546 availableInputBufferQueue_.pop(); in ProcessData()
/ohos5.0/foundation/distributedhardware/distributed_screen/services/screendemo/
H A Ddecoder_demo.cpp237 …ck, [this]() { return signal_->inQueue_.size() > 0 && signal_->availableInputBufferQueue_.size() >… in InputFunc()
244 std::shared_ptr<Media::AVSharedMemory> buffer = signal_->availableInputBufferQueue_.front(); in InputFunc()
275 signal_->availableInputBufferQueue_.pop(); in InputFunc()
325 signal_->availableInputBufferQueue_.push(buffer); in OnInputBufferAvailable()
H A Ddecoder_demo.h38 std::queue<std::shared_ptr<Media::AVSharedMemory>> availableInputBufferQueue_; variable
/ohos5.0/foundation/distributedhardware/distributed_camera/services/data_process/src/pipeline_node/multimedia_codec/decoder/
H A Ddecode_data_process.cpp329 std::queue<std::shared_ptr<Media::AVSharedMemory>>().swap(availableInputBufferQueue_); in ReleaseProcessNode()
412 …if (buffer == nullptr || availableInputIndexsQueue_.empty() || availableInputBufferQueue_.empty())… in FeedDecoderInputBuffer()
415 … inputBuffersQueue_.size(), availableInputIndexsQueue_.size(), availableInputBufferQueue_.size()); in FeedDecoderInputBuffer()
429 … std::shared_ptr<Media::AVSharedMemory> sharedMemoryInput = availableInputBufferQueue_.front(); in FeedDecoderInputBuffer()
474 availableInputBufferQueue_.pop(); in IncreaseWaitDecodeCnt()
679 availableInputBufferQueue_.push(buffer); in OnInputBufferAvailable()
H A Ddecode_data_process_common.cpp376 std::queue<std::shared_ptr<Media::AVSharedMemory>>().swap(availableInputBufferQueue_); in ReleaseProcessNode()
459 …if (buffer == nullptr || availableInputIndexsQueue_.empty() || availableInputBufferQueue_.empty())… in FeedDecoderInputBuffer()
462 … inputBuffersQueue_.size(), availableInputIndexsQueue_.size(), availableInputBufferQueue_.size()); in FeedDecoderInputBuffer()
476 … std::shared_ptr<Media::AVSharedMemory> sharedMemoryInput = availableInputBufferQueue_.front(); in FeedDecoderInputBuffer()
521 availableInputBufferQueue_.pop(); in IncreaseWaitDecodeCnt()
726 availableInputBufferQueue_.push(buffer); in OnInputBufferAvailable()
/ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/test/unittest/screensinkprocessor/src/
H A Dimage_sink_decoder_test.cpp464 imageDecoder_->availableInputBufferQueue_.push(buffer);
480 imageDecoder_->availableInputBufferQueue_.push(buffer);
496 imageDecoder_->availableInputBufferQueue_.push(buffer);
/ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/screensinkprocessor/decoder/include/
H A Dimage_sink_decoder.h103 std::queue<std::shared_ptr<Media::AVSharedMemory>> availableInputBufferQueue_; variable
/ohos5.0/foundation/distributedhardware/distributed_camera/services/data_process/include/pipeline_node/multimedia_codec/decoder/
H A Ddecode_data_process.h143 std::queue<std::shared_ptr<Media::AVSharedMemory>> availableInputBufferQueue_; variable