Home
last modified time | relevance | path

Searched refs:inputBuffers (Results 1 - 25 of 46) sorted by relevance

12

/foundation/distributedhardware/distributed_camera/services/data_process/test/unittest/common/pipeline_node/
H A Dfps_controller_process_test.cpp118 * @tc.desc: Verify fps controller process ProcessData inputBuffers is empty.
140 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
141 rc = testFpsControllerProcess_->ProcessData(inputBuffers); in HWTEST_F()
155 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
156 int32_t rc = testFpsControllerProcess_->ProcessData(inputBuffers); in HWTEST_F()
160 inputBuffers.push_back(db); in HWTEST_F()
161 rc = testFpsControllerProcess_->ProcessData(inputBuffers); in HWTEST_F()
164 inputBuffers.clear(); in HWTEST_F()
169 inputBuffers.push_back(dataBuf); in HWTEST_F()
170 rc = testFpsControllerProcess_->ProcessData(inputBuffers); in HWTEST_F()
199 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
232 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
268 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
[all...]
H A Ddecode_data_process_test.cpp185 * @tc.desc: Verify decode data process ProcessData inputBuffers is nullptr.
194 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
195 int32_t rc = testDecodeDataProcess_->ProcessData(inputBuffers); in HWTEST_F()
225 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
227 inputBuffers.push_back(db); in HWTEST_F()
228 rc = testDecodeDataProcess_->ProcessData(inputBuffers); in HWTEST_F()
258 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
260 inputBuffers.push_back(db); in HWTEST_F()
261 rc = testDecodeDataProcess_->ProcessData(inputBuffers); in HWTEST_F()
315 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
352 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
363 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
401 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
438 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
530 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
570 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
[all...]
H A Dencode_data_process_test.cpp170 * @tc.desc: Verify encode data process ProcessData inputBuffers is nullptr.
178 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
179 int32_t rc = testEncodeDataProcess_->ProcessData(inputBuffers); in HWTEST_F()
190 inputBuffers.push_back(db); in HWTEST_F()
193 rc = testEncodeDataProcess_->ProcessData(inputBuffers); in HWTEST_F()
222 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
224 inputBuffers.push_back(db); in HWTEST_F()
225 rc = testEncodeDataProcess_->ProcessData(inputBuffers); in HWTEST_F()
311 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
316 inputBuffers in HWTEST_F()
455 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
561 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
[all...]
H A Dscale_convert_process_test.cpp118 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
119 int32_t rc = testScaleConvertProcess_->ProcessData(inputBuffers); in HWTEST_F()
125 * @tc.desc: Verify scale convert process ProcessData inputBuffers is empty.
135 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
136 rc = testScaleConvertProcess_->ProcessData(inputBuffers); in HWTEST_F()
153 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
155 inputBuffers.push_back(db); in HWTEST_F()
156 rc = testScaleConvertProcess_->ProcessData(inputBuffers); in HWTEST_F()
173 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; in HWTEST_F() local
175 inputBuffers in HWTEST_F()
194 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
223 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
478 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
593 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
612 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
635 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
664 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
692 std::vector<std::shared_ptr<DataBuffer>> inputBuffers; HWTEST_F() local
[all...]
/foundation/distributedhardware/distributed_camera/services/data_process/src/pipeline_node/fpscontroller/
H A Dfps_controller_process.cpp74 int32_t FpsControllerProcess::ProcessData(std::vector<std::shared_ptr<DataBuffer>>& inputBuffers) in ProcessData() argument
76 if (inputBuffers.empty() || inputBuffers[0] == nullptr) { in ProcessData()
85 if (!inputBuffers[0]->FindInt64("timeUs", timeStampUs)) { in ProcessData()
104 return FpsControllerDone(inputBuffers); in ProcessData()
/foundation/distributedhardware/distributed_camera/services/data_process/src/pipeline/
H A Ddcamera_pipeline_source.cpp189 std::vector<std::shared_ptr<DataBuffer>> inputBuffers = pipConfigSource->GetDataBuffers(); in ProcessData() local
190 if (inputBuffers.empty()) { in ProcessData()
195 auto sendFunc = [this, inputBuffers]() mutable { in ProcessData()
196 int32_t ret = pipelineHead_->ProcessData(inputBuffers); in ProcessData()
/foundation/distributedhardware/distributed_camera/services/data_process/src/pipeline_node/scale_conversion/
H A Dscale_convert_process_common.cpp110 int ScaleConvertProcess::ProcessData(std::vector<std::shared_ptr<DataBuffer>>& inputBuffers) in ProcessData() argument
119 if (inputBuffers.empty() || inputBuffers[0] == nullptr) { in ProcessData()
123 inputBuffers[0]->frameInfo_.timePonit.startScale = startScaleTime; in ProcessData()
131 return ConvertDone(inputBuffers); in ProcessData()
135 if ((GetImageUnitInfo(srcImgInfo, inputBuffers[0]) != DCAMERA_OK) || !CheckScaleProcessInputInfo(srcImgInfo)) { in ProcessData()
149 dstBuf->frameInfo_ = inputBuffers[0]->frameInfo_; in ProcessData()
H A Dscale_convert_process.cpp75 int ScaleConvertProcess::ProcessData(std::vector<std::shared_ptr<DataBuffer>>& inputBuffers) in ProcessData() argument
84 if (inputBuffers.empty() || inputBuffers[0] == nullptr) { in ProcessData()
88 inputBuffers[0]->frameInfo_.timePonit.startScale = startScaleTime; in ProcessData()
96 return ConvertDone(inputBuffers); in ProcessData()
100 if ((GetImageUnitInfo(srcImgInfo, inputBuffers[0]) != DCAMERA_OK) || !CheckScaleProcessInputInfo(srcImgInfo)) { in ProcessData()
116 dstBuf->frameInfo_ = inputBuffers[0]->frameInfo_; in ProcessData()
/foundation/distributedhardware/distributed_camera/services/data_process/include/pipeline/
H A Dabstract_data_process.h38 virtual int32_t ProcessData(std::vector<std::shared_ptr<DataBuffer>>& inputBuffers) = 0;
/foundation/distributedhardware/distributed_camera/services/data_process/src/pipeline_node/multimedia_codec/encoder/
H A Dencode_data_process.cpp318 int32_t EncodeDataProcess::ProcessData(std::vector<std::shared_ptr<DataBuffer>>& inputBuffers) in ProcessData() argument
321 if (inputBuffers.empty() || inputBuffers[0] == nullptr) { in ProcessData()
328 return EncodeDone(inputBuffers); in ProcessData()
334 if (inputBuffers[0]->Size() > NORM_YUV420_BUFFER_SIZE) { in ProcessData()
335 DHLOGE("EncodeNode input buffer size %{public}zu error.", inputBuffers[0]->Size()); in ProcessData()
340 int32_t err = FeedEncoderInputBuffer(inputBuffers[0]); in ProcessData()
/foundation/distributedhardware/distributed_camera/services/data_process/src/pipeline_node/multimedia_codec/decoder/
H A Ddecode_data_process.cpp343 int32_t DecodeDataProcess::ProcessData(std::vector<std::shared_ptr<DataBuffer>>& inputBuffers) in ProcessData() argument
346 if (inputBuffers.empty() || inputBuffers[0] == nullptr) { in ProcessData()
355 return DecodeDone(inputBuffers); in ProcessData()
366 if (inputBuffers[0]->Size() > MAX_YUV420_BUFFER_SIZE) { in ProcessData()
367 DHLOGE("DecodeNode input buffer size %{public}zu error.", inputBuffers[0]->Size()); in ProcessData()
374 inputBuffersQueue_.push(inputBuffers[0]); in ProcessData()
375 DHLOGD("Push inputBuf sucess. BufSize %{public}zu, QueueSize %{public}zu.", inputBuffers[0]->Size(), in ProcessData()
H A Ddecode_data_process_common.cpp390 int32_t DecodeDataProcess::ProcessData(std::vector<std::shared_ptr<DataBuffer>>& inputBuffers) in ProcessData() argument
393 if (inputBuffers.empty() || inputBuffers[0] == nullptr) { in ProcessData()
402 return DecodeDone(inputBuffers); in ProcessData()
413 if (inputBuffers[0]->Size() > MAX_BUFFER_SIZE) { in ProcessData()
414 DHLOGE("DecodeNode input buffer size %{public}zu error.", inputBuffers[0]->Size()); in ProcessData()
421 inputBuffersQueue_.push(inputBuffers[0]); in ProcessData()
422 DHLOGD("Push inputBuf sucess. BufSize %{public}zu, QueueSize %{public}zu.", inputBuffers[0]->Size(), in ProcessData()
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_decoder/ape/
H A Dffmpeg_ape_decoder_plugin.h51 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_decoder/amrwb/
H A Dffmpeg_amrwb_decoder_plugin.h50 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_decoder/amrnb/
H A Dffmpeg_amrnb_decoder_plugin.h50 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/interfaces/plugin/
H A Dcodec_plugin.h46 virtual Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) = 0;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_decoder/aac/
H A Dffmpeg_aac_decoder_plugin.h51 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_decoder/vorbis/
H A Dffmpeg_vorbis_decoder_plugin.h50 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_decoder/mp3/
H A Dffmpeg_mp3_decoder_plugin.h49 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_encoder/mp3/
H A Daudio_mp3_encoder_plugin.h56 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_encoder/lbvc/
H A Daudio_lbvc_encoder_plugin.h49 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_encoder/g711mu/
H A Daudio_g711mu_encoder_plugin.h56 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_encoder/flac/
H A Dffmpeg_flac_encoder_plugin.h43 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_decoder/g711mu/
H A Daudio_g711mu_decoder_plugin.h56 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/audio_decoder/lbvc/
H A Daudio_lbvc_decoder_plugin.h49 Status GetInputBuffers(std::vector<std::shared_ptr<AVBuffer>> &inputBuffers) override;

Completed in 14 milliseconds

12