Home
last modified time | relevance | path

Searched refs:inputBuffersQueue_ (Results 1 – 3 of 3) sorted by relevance

/ohos5.0/foundation/distributedhardware/distributed_camera/services/data_process/src/pipeline_node/multimedia_codec/decoder/
H A Ddecode_data_process.cpp327 std::queue<std::shared_ptr<DataBuffer>>().swap(inputBuffersQueue_); in ReleaseProcessNode()
362 if (inputBuffersQueue_.size() > VIDEO_DECODER_QUEUE_MAX) { in ProcessData()
374 inputBuffersQueue_.push(inputBuffers[0]); in ProcessData()
376 inputBuffersQueue_.size()); in ProcessData()
410 while ((!inputBuffersQueue_.empty()) && (isDecoderProcess_.load())) { in FeedDecoderInputBuffer()
411 std::shared_ptr<DataBuffer> buffer = inputBuffersQueue_.front(); in FeedDecoderInputBuffer()
415 … inputBuffersQueue_.size(), availableInputIndexsQueue_.size(), availableInputBufferQueue_.size()); in FeedDecoderInputBuffer()
449 inputBuffersQueue_.pop(); in FeedDecoderInputBuffer()
450 …LOGD("Push inputBuffer sucess. inputBuffersQueue size is %{public}zu.", inputBuffersQueue_.size()); in FeedDecoderInputBuffer()
H A Ddecode_data_process_common.cpp374 std::queue<std::shared_ptr<DataBuffer>>().swap(inputBuffersQueue_); in ReleaseProcessNode()
409 if (inputBuffersQueue_.size() > VIDEO_DECODER_QUEUE_MAX) { in ProcessData()
421 inputBuffersQueue_.push(inputBuffers[0]); in ProcessData()
423 inputBuffersQueue_.size()); in ProcessData()
457 while ((!inputBuffersQueue_.empty()) && (isDecoderProcess_.load())) { in FeedDecoderInputBuffer()
458 std::shared_ptr<DataBuffer> buffer = inputBuffersQueue_.front(); in FeedDecoderInputBuffer()
462 … inputBuffersQueue_.size(), availableInputIndexsQueue_.size(), availableInputBufferQueue_.size()); in FeedDecoderInputBuffer()
496 inputBuffersQueue_.pop(); in FeedDecoderInputBuffer()
497 …LOGD("Push inputBuffer sucess. inputBuffersQueue size is %{public}zu.", inputBuffersQueue_.size()); in FeedDecoderInputBuffer()
/ohos5.0/foundation/distributedhardware/distributed_camera/services/data_process/include/pipeline_node/multimedia_codec/decoder/
H A Ddecode_data_process.h142 std::queue<std::shared_ptr<DataBuffer>> inputBuffersQueue_; variable