Home
last modified time | relevance | path

Searched refs:streamId (Results 1 – 25 of 143) sorted by relevance

123456

/drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/dispatcher/
Dstream_pipeline_dispatcher.cpp90 void StreamPipelineDispatcher::CutUselessBranch(int32_t streamId, std::vector<std::shared_ptr<INode… in CutUselessBranch() argument
92 …auto it = std::find_if(branch.begin(), branch.end(), [streamId](const std::shared_ptr<INode> node)… in CutUselessBranch()
96 if (port->GetStreamId() == streamId) { in CutUselessBranch()
111 RetCode StreamPipelineDispatcher::Prepare(const int32_t streamId) in Prepare() argument
113 if (seqNode_.count(streamId) == 0) { in Prepare()
118 for (auto it = seqNode_[streamId].rbegin(); it != seqNode_[streamId].rend(); it++) { in Prepare()
120 ret = (*it)->Init(streamId) | ret; in Prepare()
126 RetCode StreamPipelineDispatcher::Start(const int32_t streamId) in Start() argument
128 if (seqNode_.count(streamId) == 0) { in Start()
133 for (auto it = seqNode_[streamId].rbegin(); it != seqNode_[streamId].rend(); it++) { in Start()
[all …]
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, std::vector<std::shared_ptr<INode>>& branch);
/drivers/peripheral/camera/vdi_base/common/adapter/platform/mpp/src/pipeline_core/nodes/vpss_node/
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()
[all …]
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/camera/vdi_base/common/pipeline_core/nodes/src/source_node/
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
45 if (streamId == format.streamId_) { in Start()
56 if (handler_.count(streamId) > 0) { in Start()
57 CAMERA_LOGI("stream [%{public}d] start again, skip", streamId); in Start()
67 handler_[streamId] = ph; in Start()
69 RetCode rc = handler_[streamId]->StartCollectBuffers(); in Start()
72 rc = handler_[streamId]->StartDistributeBuffers(); in Start()
78 RetCode SourceNode::Flush(const int32_t streamId) in Flush() argument
[all …]
Dsource_node.h27 RetCode Init(const int32_t streamId) override;
28 RetCode Start(const int32_t streamId) override;
29 RetCode Flush(const int32_t streamId) override;
30 RetCode Stop(const int32_t streamId) override;
31 RetCode Capture(const int32_t streamId, const int32_t captureId) override;
32 RetCode CancelCapture(const int32_t streamId) override;
33 RetCode Config(const int32_t streamId, const CaptureMeta& meta) override;
/drivers/peripheral/camera/hal_c/include/
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/usb_camera/pipeline_core/src/node/
Dfork_node.cpp29 RetCode PcForkNode::Start(const int32_t streamId) in Start() argument
34 CAMERA_LOGI("PcForkNode::Start streamId = %{public}d\n", streamId); in Start()
71 RetCode PcForkNode::Stop(const int32_t streamId) in Stop() argument
73 CAMERA_LOGI("PcForkNode::Stop streamId = %{public}d\n", streamId); in Stop()
86 RetCode PcForkNode::Flush(const int32_t streamId) in Flush() argument
88 if (streamId_ == streamId) { in Flush()
146 RetCode PcForkNode::Capture(const int32_t streamId, const int32_t captureId) in Capture() argument
149 streamId, captureRequests_[streamId].size()); in Capture()
153 if (streamId == in->format_.streamId_) { in Capture()
159 if (captureRequests_.count(streamId) == 0) { in Capture()
[all …]
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;
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;
Dexif_node.cpp30 RetCode RKExifNode::Start(const int32_t streamId) in Start() argument
32 CAMERA_LOGI("RKExifNode::Start streamId = %{public}d\n", streamId); in Start()
36 RetCode RKExifNode::Stop(const int32_t streamId) in Stop() argument
38 CAMERA_LOGI("RKExifNode::Stop streamId = %{public}d\n", streamId); in Stop()
42 RetCode RKExifNode::Flush(const int32_t streamId) in Flush() argument
44 CAMERA_LOGI("RKExifNode::Flush streamId = %{public}d\n", streamId); in Flush()
84 RetCode RKExifNode::Config(const int32_t streamId, const CaptureMeta &meta) in Config() argument
87 CAMERA_LOGW("%{public}s streamId= %{public}d", __FUNCTION__, streamId); in Config()
162 RetCode RKExifNode::Capture(const int32_t streamId, const int32_t captureId) in Capture() argument
168 RetCode RKExifNode::CancelCapture(const int32_t streamId) in CancelCapture() argument
[all …]
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;
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);
/drivers/peripheral/camera/vdi_base/common/metadata_manager/src/
Dmetadata_controller.cpp154 int32_t streamId = GetStreamId(meta); in UpdateSettingsConfig() local
155 if (streamId < 0) { in UpdateSettingsConfig()
156 CAMERA_LOGE("streamId is invalid %{public}d", streamId); in UpdateSettingsConfig()
159 result = FilterUpdateKeys(streamId, meta); in UpdateSettingsConfig()
161 CAMERA_LOGE("filter update keys fail and streamId = %{public}d", streamId); in UpdateSettingsConfig()
164 return DealMetadata(streamId, meta); in UpdateSettingsConfig()
181 int32_t streamId = -1; in GetStreamId() local
184 streamId = *entry.data.i32; in GetStreamId()
186 return streamId; in GetStreamId()
189 bool MetadataController::FilterUpdateKeys(int32_t streamId, const std::shared_ptr<CameraMetadata> &… in FilterUpdateKeys() argument
[all …]
Dmetadata_config.cpp26 bool MetadataConfig::UpdateSettingsConfig(int32_t streamId, bool isNew, const std::vector<int32_t> … 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/vdi_base/common/pipeline_core/nodes/src/sink_node/
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/
Dfork_node.cpp29 RetCode ForkNode::Start(const int32_t streamId) in Start() argument
38 streamId, this, streamRunning_ ? 0 : 1); in Start()
79 RetCode ForkNode::Stop(const int32_t streamId) in Stop() argument
81 CAMERA_LOGI("ForkNode::Stop streamId = %{public}d\n", streamId); in Stop()
91 …LOGD("ForkNode Stop streamId:%{public}d bqcv_:%{public}p this:%{public}p", &bqcv_, this, streamId); in Stop()
106 RetCode ForkNode::Flush(const int32_t streamId) in Flush() argument
108 if (streamId_ == streamId) { in Flush()
147 RetCode ForkNode::Capture(const int32_t streamId, const int32_t captureId) in Capture() argument
150 streamId, captureRequests_[streamId].size()); in Capture()
154 if (streamId == in->format_.streamId_) { in Capture()
[all …]
/drivers/peripheral/camera/hal_c/hdi_cif/src/
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 …MERA_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 …MERA_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 == nullptr) { in StreamCBOnFrameShutter()
99 ids.push_back(streamId[i]); in StreamCBOnFrameShutter()
/drivers/peripheral/camera/vdi_base/common/adapter/platform/v4l2/src/pipeline_core/nodes/v4l2_source_node/
Dv4l2_source_node.cpp49 RetCode V4L2SourceNode::Init(const int32_t streamId) in Init() argument
54 RetCode V4L2SourceNode::Start(const int32_t streamId) in Start() argument
81 rc = SourceNode::Start(streamId); in Start()
90 RetCode V4L2SourceNode::Flush(const int32_t streamId) in Flush() argument
95 rc = sensorController_->Flush(streamId); in Flush()
98 rc = SourceNode::Flush(streamId); in Flush()
103 RetCode V4L2SourceNode::Stop(const int32_t streamId) in Stop() argument
112 return SourceNode::Stop(streamId); in Stop()
132 int32_t streamId = -1; in GetStreamId() local
135 streamId = *entry.data.i32; in GetStreamId()
[all …]
/drivers/peripheral/camera/vdi_base/common/adapter/platform/mpp/src/pipeline_core/nodes/venc_node/
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/camera/vdi_base/common/pipeline_core/nodes/src/node_base/
Dnode_base.cpp133 RetCode NodeBase::Init(const int32_t streamId) in Init() argument
135 (void)streamId; in Init()
139 RetCode NodeBase::Start(const int32_t streamId) in Start() argument
141 (void)streamId; in Start()
146 RetCode NodeBase::Flush(const int32_t streamId) in Flush() argument
148 (void)streamId; in Flush()
157 RetCode NodeBase::Stop(const int32_t streamId) in Stop() argument
159 (void)streamId; in Stop()
163 RetCode NodeBase::Config(const int32_t streamId, const CaptureMeta& meta) in Config() argument
165 (void)streamId; in Config()
[all …]
/drivers/peripheral/distributed_camera/hdi_service/include/dstream_operator/
Ddstream_operator.h54 …int32_t AttachBufferQueue(int32_t streamId, const sptr<BufferProducerSequenceable> &bufferProducer…
55 int32_t DetachBufferQueue(int32_t streamId) override;
65 DCamRetCode AcquireBuffer(int streamId, DCameraBuffer &buffer);
66 DCamRetCode ShutterBuffer(int streamId, const DCameraBuffer &buffer);
90 void SnapShotStreamOnCaptureEnded(int32_t captureId, int streamId);
102 std::shared_ptr<DCameraStream> FindHalStreamById(int32_t streamId);
103 void InsertHalStream(int32_t streamId, std::shared_ptr<DCameraStream>& dcStream);
104 void EraseHalStream(int32_t streamId);
109 int32_t FindCaptureIdByStreamId(int32_t streamId);
111 std::shared_ptr<DCStreamInfo> FindDCStreamById(int32_t streamId);
[all …]
/drivers/peripheral/camera/vdi_base/usb_camera/adapter/platform/v4l2/src/pipeline_core/nodes/uvc_node/
Duvc_node.cpp79 RetCode UvcNode::Init(const int32_t streamId) in Init() argument
84 RetCode UvcNode::Flush(const int32_t streamId) in Flush() argument
89 rc = sensorController_->Flush(streamId); in Flush()
92 rc = SourceNode::Flush(streamId); in Flush()
97 RetCode UvcNode::Start(const int32_t streamId) in Start() argument
116 rc = SourceNode::Start(streamId); in Start()
120 RetCode UvcNode::Stop(const int32_t streamId) in Stop() argument
129 return SourceNode::Stop(streamId); in Stop()
149 int32_t streamId = -1; in GetStreamId() local
152 streamId = *entry.data.i32; in GetStreamId()
[all …]
/drivers/peripheral/camera/vdi_base/v4l2/include/stream_operator/
Dcapture_message.h40 ICaptureMessage(int32_t streamId, int32_t captureId, uint64_t time, uint32_t count);
63 CaptureStartedMessage(int32_t streamId, int32_t captureId, uint64_t time, uint32_t count) in CaptureStartedMessage() argument
64 : ICaptureMessage(streamId, captureId, time, count) in CaptureStartedMessage()
76 …CaptureEndedMessage(int32_t streamId, int32_t captureId, uint64_t time, uint32_t peerCount, uint32… in CaptureEndedMessage() argument
77 : ICaptureMessage(streamId, captureId, time, peerCount) in CaptureEndedMessage()
97 CaptureErrorMessage(int32_t streamId, int32_t captureId, uint64_t time, uint32_t peerCount, in CaptureErrorMessage() argument
98 VdiStreamError errorCode) : ICaptureMessage(streamId, captureId, time, peerCount) in CaptureErrorMessage()
120 FrameShutterMessage(int32_t streamId, int32_t captureId, uint64_t time, uint32_t count) in FrameShutterMessage() argument
121 : ICaptureMessage(streamId, captureId, time, count) in FrameShutterMessage()
/drivers/peripheral/camera/vdi_base/common/pipeline_core/ipp/src/
Doffline_pipeline_manager.cpp31 RetCode OfflinePipelineManager::SwitchToOfflinePipeline(int32_t streamId, in SwitchToOfflinePipeline() argument
37 auto op = GetOfflinePipeline(streamId, pipeline); in SwitchToOfflinePipeline()
48 offlinePipelineList_.emplace_back(std::make_pair(streamId, op)); in SwitchToOfflinePipeline()
54 RetCode OfflinePipelineManager::CancelCapture(int32_t streamId, int32_t captureId) in CancelCapture() argument
56 auto op = FindOfflinePipeline(streamId); in CancelCapture()
102 std::shared_ptr<OfflinePipeline> OfflinePipelineManager::GetOfflinePipeline(int32_t streamId, in GetOfflinePipeline() argument
109 return pipeline->GetOfflinePipeline(streamId); in GetOfflinePipeline()

123456