Home
last modified time | relevance | path

Searched refs:streamId (Results 1 - 25 of 160) sorted by relevance

1234567

/drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/dispatcher/
H A Dstream_pipeline_dispatcher.cpp92 void StreamPipelineDispatcher::CutUselessBranch(int32_t streamId, std::vector<std::shared_ptr<INode>>& branch) in CutUselessBranch() argument
94 auto it = std::find_if(branch.begin(), branch.end(), [streamId](const std::shared_ptr<INode> node) { in CutUselessBranch()
98 if (port->GetStreamId() == streamId) { in CutUselessBranch()
113 RetCode StreamPipelineDispatcher::Prepare(const int32_t streamId) in Prepare() argument
115 if (seqNode_.count(streamId) == 0) { in Prepare()
120 for (auto it = seqNode_[streamId].rbegin(); it != seqNode_[streamId].rend(); it++) { in Prepare()
122 ret = (*it)->Init(streamId) | ret; in Prepare()
128 RetCode StreamPipelineDispatcher::Start(const int32_t streamId) in Start() argument
130 if (seqNode_.count(streamId) in Start()
143 Config(const int32_t streamId, const CaptureMeta& meta) Config() argument
156 Flush(const int32_t streamId) Flush() argument
177 Stop(const int32_t streamId) Stop() argument
192 Capture(const int32_t streamId, const int32_t captureId) Capture() argument
206 CancelCapture(const int32_t streamId) CancelCapture() argument
220 Destroy(const int32_t streamId) Destroy() argument
232 GetNode(const int32_t streamId, const std::string name) GetNode() argument
[all...]
H A Dstream_pipeline_dispatcher.h30 virtual RetCode Prepare(const int32_t streamId);
31 virtual RetCode Start(const int32_t streamId);
32 virtual RetCode Config(const int32_t streamId, const CaptureMeta& meta);
33 virtual RetCode Capture(const int32_t streamId, const int32_t captureId);
34 virtual RetCode CancelCapture(const int32_t streamId);
35 virtual RetCode Flush(const int32_t streamId);
38 virtual RetCode Stop(const int32_t streamId);
39 virtual RetCode Destroy(const int32_t streamId);
40 virtual std::shared_ptr<INode> GetNode(const int32_t streamId, const std::string name);
45 void CutUselessBranch(int32_t streamId, st
[all...]
/drivers/peripheral/camera/vdi_base/common/adapter/platform/mpp/src/pipeline_core/nodes/vpss_node/
H A Dvpss_node.cpp41 RetCode VpssNode::Init(const int32_t streamId) in Init() argument
43 (void)streamId; in Init()
47 RetCode VpssNode::Start(const int32_t streamId) in Start() argument
66 rc = ConnectMpi(streamId); in Start()
71 rc = SourceNode::Start(streamId); in Start()
72 ids_[streamId] = -1; in Start()
76 RetCode VpssNode::Flush(const int32_t streamId) in Flush() argument
79 rc = SourceNode::Flush(streamId); in Flush()
82 rc = DisConnectMpi(streamId); in Flush()
92 rc = IDeviceManager::GetInstance()->Flush(streamId); in Flush()
97 Stop(const int32_t streamId) Stop() argument
119 Capture(const int32_t streamId, const int32_t captureId) Capture() argument
135 CancelCapture(const int32_t streamId) CancelCapture() argument
[all...]
H A Dvpss_node.h34 RetCode Init(const int32_t streamId) override;
35 RetCode Start(const int32_t streamId) override;
36 RetCode Flush(const int32_t streamId) override;
37 RetCode Stop(const int32_t streamId) override;
40 RetCode Capture(const int32_t streamId, const int32_t captureId) override;
41 RetCode CancelCapture(const int32_t streamId) override;
/drivers/peripheral/distributed_audio/hdi_service/audio_ext/v1_0/test/unittest/include/
H A Ddaudio_test_utils.h30 int32_t CreateStream(int32_t streamId) override
35 int32_t DestroyStream(int32_t streamId) override
40 int32_t SetParameters(int32_t streamId, const AudioParameter &param) override
45 int32_t NotifyEvent(int32_t streamId, const DAudioEvent &event) override
50 int32_t WriteStreamData(int32_t streamId, const AudioData &data) override
55 int32_t ReadStreamData(int32_t streamId, AudioData &data) override
60 int32_t ReadMmapPosition(int32_t streamId, uint64_t &frames, CurrentTime &time) override
65 int32_t RefreshAshmemInfo(int32_t streamId, int fd, int32_t ashmemLength, int32_t lengthPerTrans) override
/drivers/peripheral/camera/vdi_base/usb_camera/pipeline_core/src/node/
H A Dscale_node.cpp34 RetCode ScaleNode::Start(const int32_t streamId) in Start() argument
36 CAMERA_LOGI("ScaleNode::Start streamId = %{public}d\n", streamId); in Start()
40 RetCode ScaleNode::Stop(const int32_t streamId) in Stop() argument
42 CAMERA_LOGI("ScaleNode::Stop streamId = %{public}d\n", streamId); in Stop()
46 RetCode ScaleNode::Flush(const int32_t streamId) in Flush() argument
48 CAMERA_LOGI("ScaleNode::Flush streamId = %{public}d\n", streamId); in Flush()
75 RetCode ScaleNode::Capture(const int32_t streamId, cons argument
81 CancelCapture(const int32_t streamId) CancelCapture() argument
[all...]
H A Dfork_node.cpp30 RetCode PcForkNode::Start(const int32_t streamId) in Start() argument
35 CAMERA_LOGI("PcForkNode::Start streamId = %{public}d\n", streamId); in Start()
49 CAMERA_LOGI("fork buffer get buffer streamId = %{public}d", out->format_.streamId_); in Start()
72 RetCode PcForkNode::Stop(const int32_t streamId) in Stop() argument
74 CAMERA_LOGI("PcForkNode::Stop streamId = %{public}d\n", streamId); in Stop()
89 RetCode PcForkNode::Flush(const int32_t streamId) in Flush() argument
91 if (streamId_ == streamId) { in Flush()
157 CAMERA_LOGE("Deliver fork buffer, streamId[ in DeliverBuffer()
165 Capture(const int32_t streamId, const int32_t captureId) Capture() argument
187 CancelCapture(const int32_t streamId) CancelCapture() argument
[all...]
H A Dscale_node.h31 RetCode Start(const int32_t streamId) override;
32 RetCode Stop(const int32_t streamId) override;
34 virtual RetCode Capture(const int32_t streamId, const int32_t captureId) override;
35 RetCode CancelCapture(const int32_t streamId) override;
36 RetCode Flush(const int32_t streamId);
H A Dexif_node.cpp31 RetCode ExifNode::Start(const int32_t streamId) in Start() argument
33 CAMERA_LOGI("ExifNode::Start streamId = %{public}d\n", streamId); in Start()
37 RetCode ExifNode::Stop(const int32_t streamId) in Stop() argument
39 CAMERA_LOGI("ExifNode::Stop streamId = %{public}d\n", streamId); in Stop()
43 RetCode ExifNode::Flush(const int32_t streamId) in Flush() argument
45 CAMERA_LOGI("ExifNode::Flush streamId = %{public}d\n", streamId); in Flush()
83 RetCode ExifNode::Config(const int32_t streamId, cons argument
161 Capture(const int32_t streamId, const int32_t captureId) Capture() argument
167 CancelCapture(const int32_t streamId) CancelCapture() argument
[all...]
H A Dexif_node.h36 RetCode Start(const int32_t streamId) override;
37 RetCode Stop(const int32_t streamId) override;
39 virtual RetCode Capture(const int32_t streamId, const int32_t captureId) override;
40 RetCode CancelCapture(const int32_t streamId) override;
41 RetCode Flush(const int32_t streamId);
42 RetCode Config(const int32_t streamId, const CaptureMeta &meta) override;
H A Dcodec_node.h31 RetCode Start(const int32_t streamId) override;
32 RetCode Stop(const int32_t streamId) override;
34 virtual RetCode Capture(const int32_t streamId, const int32_t captureId) override;
35 RetCode CancelCapture(const int32_t streamId) override;
36 RetCode Flush(const int32_t streamId);
39 RetCode Config(const int32_t streamId, const CaptureMeta& meta) override;
H A Dfork_node.h29 RetCode Start(const int32_t streamId) override;
30 RetCode Stop(const int32_t streamId) override;
32 RetCode Capture(const int32_t streamId, const int32_t captureId) override;
33 RetCode CancelCapture(const int32_t streamId) override;
34 RetCode Flush(const int32_t streamId);
H A Dface_node.h43 RetCode Start(const int32_t streamId) override;
44 RetCode Stop(const int32_t streamId) override;
46 virtual RetCode Capture(const int32_t streamId, const int32_t captureId) override;
47 RetCode CancelCapture(const int32_t streamId) override;
48 RetCode Flush(const int32_t streamId);
49 RetCode Config(const int32_t streamId, const CaptureMeta& meta) override;
H A Dface_node.cpp31 RetCode FaceNode::Start(const int32_t streamId) in Start() argument
33 CAMERA_LOGI("FaceNode::Start streamId = %{public}d\n", streamId); in Start()
38 RetCode FaceNode::Stop(const int32_t streamId) in Stop() argument
40 CAMERA_LOGI("FaceNode::Stop streamId = %{public}d\n", streamId); in Stop()
46 RetCode FaceNode::Flush(const int32_t streamId) in Flush() argument
48 CAMERA_LOGI("FaceNode::Flush streamId = %{public}d\n", streamId); in Flush()
69 RetCode FaceNode::Config(const int32_t streamId, cons argument
80 Capture(const int32_t streamId, const int32_t captureId) Capture() argument
86 CancelCapture(const int32_t streamId) CancelCapture() argument
[all...]
/drivers/peripheral/camera/vdi_base/common/metadata_manager/src/
H A Dmetadata_controller.cpp163 int32_t streamId = GetStreamId(meta); in UpdateSettingsConfig() local
164 if (streamId < 0) { in UpdateSettingsConfig()
165 CAMERA_LOGE("streamId is invalid %{public}d", streamId); in UpdateSettingsConfig()
168 result = FilterUpdateKeys(streamId, meta); in UpdateSettingsConfig()
170 CAMERA_LOGE("filter update keys fail and streamId = %{public}d", streamId); in UpdateSettingsConfig()
173 return DealMetadata(streamId, meta); in UpdateSettingsConfig()
190 int32_t streamId = -1; in GetStreamId() local
193 streamId in GetStreamId()
198 FilterUpdateKeys(int32_t streamId, const std::shared_ptr<CameraMetadata> &meta) FilterUpdateKeys() argument
224 DealMetadata(int32_t streamId, const std::shared_ptr<CameraMetadata> &meta) DealMetadata() argument
270 CompareMetadata(int32_t streamId, const std::shared_ptr<CameraMetadata> &oldMeta, const std::shared_ptr<CameraMetadata> &newMeta, std::shared_ptr<CameraMetadata> &outMetadata) CompareMetadata() argument
323 UpdateChangeMetadata(int32_t streamId, const std::vector<int32_t> &updateKeys, const std::vector<int32_t> &newKeys, const std::shared_ptr<CameraMetadata> &newMeta, std::shared_ptr<CameraMetadata> &outMetadata) UpdateChangeMetadata() argument
598 NotifyMetaData(int32_t streamId) NotifyMetaData() argument
[all...]
H A Dmetadata_config.cpp26 bool MetadataConfig::UpdateSettingsConfig(int32_t streamId, bool isNew, const std::vector<int32_t> &updateKeys, in UpdateSettingsConfig() argument
34 if (metadata_.count(streamId) == 0) { in UpdateSettingsConfig()
40 metadata_[streamId] = meta; in UpdateSettingsConfig()
58 result = metadata_[streamId]->addEntry(*it, static_cast<void *>(entry.data.u8), entry.count); in UpdateSettingsConfig()
60 result = metadata_[streamId]->updateEntry(*it, static_cast<void *>(entry.data.u8), entry.count); in UpdateSettingsConfig()
70 bool MetadataConfig::GetMetadata(int32_t streamId, std::shared_ptr<CameraMetadata> &metaData) in GetMetadata() argument
72 if (streamId < 0 || metadata_.count(streamId) == 0) { in GetMetadata()
75 metaData = metadata_[streamId]; in GetMetadata()
/drivers/peripheral/camera/hal_c/include/
H A Dcamera_types_c_if.h100 int streamId; member
155 int streamId; member
178 int streamId; member
208 int streamId; member
215 int (*GetQueueSize)(int streamId);
216 unsigned int (*SetQueueSize)(int streamId, int size);
217 void (*DetachBufferProducer)(int streamId);
221 int streamId; member
/drivers/peripheral/camera/vdi_base/common/pipeline_core/nodes/src/sink_node/
H A Dsink_node.cpp24 RetCode SinkNode::Start(const int32_t streamId) in Start() argument
26 (void)streamId; in Start()
30 RetCode SinkNode::Stop(const int32_t streamId) in Stop() argument
32 (void)streamId; in Stop()
39 int32_t streamId = buffer->GetStreamId(); in DeliverBuffer() local
42 metaDataController.NotifyMetaData(streamId); in DeliverBuffer()
/drivers/peripheral/camera/vdi_base/common/pipeline_core/nodes/src/fork_node/
H A Dfork_node.cpp30 RetCode ForkNode::Start(const int32_t streamId) in Start() argument
38 CAMERA_LOGI("ForkNode::Start streamId = %{public}d this:[%{public}p] streamRunning_ = %{public}d\n", in Start()
39 streamId, this, streamRunning_ ? 0 : 1); in Start()
50 CAMERA_LOGI("fork buffer get buffer streamId = %{public}d", out->format_.streamId_); in Start()
80 RetCode ForkNode::Stop(const int32_t streamId) in Stop() argument
82 CAMERA_LOGI("ForkNode::Stop streamId = %{public}d\n", streamId); in Stop()
92 CAMERA_LOGD("ForkNode Stop streamId:%{public}d bqcv_:%{public}p this:%{public}p", &bqcv_, this, streamId); in Stop()
109 RetCode ForkNode::Flush(const int32_t streamId) in Flush() argument
177 Capture(const int32_t streamId, const int32_t captureId) Capture() argument
238 CancelCapture(const int32_t streamId) CancelCapture() argument
[all...]
/drivers/peripheral/camera/vdi_base/common/pipeline_core/nodes/src/source_node/
H A Dsource_node.cpp32 RetCode SourceNode::Init(const int32_t streamId) in Init() argument
34 (void)streamId; in Init()
38 RetCode SourceNode::Start(const int32_t streamId) in Start() argument
40 CAMERA_LOGI("SourceNode::Start [%{public}d] start", streamId); in Start()
46 if (streamId == format.streamId_) { in Start()
57 if (handler_.count(streamId) > 0) { in Start()
58 CAMERA_LOGI("stream [%{public}d] start again, skip", streamId); in Start()
69 handler_[streamId] = ph; in Start()
71 RetCode rc = handler_[streamId]->StartCollectBuffers(); in Start()
74 rc = handler_[streamId] in Start()
80 Flush(const int32_t streamId) Flush() argument
87 Stop(const int32_t streamId) Stop() argument
102 Config(const int32_t streamId, const CaptureMeta& meta) Config() argument
155 Capture(const int32_t streamId, const int32_t captureId) Capture() argument
168 CancelCapture(const int32_t streamId) CancelCapture() argument
190 uint32_t streamId = format.streamId_; StartCollectBuffers() local
[all...]
/drivers/peripheral/camera/hal_c/hdi_cif/src/
H A Dstream_operator_callback_wrapper.cpp28 void StreamCBOnCaptureStarted(int captureId, const int* streamId, int count) in StreamCBOnCaptureStarted() argument
35 ids.push_back(streamId[i]); in StreamCBOnCaptureStarted()
51 CAMERA_LOGE("it is nullptr captureId: %{public}d streamId: %{public}d", captureId, info[i].streamId); in StreamCBOnCaptureEnded()
54 it->streamId_ = info[i].streamId; in StreamCBOnCaptureEnded()
74 CAMERA_LOGE("it is nullptr captureId: %{public}d streamId: %{public}d", captureId, info[i].streamId); in StreamCBOnCaptureError()
77 it->streamId_ = info[i].streamId; in StreamCBOnCaptureError()
87 void StreamCBOnFrameShutter(int captureId, const int* streamId, int count, uint64_t timestamp) in StreamCBOnFrameShutter() argument
93 if (streamId in StreamCBOnFrameShutter()
[all...]
/drivers/peripheral/camera/vdi_base/common/adapter/platform/mpp/src/pipeline_core/nodes/venc_node/
H A Dvenc_node.cpp27 RetCode VencNode::Start(const int32_t streamId) in Start() argument
29 (void)streamId; in Start()
32 RetCode VencNode::Stop(const int32_t streamId) in Stop() argument
34 (void)streamId; in Stop()
/drivers/peripheral/distributed_camera/hdi_service/include/dstream_operator/
H A Ddstream_operator.h68 int32_t AttachBufferQueue(int32_t streamId, const sptr<BufferProducerSequenceable> &bufferProducer) override;
69 int32_t DetachBufferQueue(int32_t streamId) override;
74 int32_t EnableResult(int32_t streamId, const std::vector<uint8_t> &results) override;
75 int32_t DisableResult(int32_t streamId, const std::vector<uint8_t> &results) override;
83 DCamRetCode AcquireBuffer(int streamId, DCameraBuffer &buffer);
84 DCamRetCode ShutterBuffer(int streamId, const DCameraBuffer &buffer);
110 void SnapShotStreamOnCaptureEnded(int32_t captureId, int streamId);
123 std::shared_ptr<DCameraStream> FindHalStreamById(int32_t streamId);
124 void InsertHalStream(int32_t streamId, std::shared_ptr<DCameraStream>& dcStream);
125 void EraseHalStream(int32_t streamId);
[all...]
/drivers/peripheral/camera/vdi_base/common/adapter/platform/v4l2/src/pipeline_core/nodes/v4l2_source_node/
H A Dv4l2_source_node.cpp52 RetCode V4L2SourceNode::Init(const int32_t streamId) in Init() argument
57 RetCode V4L2SourceNode::Start(const int32_t streamId) in Start() argument
75 if (streamId == CaptureStreamId) { in Start()
98 rc = SourceNode::Start(streamId); in Start()
107 RetCode V4L2SourceNode::Flush(const int32_t streamId) in Flush() argument
112 rc = sensorController_->Flush(streamId); in Flush()
115 rc = SourceNode::Flush(streamId); in Flush()
120 RetCode V4L2SourceNode::Stop(const int32_t streamId) in Stop() argument
129 return SourceNode::Stop(streamId); in Stop()
149 int32_t streamId in GetStreamId() local
[all...]
/drivers/peripheral/camera/vdi_base/usb_camera/adapter/platform/v4l2/src/pipeline_core/nodes/uvc_node/
H A Duvc_node.cpp79 RetCode UvcNode::Init(const int32_t streamId) in Init() argument
81 CAMERA_LOGD("UvcNode::Init streamId = %{public}d", streamId); in Init()
85 RetCode UvcNode::Flush(const int32_t streamId) in Flush() argument
90 rc = sensorController_->Flush(streamId); in Flush()
93 rc = SourceNode::Flush(streamId); in Flush()
98 RetCode UvcNode::Start(const int32_t streamId) in Start() argument
118 rc = SourceNode::Start(streamId); in Start()
122 RetCode UvcNode::Stop(const int32_t streamId) in Stop() argument
131 return SourceNode::Stop(streamId); in Stop()
151 int32_t streamId = -1; GetStreamId() local
[all...]

Completed in 9 milliseconds

1234567