/ohos5.0/foundation/graphic/graphic_surface/surface/src/ |
H A D | buffer_queue_consumer.cpp | 21 bufferQueue_ = bufferQueue; in BufferQueueConsumer() 22 if (bufferQueue_ != nullptr) { in BufferQueueConsumer() 23 bufferQueue_->GetName(name_); in BufferQueueConsumer() 34 if (bufferQueue_ == nullptr) { in AcquireBuffer() 43 if (bufferQueue_ == nullptr) { in AcquireBuffer() 51 if (bufferQueue_ == nullptr) { in ReleaseBuffer() 59 if (bufferQueue_ == nullptr) { in AttachBufferToQueue() 67 if (bufferQueue_ == nullptr) { in DetachBufferFromQueue() 80 if (bufferQueue_ == nullptr) { in AttachBuffer() 88 if (bufferQueue_ == nullptr) { in DetachBuffer() [all …]
|
H A D | buffer_queue_producer.cpp | 42 if (bufferQueue_ != nullptr) { in BufferQueueProducer() 43 bufferQueue_->GetName(name_); in BufferQueueProducer() 804 if (bufferQueue_ == nullptr) { in RequestAndDetachBuffer() 820 if (bufferQueue_ == nullptr) { in AttachAndFlushBuffer() 829 if (bufferQueue_ == nullptr) { in AcquireLastFlushedBuffer() 837 if (bufferQueue_ == nullptr) { in ReleaseLastFlushedBuffer() 846 if (bufferQueue_ == nullptr) { in RequestBuffer() 862 if (bufferQueue_ == nullptr) { in RequestBuffers() 889 if (bufferQueue_ == nullptr) { in GetProducerInitInfo() 897 if (bufferQueue_ == nullptr) { in CancelBuffer() [all …]
|
/ohos5.0/foundation/graphic/surface_lite/frameworks/ |
H A D | buffer_queue_producer.cpp | 225 : bufferQueue_(bufferQueue), in BufferQueueProducer() 233 delete bufferQueue_; in ~BufferQueueProducer() 234 bufferQueue_ = nullptr; in ~BufferQueueProducer() 275 RETURN_IF_FAIL(bufferQueue_); in Cancel() 281 RETURN_IF_FAIL(bufferQueue_); in SetQueueSize() 293 RETURN_IF_FAIL(bufferQueue_); in SetWidthAndHeight() 311 RETURN_IF_FAIL(bufferQueue_); in SetFormat() 323 RETURN_IF_FAIL(bufferQueue_); in SetStrideAlignment() 341 RETURN_IF_FAIL(bufferQueue_); in SetSize() 342 bufferQueue_->SetSize(size); in SetSize() [all …]
|
H A D | buffer_queue_consumer.cpp | 24 bufferQueue_ = &bufferQueue; in BufferQueueConsumer() 29 bufferQueue_ = nullptr; in ~BufferQueueConsumer() 34 return bufferQueue_->AcquireBuffer(); in AcquireBuffer() 39 return bufferQueue_->ReleaseBuffer(buffer); in ReleaseBuffer()
|
/ohos5.0/foundation/multimedia/media_foundation/src/buffer/avbuffer_queue/ |
H A D | avbuffer_queue_producer.cpp | 28 return bufferQueue_->GetQueueSize(); in GetQueueSize() 33 return bufferQueue_->SetQueueSize(size); in SetQueueSize() 44 return bufferQueue_->PushBuffer(uniqueId, available); in PushBuffer() 49 return bufferQueue_->PushBuffer(buffer, available); in PushBuffer() 64 return bufferQueue_->AttachBuffer(buffer, isFilled); in AttachBuffer() 69 return bufferQueue_->DetachBuffer(uniqueId); in DetachBuffer() 74 return bufferQueue_->DetachBuffer(buffer); in DetachBuffer() 79 return bufferQueue_->SetBrokerListener(listener); in SetBufferFilledListener() 84 return bufferQueue_->RemoveBrokerListener(listener); in RemoveBufferFilledListener() 89 return bufferQueue_->Clear(); in Clear() [all …]
|
H A D | avbuffer_queue_consumer.cpp | 22 : AVBufferQueueConsumer(), bufferQueue_(bufferQueue) { in AVBufferQueueConsumerImpl() 27 return bufferQueue_->GetQueueSize(); in GetQueueSize() 32 return bufferQueue_->SetQueueSize(size); in SetQueueSize() 37 return bufferQueue_->IsBufferInQueue(buffer); in IsBufferInQueue() 42 return bufferQueue_->AcquireBuffer(buffer); in AcquireBuffer() 47 return bufferQueue_->ReleaseBuffer(buffer); in ReleaseBuffer() 52 return bufferQueue_->AttachBuffer(buffer, isFilled); in AttachBuffer() 57 return bufferQueue_->DetachBuffer(buffer); in DetachBuffer() 62 return bufferQueue_->SetConsumerListener(listener); in SetBufferAvailableListener() 68 return bufferQueue_->SetQueueSizeAndAttachBuffer(size, buffer, isFilled); in SetQueueSizeAndAttachBuffer()
|
/ohos5.0/drivers/peripheral/camera/vdi_base/v4l2/src/stream_operator/stream_tunnel/lite/ |
H A D | stream_tunnel.cpp | 34 bufferQueue_ = producer; in AttachBufferQueue() 35 CHECK_IF_PTR_NULL_RETURN_VALUE(bufferQueue_, RC_ERROR); in AttachBufferQueue() 41 bufferQueue_ = nullptr; in DetachBufferQueue() 60 CHECK_IF_PTR_NULL_RETURN_VALUE(bufferQueue_, nullptr); in GetBuffer() 63 sb = bufferQueue_->RequestBuffer(); in GetBuffer() 74 int ret = bufferQueue_->CancelBuffer(sb); in GetBuffer() 112 CHECK_IF_PTR_NULL_RETURN_VALUE(bufferQueue_, RC_ERROR); in PutBuffer() 131 int ret = bufferQueue_->FlushBuffer(sb); in PutBuffer() 135 int ret = bufferQueue_->CancelBuffer(sb); in PutBuffer() 155 bufferQueue_->SetQueueSize(n); in SetBufferCount() [all …]
|
/ohos5.0/foundation/ai/intelligent_voice_framework/services/intell_voice_engine/server/wakeup/ |
H A D | wakeup_source_process.cpp | 49 bufferQueue_.push_back(std::move(queue)); in Init() 58 (static_cast<uint32_t>(bufferQueue_.size()) != channelCnt_)) { in Write() 60 … static_cast<uint32_t>(audioData.size()), static_cast<uint32_t>(bufferQueue_.size()), channelCnt_); in Write() 97 for (auto &queue : bufferQueue_) { in Release() 100 std::vector<std::unique_ptr<Uint8ArrayBufferQueue>>().swap(bufferQueue_); in Release() 107 if ((channelId >= bufferQueue_.size()) || (bufferQueue_[channelId] == nullptr)) { in WriteChannelData() 117 if (!bufferQueue_[channelId]->Push(std::move(arrayBuffer), false)) { in WriteChannelData() 127 if ((channelId >= bufferQueue_.size()) || (bufferQueue_[channelId] == nullptr)) { in ReadChannelData() 133 bufferQueue_[channelId]->PopUntilTimeout(WAIT_TIME, arrayBuffer); in ReadChannelData()
|
/ohos5.0/foundation/multimedia/av_codec/test/unittest/video_test/video_test/capbilities/sample_buffer_queue/ |
H A D | sample_buffer_queue.cpp | 27 bufferQueue_.emplace(bufferInfo); in QueueBuffer() 36 …_.wait_for(lock, std::chrono::milliseconds(timeoutMs), [this]() { return !bufferQueue_.empty(); }); in DequeueBuffer() 37 CHECK_AND_RETURN_RET(!bufferQueue_.empty(), std::nullopt); in DequeueBuffer() 39 CodecBufferInfo bufferInfo = bufferQueue_.front(); in DequeueBuffer() 40 bufferQueue_.pop(); in DequeueBuffer() 50 bufferQueue_.swap(emptyQueue); in Clear()
|
/ohos5.0/drivers/peripheral/camera/vdi_base/v4l2/src/stream_operator/stream_tunnel/standard/ |
H A D | stream_tunnel.cpp | 37 bufferQueue_ = OHOS::Surface::CreateSurfaceAsProducer(producer); in AttachBufferQueue() 38 CHECK_IF_PTR_NULL_RETURN_VALUE(bufferQueue_, RC_ERROR); in AttachBufferQueue() 44 bufferQueue_ = nullptr; in DetachBufferQueue() 58 bufferQueue_->CleanCache(); in CleanBuffers() 64 CHECK_IF_PTR_NULL_RETURN_VALUE(bufferQueue_, nullptr); in GetBuffer() 89 int ret = bufferQueue_->CancelBuffer(sb); in GetBuffer() 133 CHECK_IF_PTR_NULL_RETURN_VALUE(bufferQueue_, RC_ERROR); in PutBuffer() 155 int ret = bufferQueue_->FlushBuffer(sb, fence, flushConfig_); in PutBuffer() 161 int ret = bufferQueue_->CancelBuffer(sb); in PutBuffer() 179 CHECK_IF_PTR_NULL_RETURN_VALUE(bufferQueue_, RC_ERROR); in SetBufferCount() [all …]
|
/ohos5.0/drivers/peripheral/camera/test/mpi/src/ |
H A D | resolution_test.cpp | 71 …Test_->streamInfo_pre->bufferQueue_ = preview_consumer->CreateProducer([this](OHOS::SurfaceBuffer*… in __anone71a65810102() 75 …Test_->streamInfo_pre->bufferQueue_ = preview_consumer->CreateProducer([this](void* addr, uint32_t… in __anone71a65810202() 79 Test_->streamInfo_pre->bufferQueue_->SetQueueSize(8); // 8:size of bufferQueue 108 Test_->streamInfo_capture->bufferQueue_->SetQueueSize(8); // 8:bufferqueue size 181 …Test_->streamInfo_pre->bufferQueue_ = preview_consumer->CreateProducer([this](void* addr, uint32_t… in __anone71a65810602() 185 Test_->streamInfo_pre->bufferQueue_->SetQueueSize(8); // 8:size of bufferQueue 211 …Test_->streamInfo_video->bufferQueue_ = consumer_video->CreateProducer([this](void* addr, uint32_t… in __anone71a65810802() 215 Test_->streamInfo_video->bufferQueue_->SetQueueSize(8); // 8:bufferqueue size 288 …Test_->streamInfo_pre->bufferQueue_ = preview_consumer->CreateProducer([this](void* addr, uint32_t… in __anone71a65810a02() 292 Test_->streamInfo_pre->bufferQueue_->SetQueueSize(8); // 8:size of bufferQueue [all …]
|
H A D | hdi_stream_test.cpp | 77 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 131 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 219 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 440 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 485 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 527 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 572 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 629 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 678 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 725 Test_->streamInfo->bufferQueue_->SetQueueSize(8); [all …]
|
H A D | pipeline_test.cpp | 130 Test_->streamInfo->bufferQueue_ = consumer->CreateProducer([this](OHOS::SurfaceBuffer* buffer) { in __anon58e12a830102() 134 Test_->streamInfo->bufferQueue_ = consumer->CreateProducer([this](void* addr, uint32_t size) { in __anon58e12a830202() 138 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 216 …Test_->streamInfo->bufferQueue_ = preview_consumer->CreateProducer([this](void* addr, uint32_t siz… in __anon58e12a830302() 219 Test_->streamInfo->bufferQueue_->SetQueueSize(8); 235 …Test_->streamInfo2->bufferQueue_ = preview_consumer2->CreateProducer([this](void* addr, uint32_t s… in __anon58e12a830402() 238 Test_->streamInfo2->bufferQueue_->SetQueueSize(8);
|
/ohos5.0/drivers/peripheral/camera/test/ut/v4l2/ |
H A D | camera_preview_test.cpp | 70 ASSERT_NE(streamInfo.bufferQueue_, nullptr); 113 ASSERT_NE(streamInfo.bufferQueue_, nullptr); 167 ASSERT_NE(streamInfo.bufferQueue_, nullptr); 209 ASSERT_NE(streamInfo.bufferQueue_, nullptr); 312 ASSERT_NE(streamInfo.bufferQueue_, nullptr); 366 ASSERT_NE(streamInfo.bufferQueue_, nullptr); 418 ASSERT_NE(streamInfo.bufferQueue_, nullptr); 462 ASSERT_NE(streamInfo.bufferQueue_, nullptr); 507 ASSERT_NE(streamInfo.bufferQueue_, nullptr); 549 ASSERT_NE(streamInfo.bufferQueue_, nullptr); [all …]
|
H A D | usb_camera_test.cpp | 529 streamInfo.bufferQueue_ = new BufferProducerSequenceable(producer); in TEST_F() 530 ASSERT_NE(streamInfo.bufferQueue_, nullptr); in TEST_F() 685 ASSERT_NE(streamInfo.bufferQueue_, nullptr); in TEST_F() 686 streamInfo.bufferQueue_->producer_->SetQueueSize(8); // 8:set bufferQueue size in TEST_F() 700 streamInfoCapture.bufferQueue_ = new BufferProducerSequenceable( in TEST_F() 702 ASSERT_NE(streamInfoCapture.bufferQueue_, nullptr); in TEST_F() 840 ASSERT_NE(streamInfo.bufferQueue_, nullptr); in TEST_F() 856 ASSERT_NE(streamInfoVideo.bufferQueue_, nullptr); in TEST_F() 1068 ASSERT_NE(streamInfo.bufferQueue_, nullptr); in TEST_F() 1083 streamInfoCapture.bufferQueue_ = new BufferProducerSequenceable( in TEST_F() [all …]
|
H A D | hdi_interfaces_test.cpp | 68 cameraBase->streamInfo->bufferQueue_ = producer; in TEST_F() 121 cameraBase->streamInfo->bufferQueue_ = producer; in TEST_F() 166 streamInfo->bufferQueue_ = producer; in TEST_F() 212 cameraBase->streamInfo->bufferQueue_ = producer; in TEST_F() 256 cameraBase->streamInfo->bufferQueue_ = producer; in TEST_F() 310 cameraBase->streamInfo->bufferQueue_ = producer; in TEST_F() 354 cameraBase->streamInfo->bufferQueue_ = producer; in TEST_F() 398 cameraBase->streamInfo->bufferQueue_ = producer; in TEST_F() 442 cameraBase->streamInfo->bufferQueue_ = producer; in TEST_F() 496 cameraBase->streamInfo->bufferQueue_ = producer; in TEST_F() [all …]
|
H A D | usb_camera_test_mult.cpp | 70 …streamInfoPre_.bufferQueue_ = new BufferProducerSequenceable(streamCustomerPreview_->CreateProduce… in DefaultInfosPreview() 71 ASSERT_NE(streamInfoPre_.bufferQueue_, nullptr); in DefaultInfosPreview() 72 streamInfoPre_.bufferQueue_->producer_->SetQueueSize(8); // 8:set bufferQueue size in DefaultInfosPreview() 91 …streamInfoVideo_.bufferQueue_ = new BufferProducerSequenceable(streamCustomerVideo_->CreateProduce… in DefaultInfosVideo() 92 ASSERT_NE(streamInfoVideo_.bufferQueue_, nullptr); in DefaultInfosVideo() 93 streamInfoVideo_.bufferQueue_->producer_->SetQueueSize(8); // 8:set bufferQueue size in DefaultInfosVideo() 112 …streamInfoCapture_.bufferQueue_ = new BufferProducerSequenceable(streamCustomerCapture_->CreatePro… in DefaultInfosCapture() 113 ASSERT_NE(streamInfoCapture_.bufferQueue_, nullptr); in DefaultInfosCapture() 114 streamInfoCapture_.bufferQueue_->producer_->SetQueueSize(8); // 8:set bufferQueue size in DefaultInfosCapture()
|
/ohos5.0/drivers/peripheral/distributed_camera/hdi_service/test/unittest/common/dstream_operator/ |
H A D | dstream_operator_test.cpp | 135 streamInfo.bufferQueue_ = sptr<BufferProducerSequenceable>(new BufferProducerSequenceable()); 163 streamInfo.bufferQueue_ = nullptr; 191 …streamInfo.bufferQueue_ = sptr<BufferProducerSequenceable>(new BufferProducerSequenceable(producer… 192 streamInfo.bufferQueue_->producer_->SetQueueSize(TEST_DATASPACE); 225 …streamInfo.bufferQueue_ = sptr<BufferProducerSequenceable>(new BufferProducerSequenceable(producer… 226 streamInfo.bufferQueue_->producer_->SetQueueSize(TEST_DATASPACE); 260 streamInfo.bufferQueue_ = nullptr; 296 …streamInfo.bufferQueue_ = sptr<BufferProducerSequenceable>(new BufferProducerSequenceable(producer… 297 streamInfo.bufferQueue_->producer_->SetQueueSize(TEST_DATASPACE); 337 …streamInfo.bufferQueue_ = sptr<BufferProducerSequenceable>(new BufferProducerSequenceable(producer… [all …]
|
/ohos5.0/drivers/peripheral/distributed_camera/hdi_service/src/dstream_operator/ |
H A D | dcamera_stream.cpp | 41 dcStreamInfo_->bufferQueue_ = info.bufferQueue_; in InitDCameraStream() 56 if (dcStreamInfo_->bufferQueue_ != nullptr) { in InitDCameraStream() 74 … if (dcStreamInfo_->bufferQueue_ != nullptr && dcStreamInfo_->bufferQueue_->producer_ != nullptr) { in InitDCameraBufferManager() 75 …dcStreamProducer_ = OHOS::Surface::CreateSurfaceAsProducer(dcStreamInfo_->bufferQueue_->producer_); in InitDCameraBufferManager() 103 if (dcStreamInfo_->bufferQueue_) { in SetDCameraBufferQueue() 108 dcStreamInfo_->bufferQueue_ = producer; in SetDCameraBufferQueue() 125 if (dcStreamInfo_ != nullptr && dcStreamInfo_->bufferQueue_ != nullptr) { in ReleaseDCameraBufferQueue() 126 dcStreamInfo_->bufferQueue_->producer_ = nullptr; in ReleaseDCameraBufferQueue() 127 dcStreamInfo_->bufferQueue_ = nullptr; in ReleaseDCameraBufferQueue()
|
/ohos5.0/drivers/peripheral/camera/test/benchmarktest/v1_0/src/ |
H A D | camera_benchmark_test.cpp | 182 if (streamInfoPre->bufferQueue_ == nullptr) { in BENCHMARK_F() 187 streamInfoPre->bufferQueue_->producer_->SetQueueSize(OHOS::Camera::UT_DATA_SIZE); in BENCHMARK_F() 222 … streamInfoPre->bufferQueue_ = consumer_pre->CreateProducerSeq([this](void* addr, uint32_t size) { in BENCHMARK_F() 225 streamInfoPre->bufferQueue_->producer_->SetQueueSize(OHOS::Camera::UT_DATA_SIZE); in BENCHMARK_F() 468 cameraTest->streamInfo->bufferQueue_->producer_->SetQueueSize(8); in BENCHMARK_F() 514 cameraTest->streamInfo->bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in BENCHMARK_F() 533 cameraTest->streamInfoSnapshot->bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in BENCHMARK_F() 593 cameraTest->streamInfo->bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in BENCHMARK_F() 612 cameraTest->streamInfoSnapshot->bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in BENCHMARK_F() 671 cameraTest->streamInfo->bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in BENCHMARK_F() [all …]
|
/ohos5.0/foundation/graphic/graphic_surface/surface/include/ |
H A D | buffer_queue_consumer.h | 68 bufferQueue_->ConsumerRequestCpuAccess(on); in ConsumerRequestCpuAccess() 76 if (bufferQueue_ == nullptr) { in IsBufferHold() 79 return bufferQueue_->IsBufferHold(); in IsBufferHold() 86 sptr<BufferQueue> bufferQueue_ = nullptr;
|
/ohos5.0/drivers/peripheral/camera/vdi_base/common/pipeline_core/nodes/src/fork_node/ |
H A D | fork_node.cpp | 161 bufferQueue_.push(forkBuffer); in DeliverBuffer() 222 stopForkThread_ ? 0 : 1, bufferQueue_.empty() ? 0 : 1); in DeliverBufferToNextNode() 223 return stopForkThread_ || !bufferQueue_.empty(); in DeliverBufferToNextNode() 228 if (bufferQueue_.empty()) { in DeliverBufferToNextNode() 232 std::shared_ptr<IBuffer> forkBuffer = bufferQueue_.front(); in DeliverBufferToNextNode() 233 bufferQueue_.pop(); in DeliverBufferToNextNode()
|
/ohos5.0/docs/zh-cn/device-dev/reference/hdi-apis/camera/ |
H A D | _stream_info_v10.md | 27 | BufferProducerSequenceable [bufferQueue_](#bufferqueue_) | 图形提供的生产者句柄。 | 35 ### bufferQueue_ subsection 38 BufferProducerSequenceable StreamInfo::bufferQueue_
|
/ohos5.0/drivers/peripheral/camera/hdi_service/v1_0/src/ |
H A D | camera_service_type_converter.cpp | 29 dst.bufferQueue_ = src.bufferQueue_; in ConvertStreamInfoHdiToVdi() 81 dst.bufferQueue_ = src.bufferQueue_; in ConvertStreamInfoVdiToHdi()
|
/ohos5.0/drivers/peripheral/camera/test/hdi/v1_3/src/ |
H A D | hdi_common_v1_3.cpp | 207 infos->v1_0.bufferQueue_ = consumer_pre->CreateProducerSeq([this](void* addr, uint32_t size) { in DefaultInfosSketch() 210 infos->v1_0.bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in DefaultInfosSketch() 219 infos->v1_0.bufferQueue_ = consumer_pre->CreateProducerSeq([this](void* addr, uint32_t size) { in DefaultInfosMeta() 222 infos->v1_0.bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in DefaultInfosMeta() 231 infos->v1_0.bufferQueue_ = consumer_pre->CreateProducerSeq([this](void* addr, uint32_t size) { in DefaultInfosPreviewV1_2() 234 infos->v1_0.bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in DefaultInfosPreviewV1_2() 245 infos->v1_0.bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in DefaultInfosPreview() 257 infos->v1_0.bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in DefaultInfosCapture() 269 infos->v1_0.bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in DefaultInfosProfessionalCapture() 288 infos->v1_0.bufferQueue_->producer_->SetQueueSize(UT_DATA_SIZE); in DefaultInfosVideo() [all …]
|