| /foundation/multimedia/av_codec/test/nativedemo/audio_demo/ |
| H A D | avcodec_audio_avbuffer_amrnb_encoder_demo.cpp | 127 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
128 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
154 : isRunning_(false), audioEnc_(nullptr), signal_(nullptr), frameCount_(0) in AEncAvbufferAmrNbDemo()
163 if (signal_) { in ~AEncAvbufferAmrNbDemo()
164 delete signal_; in ~AEncAvbufferAmrNbDemo()
165 signal_ = nullptr; in ~AEncAvbufferAmrNbDemo()
174 signal_ = new AEncSignal(); in CreateEnc()
175 DEMO_CHECK_AND_RETURN_RET_LOG(signal_ != nullptr, AVCS_ERR_UNKNOWN, "Fatal: No memory"); in CreateEnc()
178 int32_t ret = OH_AudioCodec_RegisterCallback(audioEnc_, cb_, signal_); in CreateEnc()
207 unique_lock<mutex> lock(signal_ in Stop()
[all...] |
| H A D | avcodec_audio_avbuffer_mp3_encoder_demo.cpp | 127 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
128 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
154 : isRunning_(false), audioEnc_(nullptr), signal_(nullptr), frameCount_(0) in AEncAvbufferMp3Demo()
163 if (signal_) { in ~AEncAvbufferMp3Demo()
164 delete signal_; in ~AEncAvbufferMp3Demo()
165 signal_ = nullptr; in ~AEncAvbufferMp3Demo()
174 signal_ = new AEncSignal(); in CreateEnc()
175 DEMO_CHECK_AND_RETURN_RET_LOG(signal_ != nullptr, AVCS_ERR_UNKNOWN, "Fatal: No memory"); in CreateEnc()
178 int32_t ret = OH_AudioCodec_RegisterCallback(audioEnc_, cb_, signal_); in CreateEnc()
207 unique_lock<mutex> lock(signal_ in Stop()
[all...] |
| H A D | avcodec_audio_encoder_inner_demo.cpp | 73 signal_ = make_shared<AEnSignal>(); in CreateDec()
75 cb_ = make_unique<AEnDemoCallback>(signal_); in CreateDec()
107 unique_lock<mutex> lock(signal_->inMutex_); in Stop()
108 signal_->inQueue_.push(0); in Stop()
109 signal_->inCond_.notify_all(); in Stop()
117 unique_lock<mutex> lock(signal_->outMutex_); in Stop()
118 signal_->outQueue_.push(0); in Stop()
119 signal_->outCond_.notify_all(); in Stop()
154 std::unique_lock<std::mutex> lock(signal_->inMutex_); in InputFunc()
155 signal_ in InputFunc()
[all...] |
| H A D | avcodec_audio_g711mu_encoder_demo.cpp | 124 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
125 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
141 signal_(nullptr), in AEncG711muDemo()
148 if (signal_) { in ~AEncG711muDemo()
149 delete signal_; in ~AEncG711muDemo()
150 signal_ = nullptr; in ~AEncG711muDemo()
159 signal_ = new AEncSignal(); in CreateEnc()
160 DEMO_CHECK_AND_RETURN_RET_LOG(signal_ != nullptr, AVCS_ERR_UNKNOWN, "Fatal: No memory"); in CreateEnc()
163 int32_t ret = OH_AudioEncoder_SetCallback(audioEnc_, cb_, signal_); in CreateEnc()
193 unique_lock<mutex> lock(signal_ in Stop()
[all...] |
| H A D | avcodec_audio_avbuffer_decoder_demo.cpp | 180 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
181 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
214 ADecBufferDemo::ADecBufferDemo() : audioDec_(nullptr), signal_(nullptr), audioType_(AudioBufferFormatType::TYPE_AAC) {} in ADecBufferDemo()
218 if (signal_) { in ~ADecBufferDemo()
219 delete signal_; in ~ADecBufferDemo()
220 signal_ = nullptr; in ~ADecBufferDemo()
253 signal_ = new ADecBufferSignal(); in CreateDec()
254 DEMO_CHECK_AND_RETURN_RET_LOG(signal_ != nullptr, AVCS_ERR_UNKNOWN, "Fatal: No memory"); in CreateDec()
257 int32_t ret = OH_AudioCodec_RegisterCallback(audioDec_, cb_, signal_); in CreateDec()
286 unique_lock<mutex> lock(signal_ in Stop()
[all...] |
| /foundation/multimedia/av_codec/test/moduletest/vcodec/encoder/src/ |
| H A D | videoenc_ndk_sample.cpp | 81 enc_sample->signal_->inCond_.notify_all(); in VencInputDataReady()
82 enc_sample->signal_->outCond_.notify_all(); in VencInputDataReady()
89 enc_sample->signal_->inCond_.notify_all(); in VencInputDataReady()
90 enc_sample->signal_->outCond_.notify_all(); in VencInputDataReady()
110 enc_sample->signal_->inCond_.notify_all(); in VencOutputDataReady()
111 enc_sample->signal_->outCond_.notify_all(); in VencOutputDataReady()
118 enc_sample->signal_->inCond_.notify_all(); in VencOutputDataReady()
119 enc_sample->signal_->outCond_.notify_all(); in VencOutputDataReady()
223 signal_ = new VEncSignal(); in SetVideoEncoderCallback()
224 if (signal_ in SetVideoEncoderCallback()
[all...] |
| /test/xts/acts/multimedia/av_codec/vcodec/encoder/src/ |
| H A D | videoenc_ndk_sample.cpp | 78 enc_sample->signal_->inCond_.notify_all(); in VencInputDataReady()
79 enc_sample->signal_->outCond_.notify_all(); in VencInputDataReady()
86 enc_sample->signal_->inCond_.notify_all(); in VencInputDataReady()
87 enc_sample->signal_->outCond_.notify_all(); in VencInputDataReady()
104 enc_sample->signal_->inCond_.notify_all(); in VencOutputDataReady()
105 enc_sample->signal_->outCond_.notify_all(); in VencOutputDataReady()
112 enc_sample->signal_->inCond_.notify_all(); in VencOutputDataReady()
113 enc_sample->signal_->outCond_.notify_all(); in VencOutputDataReady()
216 signal_ = new VEncSignal(); in SetVideoEncoderCallback()
217 if (signal_ in SetVideoEncoderCallback()
[all...] |
| H A D | videoenc_api11_sample.cpp | 242 signal_ = new VEncSignal(); in SetVideoEncoderCallback()
243 if (signal_ == nullptr) { in SetVideoEncoderCallback()
258 return OH_VideoEncoder_RegisterCallback(venc_, cb_, static_cast<void *>(signal_)); in SetVideoEncoderCallback()
263 unique_lock<mutex> lock(signal_->inMutex_); in state_EOS()
264 signal_->inCond_.wait(lock, [this]() { return signal_->inIdxQueue_.size() > 0; }); in state_EOS()
265 uint32_t index = signal_->inIdxQueue_.front(); in state_EOS()
266 OH_AVBuffer *buffer = signal_->inBufferQueue_.front(); in state_EOS()
267 signal_->inIdxQueue_.pop(); in state_EOS()
268 signal_ in state_EOS()
[all...] |
| /foundation/multimedia/av_codec/test/moduletest/audio_encoder/Avbuffer/src/ |
| H A D | avcodec_audio_avbuffer_encoder_demo.cpp | 265 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
266 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
291 AudioBufferAacEncDemo::AudioBufferAacEncDemo() : isRunning_(false), audioEnc_(nullptr), signal_(nullptr), frameCount_(0) in AudioBufferAacEncDemo()
293 signal_ = new AEncSignal(); in AudioBufferAacEncDemo()
294 DEMO_CHECK_AND_RETURN_LOG(signal_ != nullptr, "Fatal: No memory"); in AudioBufferAacEncDemo()
299 if (signal_) { in ~AudioBufferAacEncDemo()
300 delete signal_; in ~AudioBufferAacEncDemo()
301 signal_ = nullptr; in ~AudioBufferAacEncDemo()
320 if (signal_ == nullptr) { in CreateEnc()
321 signal_ in CreateEnc()
[all...] |
| /test/xts/acts/multimedia/av_codec/audio_encoder/src/ |
| H A D | avcodec_audio_avbuffer_encoder_demo.cpp | 265 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
266 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
291 AudioBufferAacEncDemo::AudioBufferAacEncDemo() : isRunning_(false), audioEnc_(nullptr), signal_(nullptr), frameCount_(0) in AudioBufferAacEncDemo()
293 signal_ = new AEncSignal(); in AudioBufferAacEncDemo()
294 DEMO_CHECK_AND_RETURN_LOG(signal_ != nullptr, "Fatal: No memory"); in AudioBufferAacEncDemo()
299 if (signal_) { in ~AudioBufferAacEncDemo()
300 delete signal_; in ~AudioBufferAacEncDemo()
301 signal_ = nullptr; in ~AudioBufferAacEncDemo()
320 if (signal_ == nullptr) { in CreateEnc()
321 signal_ in CreateEnc()
[all...] |
| /test/xts/acts/multimedia/av_codec/vcodec/swdecoder/src/ |
| H A D | videodec_ndk_sample.cpp | 260 signal_ = new VDecSignal(); in SetVideoDecoderCallback()
261 if (signal_ == nullptr) { in SetVideoDecoderCallback()
270 return OH_VideoDecoder_SetCallback(vdec_, cb_, static_cast<void *>(signal_)); in SetVideoDecoderCallback()
287 unique_lock<mutex> lock(signal_->inMutex_); in StopInloop()
288 clearIntqueue(signal_->inIdxQueue_); in StopInloop()
289 signal_->inCond_.notify_all(); in StopInloop()
402 unique_lock<mutex> lock(signal_->outMutex_); in OutputFunc()
403 signal_->outCond_.wait(lock, [this]() { in OutputFunc()
408 return signal_->outIdxQueue_.size() > 0; in OutputFunc()
413 uint32_t index = signal_ in OutputFunc()
[all...] |
| /foundation/multimedia/av_codec/test/moduletest/vcodec/swdecoder/src/InnerAPI/ |
| H A D | videodec_ndk_inner_sample.cpp | 199 clearIntqueue(signal_->outIdxQueue_); in Stop()
200 clearBufferqueue(signal_->infoQueue_); in Stop()
201 clearFlagqueue(signal_->flagQueue_); in Stop()
209 unique_lock<mutex> inLock(signal_->inMutex_); in Flush()
210 clearIntqueue(signal_->inIdxQueue_); in Flush()
211 signal_->inCond_.notify_all(); in Flush()
213 unique_lock<mutex> outLock(signal_->outMutex_); in Flush()
214 clearIntqueue(signal_->outIdxQueue_); in Flush()
215 clearBufferqueue(signal_->infoQueue_); in Flush()
216 clearFlagqueue(signal_ in Flush()
[all...] |
| /foundation/multimedia/av_codec/test/moduletest/vcodec/hwdecoder/src/InnerAPI/ |
| H A D | videodec_ndk_inner_sample.cpp | 156 clearIntqueue(signal_->outIdxQueue_); in Stop()
157 clearBufferqueue(signal_->infoQueue_); in Stop()
158 clearFlagqueue(signal_->flagQueue_); in Stop()
166 unique_lock<mutex> inLock(signal_->inMutex_); in Flush()
167 clearIntqueue(signal_->inIdxQueue_); in Flush()
168 signal_->inCond_.notify_all(); in Flush()
170 unique_lock<mutex> outLock(signal_->outMutex_); in Flush()
171 clearIntqueue(signal_->outIdxQueue_); in Flush()
172 clearBufferqueue(signal_->infoQueue_); in Flush()
173 clearFlagqueue(signal_ in Flush()
[all...] |
| /foundation/multimedia/av_codec/test/moduletest/audio_decoder/Avbuffer/src/ |
| H A D | avcodec_audio_avbuffer_decoder_demo.cpp | 242 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
243 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
298 ADecBufferDemo::ADecBufferDemo() : audioDec_(nullptr), signal_(nullptr), audioType_(AudioBufferFormatType::TYPE_AAC) in ADecBufferDemo()
300 signal_ = new ADecBufferSignal(); in ADecBufferDemo()
301 DEMO_CHECK_AND_RETURN_LOG(signal_ != nullptr, "Fatal: No memory"); in ADecBufferDemo()
306 if (signal_) { in ~ADecBufferDemo()
307 delete signal_; in ~ADecBufferDemo()
308 signal_ = nullptr; in ~ADecBufferDemo()
356 if (signal_ == nullptr) { in CreateDec()
357 signal_ in CreateDec()
[all...] |
| /foundation/multimedia/av_codec/test/fuzztest/audiodecoderreset_fuzzer/ |
| H A D | audio_decoder_reset_demo.cpp | 197 ADecBufferDemo::ADecBufferDemo() : audioDec_(nullptr), signal_(nullptr), audioType_(AudioBufferFormatType::TYPE_AAC) in ADecBufferDemo()
199 signal_ = new ADecBufferSignal(); in ADecBufferDemo()
200 DEMO_CHECK_AND_RETURN_LOG(signal_ != nullptr, "Fatal: No memory"); in ADecBufferDemo()
205 if (signal_) { in ~ADecBufferDemo()
206 delete signal_; in ~ADecBufferDemo()
207 signal_ = nullptr; in ~ADecBufferDemo()
253 if (signal_ == nullptr) { in CreateDec()
254 signal_ = new ADecBufferSignal(); in CreateDec()
255 DEMO_CHECK_AND_RETURN_RET_LOG(signal_ != nullptr, AVCS_ERR_UNKNOWN, "Fatal: No memory"); in CreateDec()
258 int32_t ret = OH_AudioCodec_RegisterCallback(audioDec_, cb_, signal_); in CreateDec()
[all...] |
| /foundation/multimedia/av_codec/test/fuzztest/audiodecoderdescription_fuzzer/ |
| H A D | audio_decoder_description_demo.cpp | 197 ADecBufferDemo::ADecBufferDemo() : audioDec_(nullptr), signal_(nullptr), audioType_(AudioBufferFormatType::TYPE_AAC) in ADecBufferDemo()
199 signal_ = new ADecBufferSignal(); in ADecBufferDemo()
200 DEMO_CHECK_AND_RETURN_LOG(signal_ != nullptr, "Fatal: No memory"); in ADecBufferDemo()
205 if (signal_) { in ~ADecBufferDemo()
206 delete signal_; in ~ADecBufferDemo()
207 signal_ = nullptr; in ~ADecBufferDemo()
253 if (signal_ == nullptr) { in CreateDec()
254 signal_ = new ADecBufferSignal(); in CreateDec()
255 DEMO_CHECK_AND_RETURN_RET_LOG(signal_ != nullptr, AVCS_ERR_UNKNOWN, "Fatal: No memory"); in CreateDec()
258 int32_t ret = OH_AudioCodec_RegisterCallback(audioDec_, cb_, signal_); in CreateDec()
[all...] |
| /foundation/multimedia/av_codec/test/fuzztest/audiodecoderflush_fuzzer/ |
| H A D | audio_decoder_flush_demo.cpp | 197 ADecBufferDemo::ADecBufferDemo() : audioDec_(nullptr), signal_(nullptr), audioType_(AudioBufferFormatType::TYPE_AAC) in ADecBufferDemo()
199 signal_ = new ADecBufferSignal(); in ADecBufferDemo()
200 DEMO_CHECK_AND_RETURN_LOG(signal_ != nullptr, "Fatal: No memory"); in ADecBufferDemo()
205 if (signal_) { in ~ADecBufferDemo()
206 delete signal_; in ~ADecBufferDemo()
207 signal_ = nullptr; in ~ADecBufferDemo()
253 if (signal_ == nullptr) { in CreateDec()
254 signal_ = new ADecBufferSignal(); in CreateDec()
255 DEMO_CHECK_AND_RETURN_RET_LOG(signal_ != nullptr, AVCS_ERR_UNKNOWN, "Fatal: No memory"); in CreateDec()
258 int32_t ret = OH_AudioCodec_RegisterCallback(audioDec_, cb_, signal_); in CreateDec()
[all...] |
| /foundation/multimedia/av_codec/test/fuzztest/audiodecoder_fuzzer/ |
| H A D | audio_decoder_demo.cpp | 131 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
132 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
238 ADecBufferDemo::ADecBufferDemo() : audioDec_(nullptr), signal_(nullptr), audioType_(AudioBufferFormatType::TYPE_AAC) in ADecBufferDemo()
240 signal_ = new ADecBufferSignal(); in ADecBufferDemo()
241 DEMO_CHECK_AND_RETURN_LOG(signal_ != nullptr, "Fatal: No memory"); in ADecBufferDemo()
246 if (signal_) { in ~ADecBufferDemo()
247 delete signal_; in ~ADecBufferDemo()
248 signal_ = nullptr; in ~ADecBufferDemo()
294 if (signal_ == nullptr) { in CreateDec()
295 signal_ in CreateDec()
[all...] |
| /test/xts/acts/multimedia/av_codec/audio_decoder/src/ |
| H A D | avcodec_audio_avbuffer_decoder_demo.cpp | 242 unique_lock<mutex> lock(signal_->startMutex_); in RunCase()
243 signal_->startCond_.wait(lock, [this]() { return (!(isRunning_.load())); }); in RunCase()
298 ADecBufferDemo::ADecBufferDemo() : audioDec_(nullptr), signal_(nullptr), audioType_(AudioBufferFormatType::TYPE_AAC) in ADecBufferDemo()
300 signal_ = new ADecBufferSignal(); in ADecBufferDemo()
301 DEMO_CHECK_AND_RETURN_LOG(signal_ != nullptr, "Fatal: No memory"); in ADecBufferDemo()
306 if (signal_) { in ~ADecBufferDemo()
307 delete signal_; in ~ADecBufferDemo()
308 signal_ = nullptr; in ~ADecBufferDemo()
356 if (signal_ == nullptr) { in CreateDec()
357 signal_ in CreateDec()
[all...] |
| /foundation/multimedia/av_codec/test/fuzztest/encoderconfigure_fuzzer/ |
| H A D | videoenc_sample.cpp | 143 signal_ = new VEncSignal(); in SetVideoEncoderCallback()
144 if (signal_ == nullptr) { in SetVideoEncoderCallback()
153 return OH_VideoEncoder_SetCallback(venc_, cb_, static_cast<void *>(signal_)); in SetVideoEncoderCallback()
170 unique_lock<mutex> lock(signal_->inMutex_); in StopInloop()
171 clearIntqueue(signal_->inIdxQueue_); in StopInloop()
173 signal_->inCond_.notify_all(); in StopInloop()
227 signal_->inCond_.notify_all(); in StartVideoEncoder()
228 signal_->outCond_.notify_all(); in StartVideoEncoder()
335 unique_lock<mutex> lock(signal_->inMutex_); in SetEOS()
336 signal_ in SetEOS()
[all...] |
| /foundation/multimedia/av_codec/test/moduletest/vcodec/encoder/src/InnerAPI/ |
| H A D | videoenc_ndk_inner_sample.cpp | 69 : signal_(signal) in VEncNdkInnerSample()
116 std::shared_ptr<VEncInnerSignal> signal) : signal_(signal) {} in VEncParamWithAttrCallbackTest()
120 signal_ = nullptr; in ~VEncParamWithAttrCallbackTest()
127 if (signal_ == nullptr) { in OnInputParameterWithAttrAvailable()
130 unique_lock<mutex> lock(signal_->inMutex_); in OnInputParameterWithAttrAvailable()
132 signal_->inIdxQueue_.push(index); in OnInputParameterWithAttrAvailable()
133 signal_->inAttrQueue_.push(attribute); in OnInputParameterWithAttrAvailable()
134 signal_->inFormatQueue_.push(parameter); in OnInputParameterWithAttrAvailable()
135 signal_->inCond_.notify_all(); in OnInputParameterWithAttrAvailable()
223 clearIntqueue(signal_ in Stop()
[all...] |
| /foundation/distributedhardware/distributed_screen/services/screendemo/ |
| H A D | decoder_demo.cpp | 106 signal_ = make_shared<VDecSignal>(); in CreateVdec()
107 cb_ = make_unique<VDecDemoCallback>(signal_); in CreateVdec()
140 unique_lock<mutex> inLock(signal_->inMutex_); in Stop()
141 signal_->inQueue_.push(INDEX_CONSTANT); in Stop()
142 signal_->inCond_.notify_all(); in Stop()
150 unique_lock<mutex> outLock(signal_->outMutex_); in Stop()
151 signal_->outQueue_.push(INDEX_CONSTANT); in Stop()
152 signal_->outCond_.notify_all(); in Stop()
235 unique_lock<mutex> lock(signal_->inMutex_); in InputFunc()
236 signal_ in InputFunc()
[all...] |
| /test/xts/dcts/distributedhardware/distributedscreentest/ |
| H A D | decoder_demo.cpp | 107 signal_ = make_shared<VDecSignal>(); in CreateVdec()
108 cb_ = make_unique<VDecDemoCallback>(signal_); in CreateVdec()
141 unique_lock<mutex> inLock(signal_->inMutex_); in Stop()
142 signal_->inQueue_.push(INDEX_CONSTANT); in Stop()
143 signal_->inCond_.notify_all(); in Stop()
151 unique_lock<mutex> outLock(signal_->outMutex_); in Stop()
152 signal_->outQueue_.push(INDEX_CONSTANT); in Stop()
153 signal_->outCond_.notify_all(); in Stop()
235 unique_lock<mutex> lock(signal_->inMutex_); in InputFunc()
236 signal_ in InputFunc()
[all...] |
| /foundation/multimedia/av_codec/test/unittest/video_test/vcodec_framework_test/stable_sample/common/include/ |
| H A D | vcodec_signal.h | 109 signal_ = signal; in FlushGuard()
110 signal_->isFlushing_ = true; in FlushGuard()
111 signal_->inCond_.notify_all(); in FlushGuard()
112 signal_->outCond_.notify_all(); in FlushGuard()
114 std::scoped_lock lock(signal_->inMutex_, signal_->outMutex_); in FlushGuard()
122 if (signal_ == nullptr) { in ~FlushGuard()
125 signal_->isFlushing_ = false; in ~FlushGuard()
126 signal_->inCond_.notify_all(); in ~FlushGuard()
127 signal_ in ~FlushGuard()
152 std::shared_ptr<T> signal_ = nullptr; global() member in OHOS::MediaAVCodec::FlushGuard
[all...] |
| /foundation/multimedia/av_codec/test/nativedemo/video_demo/ |
| H A D | avcodec_video_decoder_inner_demo.cpp | 173 signal_ = make_shared<VDecSignal>(); in CreateDec()
175 cb_ = make_unique<VDecDemoCallback>(signal_); in CreateDec()
221 unique_lock<mutex> lock(signal_->inMutex_); in Stop()
222 signal_->inQueue_.push(0); in Stop()
223 signal_->inCond_.notify_all(); in Stop()
230 unique_lock<mutex> lock(signal_->outMutex_); in Stop()
231 signal_->outQueue_.push(0); in Stop()
232 signal_->outCond_.notify_all(); in Stop()
324 std::unique_lock<std::mutex> lock(signal_->inMutex_); in InputFunc()
325 signal_ in InputFunc()
[all...] |