Home
last modified time | relevance | path

Searched refs:availableInputIndexsQueue_ (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/screensinkprocessor/decoder/src/
H A Dimage_sink_decoder.cpp422 availableInputIndexsQueue_.push(index); in OnInputBufferAvailable()
464 std::queue<int32_t>().swap(availableInputIndexsQueue_); in StopInputThread()
483 return (!videoDataQueue_.empty() && !availableInputIndexsQueue_.empty() && in DecodeScreenData()
491 …if (videoDataQueue_.empty() || availableInputIndexsQueue_.empty() || availableInputBufferQueue_.em… in DecodeScreenData()
495 bufferIndex = availableInputIndexsQueue_.front(); in DecodeScreenData()
496 availableInputIndexsQueue_.pop(); in DecodeScreenData()
/ohos5.0/foundation/distributedhardware/distributed_camera/services/data_process/src/pipeline_node/multimedia_codec/decoder/
H A Ddecode_data_process.cpp328 std::queue<uint32_t>().swap(availableInputIndexsQueue_); in ReleaseProcessNode()
412 …if (buffer == nullptr || availableInputIndexsQueue_.empty() || availableInputBufferQueue_.empty())… in FeedDecoderInputBuffer()
415 … inputBuffersQueue_.size(), availableInputIndexsQueue_.size(), availableInputBufferQueue_.size()); in FeedDecoderInputBuffer()
428 uint32_t index = availableInputIndexsQueue_.front(); in FeedDecoderInputBuffer()
473 availableInputIndexsQueue_.pop(); in IncreaseWaitDecodeCnt()
673 if (availableInputIndexsQueue_.size() > VIDEO_DECODER_QUEUE_MAX) { in OnInputBufferAvailable()
678 availableInputIndexsQueue_.push(index); in OnInputBufferAvailable()
H A Ddecode_data_process_common.cpp375 std::queue<uint32_t>().swap(availableInputIndexsQueue_); in ReleaseProcessNode()
459 …if (buffer == nullptr || availableInputIndexsQueue_.empty() || availableInputBufferQueue_.empty())… in FeedDecoderInputBuffer()
462 … inputBuffersQueue_.size(), availableInputIndexsQueue_.size(), availableInputBufferQueue_.size()); in FeedDecoderInputBuffer()
475 uint32_t index = availableInputIndexsQueue_.front(); in FeedDecoderInputBuffer()
520 availableInputIndexsQueue_.pop(); in IncreaseWaitDecodeCnt()
720 if (availableInputIndexsQueue_.size() > VIDEO_DECODER_QUEUE_MAX) { in OnInputBufferAvailable()
725 availableInputIndexsQueue_.push(index); in OnInputBufferAvailable()
/ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/screensinkprocessor/decoder/include/
H A Dimage_sink_decoder.h102 std::queue<int32_t> availableInputIndexsQueue_; variable
/ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/test/unittest/screensinkprocessor/src/
H A Dimage_sink_decoder_test.cpp363 EXPECT_EQ(len, imageDecoder_->availableInputIndexsQueue_.size());
529 imageDecoder_->availableInputIndexsQueue_.push(index);
/ohos5.0/foundation/distributedhardware/distributed_camera/services/data_process/include/pipeline_node/multimedia_codec/decoder/
H A Ddecode_data_process.h144 std::queue<uint32_t> availableInputIndexsQueue_; variable