Home
last modified time | relevance | path

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

12345678910>>...16

/ohos5.0/drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/dispatcher/
H A Dstream_pipeline_dispatcher.cpp115 if (seqNode_.count(streamId) == 0) { in Prepare()
120 for (auto it = seqNode_[streamId].rbegin(); it != seqNode_[streamId].rend(); it++) { in Prepare()
135 for (auto it = seqNode_[streamId].rbegin(); it != seqNode_[streamId].rend(); it++) { in Start()
150 for (auto it = seqNode_[streamId].rbegin(); it != seqNode_[streamId].rend(); it++) { in Config()
163 for (auto it = seqNode_[streamId].rbegin(); it != seqNode_[streamId].rend(); it++) { in Flush()
184 for (auto it = seqNode_[streamId].rbegin(); it != seqNode_[streamId].rend(); it++) { in Stop()
199 for (auto it = seqNode_[streamId].begin(); it != seqNode_[streamId].end(); it++) { in Capture()
213 for (auto it = seqNode_[streamId].begin(); it != seqNode_[streamId].end(); it++) { in CancelCapture()
222 auto it = seqNode_.find(streamId); in Destroy()
227 seqNode_.erase(streamId); in Destroy()
[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, std::vector<std::shared_ptr<INode>>& branch);
/ohos5.0/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()
79 rc = SourceNode::Flush(streamId); in Flush()
82 rc = DisConnectMpi(streamId); in Flush()
99 return SourceNode::Stop(streamId); in Stop()
126 if (captureId == ids_[streamId]) { in Capture()
[all …]
/ohos5.0/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()
173 return DealMetadata(streamId, meta); in UpdateSettingsConfig()
190 int32_t streamId = -1; in GetStreamId() local
193 streamId = *entry.data.i32; in GetStreamId()
195 return streamId; in GetStreamId()
227 if (firstNotifyNodes_.count(streamId) == 0 && streamId != DEVICE_STREAM_ID) { in DealMetadata()
230 changeDataKeys_[streamId] = updateMetaDataKeys_[streamId]; in DealMetadata()
344 … changeDataKeys_[streamId].insert(changeDataKeys_[streamId].end(), newKeys.begin(), newKeys.end()); in UpdateChangeMetadata()
614 if (streamId == DEVICE_STREAM_ID) { in NotifyMetaData()
[all …]
H A 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()
/ohos5.0/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
46 if (streamId == format.streamId_) { in Start()
57 if (handler_.count(streamId) > 0) { in Start()
69 handler_[streamId] = ph; in Start()
83 handler_[streamId]->StopCollectBuffers(); in Flush()
94 auto it = handler_.find(streamId); in Stop()
164 streamId, captureRequests_[streamId].size()); in Capture()
170 (void)streamId; in CancelCapture()
[all …]
/ohos5.0/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/
H A Ddcamera_stream_data_process.cpp50 for (auto streamId : streamIds_) { in FeedStream() local
73 for (auto streamId : streamIds) { in ConfigStreams() local
85 for (auto streamId : streamIds) { in ReleaseStreams() local
91 int32_t streamId = *iter; in ReleaseStreams() local
93 GetAnonyString(dhId_).c_str(), streamId); in ReleaseStreams()
94 streamIds_.erase(streamId); in ReleaseStreams()
100 producers_.erase(streamId); in ReleaseStreams()
122 uint32_t streamId = *iter; in StartCapture() local
136 producers_[streamId] = in StartCapture()
138 producers_[streamId]->Start(); in StartCapture()
[all …]
/ohos5.0/foundation/multimedia/av_codec/services/media_engine/modules/demuxer/
H A Ddemuxer_plugin_manager.cpp137 curAudioStreamID_ = info.streamId; in InitAudioTrack()
149 streamInfoMap_[info.streamId].type = AUDIO; in InitAudioTrack()
169 streamInfoMap_[info.streamId].type = VIDEO; in InitVideoTrack()
175 curSubTitleStreamID_ = info.streamId; in InitSubtitleTrack()
192 int32_t streamIndex = iter.streamId; in InitDefaultPlay()
531 auto iter = streamInfoMap_.find(streamId); in StartPlugin()
542 UpdateMediaInfo(streamId); in StartPlugin()
559 streamDemuxer->ResetCache(streamId); in StopPlugin()
571 streamDemuxer->ResetCache(streamId); in RebootPlugin()
579 streamId, newStreamId); in RebootPlugin()
[all …]
/ohos5.0/drivers/peripheral/camera/vdi_base/usb_camera/pipeline_core/src/node/
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()
72 RetCode PcForkNode::Stop(const int32_t streamId) in Stop() argument
89 RetCode PcForkNode::Flush(const int32_t streamId) in Flush() argument
91 if (streamId_ == streamId) { in Flush()
168 streamId, captureRequests_[streamId].size()); in Capture()
172 if (streamId == in->format_.streamId_) { in Capture()
178 if (captureRequests_.count(streamId) == 0) { in Capture()
179 captureRequests_[streamId] = {captureId}; in Capture()
181 captureRequests_[streamId].emplace_back(captureId); in Capture()
[all …]
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, const int32_t captureId) in Capture() argument
81 RetCode ScaleNode::CancelCapture(const int32_t streamId) in CancelCapture() argument
83 CAMERA_LOGI("ScaleNode::CancelCapture streamid = %{public}d", streamId); in CancelCapture()
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, const CaptureMeta &meta) in Config() argument
86 CAMERA_LOGW("%{public}s streamId= %{public}d", __FUNCTION__, streamId); in Config()
161 RetCode ExifNode::Capture(const int32_t streamId, const int32_t captureId) in Capture() argument
167 RetCode ExifNode::CancelCapture(const int32_t streamId) in CancelCapture() argument
[all …]
/ohos5.0/foundation/multimedia/camera_lite/services/impl/include/
H A Dcamera_device.h47 virtual int32_t SetFrameConfig(FrameConfig &fc, uint32_t *streamId) in SetFrameConfig() argument
51 virtual int32_t Start(uint32_t streamId) in Start() argument
68 int32_t SetFrameConfig(FrameConfig &fc, uint32_t *streamId) override;
69 int32_t Start(uint32_t streamId) override;
82 int32_t SetFrameConfig(FrameConfig &fc, uint32_t *streamId) override;
83 int32_t Start(uint32_t streamId) override;
92 int32_t SetFrameConfig(FrameConfig &fc, uint32_t *streamId) override;
93 int32_t Start(uint32_t streamId) override;
102 int32_t Start(uint32_t streamId) override;
119 int32_t TriggerLoopingCapture(FrameConfig &fc, uint32_t *streamId);
[all …]
/ohos5.0/foundation/multimedia/av_codec/services/media_engine/plugins/source/http_source/dash/
H A Ddash_media_downloader.cpp155 VideoSegmentDownloadFinished(streamId); in UpdateDownloadFinished()
403 auto doneCallback = [this] (int streamId) { in OpenInitSegment() argument
404 UpdateDownloadFinished(streamId); in OpenInitSegment()
421 int streamId = -1; in ReceiveMpdParseOkEvent() local
428 if (DoPreparedAction(streamId)) { in ReceiveMpdParseOkEvent()
439 GetSegmentToDownload(streamId, true); in ReceiveMpdParseOkEvent()
446 int downloadStreamId = streamId; in VideoSegmentDownloadFinished()
712 int streamId = trackParam_.streamId_; in IsSeekingInSwitch() local
734 streamType, streamId, isEos); in HandleSeekReady()
971 if (DoPreparedSwitchAudio(streamId)) { in DoPreparedSwitchAction()
[all …]
H A Ddash_media_downloader.h55 Status SelectStream(int32_t streamId) override;
64 void UpdateDownloadFinished(int streamId);
67 void SetDemuxerState(int32_t streamId) override;
77 void VideoSegmentDownloadFinished(int streamId);
81 bool CheckAutoSelectBitrate(int streamId);
90 bool DoPreparedSwitchBitrate(bool switchBitrateOk, bool &needDownload, int &streamId);
91 bool DoPreparedSwitchAudio(int &streamId);
92 bool DoPreparedSwitchSubtitle(int &streamId);
94 bool DoPreparedAction(int &streamId);
98 std::shared_ptr<DashSegmentDownloader> GetSegmentDownloader(int32_t streamId);
[all …]
/ohos5.0/foundation/multimedia/audio_framework/services/audio_policy/server/src/service/session/
H A Daudio_session.cpp82 uint32_t streamId = interruptPair.first.sessionId; in AddAudioInterrpt() local
83 AUDIO_INFO_LOG("AddAudioInterrpt: streamId %{public}u", streamId); in AddAudioInterrpt()
86 if (interruptMap_.count(streamId) != 0) { in AddAudioInterrpt()
89 interruptMap_[streamId] = interruptPair; in AddAudioInterrpt()
98 uint32_t streamId = interruptPair.first.sessionId; in RemoveAudioInterrpt() local
99 AUDIO_INFO_LOG("RemoveAudioInterrpt: streamId %{public}u", streamId); in RemoveAudioInterrpt()
102 if (interruptMap_.count(streamId) == 0) { in RemoveAudioInterrpt()
106 interruptMap_.erase(streamId); in RemoveAudioInterrpt()
113 int32_t AudioSession::RemoveAudioInterrptByStreamId(const uint32_t &streamId) in RemoveAudioInterrptByStreamId() argument
118 if (interruptMap_.count(streamId) == 0) { in RemoveAudioInterrptByStreamId()
[all …]
/ohos5.0/foundation/distributedhardware/distributed_audio/services/audiohdiproxy/include/
H A Didaudio_hdi_callback.h29 virtual int32_t CreateStream(const int32_t streamId) = 0;
31 virtual int32_t DestroyStream(const int32_t streamId) = 0;
33 virtual int32_t SetParameters(const int32_t streamId, const AudioParamHDF &param) = 0;
35 virtual int32_t NotifyEvent(const int32_t streamId, const AudioEvent &event) = 0;
37 virtual int32_t WriteStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) = 0;
39 virtual int32_t ReadStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) = 0;
41 …virtual int32_t ReadMmapPosition(const int32_t streamId, uint64_t &frames, CurrentTimeHDF &time) =…
43 virtual int32_t RefreshAshmemInfo(const int32_t streamId,
H A Ddaudio_manager_callback.h31 int32_t CreateStream(int32_t streamId) override;
33 int32_t DestroyStream(int32_t streamId) override;
35 int32_t SetParameters(int32_t streamId,
38 int32_t NotifyEvent(int32_t streamId,
41 int32_t WriteStreamData(int32_t streamId,
44 int32_t ReadStreamData(int32_t streamId,
47 int32_t ReadMmapPosition(int32_t streamId, uint64_t &frames,
50 …int32_t RefreshAshmemInfo(int32_t streamId, int fd, int32_t ashmemLength, int32_t lengthPerTrans) …
/ohos5.0/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
39 streamId, this, streamRunning_ ? 0 : 1); in Start()
80 RetCode ForkNode::Stop(const int32_t streamId) in Stop() argument
109 RetCode ForkNode::Flush(const int32_t streamId) in Flush() argument
111 if (streamId_ == streamId) { in Flush()
180 streamId, captureRequests_[streamId].size()); in Capture()
184 if (streamId == in->format_.streamId_) { in Capture()
190 if (captureRequests_.count(streamId) == 0) { in Capture()
191 captureRequests_[streamId] = {captureId}; in Capture()
193 captureRequests_[streamId].emplace_back(captureId); in Capture()
[all …]
/ohos5.0/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 in CreateStream() argument
35 int32_t DestroyStream(int32_t streamId) override in DestroyStream() argument
40 int32_t SetParameters(int32_t streamId, const AudioParameter &param) override in SetParameters() argument
45 int32_t NotifyEvent(int32_t streamId, const DAudioEvent &event) override in NotifyEvent() argument
50 int32_t WriteStreamData(int32_t streamId, const AudioData &data) override in WriteStreamData() argument
55 int32_t ReadStreamData(int32_t streamId, AudioData &data) override in ReadStreamData() argument
60 int32_t ReadMmapPosition(int32_t streamId, uint64_t &frames, CurrentTime &time) override in ReadMmapPosition() argument
65 …int32_t RefreshAshmemInfo(int32_t streamId, int fd, int32_t ashmemLength, int32_t lengthPerTrans) … in RefreshAshmemInfo() argument
/ohos5.0/foundation/distributedhardware/distributed_audio/services/audiohdiproxy/test/unittest/daudio_manager_callback/include/
H A Daudio_test_utils.h30 int32_t CreateStream(const int32_t streamId) override in CreateStream() argument
35 int32_t DestroyStream(const int32_t streamId) override in DestroyStream() argument
40 int32_t SetParameters(const int32_t streamId, const AudioParamHDF &param) override in SetParameters() argument
45 int32_t NotifyEvent(const int32_t streamId, const AudioEvent &event) override in NotifyEvent() argument
50 int32_t WriteStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override in WriteStreamData() argument
55 int32_t ReadStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override in ReadStreamData() argument
61 int32_t ReadMmapPosition(const int32_t streamId, uint64_t &frames, CurrentTimeHDF &time) in ReadMmapPosition() argument
66 …int32_t RefreshAshmemInfo(const int32_t streamId, int32_t fd, int32_t ashmemLength, int32_t length… in RefreshAshmemInfo() argument
/ohos5.0/foundation/distributedhardware/distributed_audio/services/audiohdiproxy/src/
H A Ddaudio_manager_callback.cpp39 if (callback_->CreateStream(streamId) != DH_SUCCESS) { in CreateStream()
46 int32_t DAudioManagerCallback::DestroyStream(int32_t streamId) in DestroyStream() argument
50 if (callback_->DestroyStream(streamId) != DH_SUCCESS) { in DestroyStream()
116 ret = callback_->SetParameters(streamId, paramHDF); in SetParameters()
124 int32_t DAudioManagerCallback::NotifyEvent(int32_t streamId, in NotifyEvent() argument
163 int32_t ret = callback_->NotifyEvent(streamId, newEvent); in NotifyEvent()
171 int32_t DAudioManagerCallback::WriteStreamData(int32_t streamId, in WriteStreamData() argument
188 if (callback_->WriteStreamData(streamId, audioData) != DH_SUCCESS) { in WriteStreamData()
195 int32_t DAudioManagerCallback::ReadStreamData(int32_t streamId, in ReadStreamData() argument
201 if (callback_->ReadStreamData(streamId, audioData) != DH_SUCCESS) { in ReadStreamData()
[all …]
/ohos5.0/foundation/distributedhardware/distributed_audio/services/audiohdiproxy/test/unittest/daudio_hdi_handler/include/
H A Daudio_test_utils.h46 int32_t NotifyEvent(const std::string &adpName, int32_t devId, int32_t streamId, in NotifyEvent() argument
58 int32_t CreateStream(const int32_t streamId) override in CreateStream() argument
63 int32_t DestroyStream(const int32_t streamId) override in DestroyStream() argument
68 int32_t SetParameters(const int32_t streamId, const AudioParamHDF &param) override in SetParameters() argument
73 int32_t NotifyEvent(const int32_t streamId, const AudioEvent &event) override in NotifyEvent() argument
78 int32_t WriteStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override in WriteStreamData() argument
83 int32_t ReadStreamData(const int32_t streamId, std::shared_ptr<AudioData> &data) override in ReadStreamData() argument
88 int32_t ReadMmapPosition(const int32_t streamId, uint64_t &frames, CurrentTimeHDF &time) in ReadMmapPosition() argument
93 …int32_t RefreshAshmemInfo(const int32_t streamId, int32_t fd, int32_t ashmemLength, int32_t length… in RefreshAshmemInfo() argument
/ohos5.0/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
/ohos5.0/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 …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()
/ohos5.0/drivers/interface/distributed_audio/audioext/v2_0/
H A DIDAudioCallback.idl47 * @param streamId Stream ID for distributed audio devices.
54 CreateStream([in] int streamId);
59 * @param streamId Stream ID for distributed audio devices.
66 DestroyStream([in] int streamId);
71 * @param streamId Stream ID for distributed audio devices.
84 * @param streamId Stream ID for distributed audio devices.
92 NotifyEvent([in] int streamId, [in] struct DAudioEvent event);
97 * @param streamId Stream ID for distributed audio devices.
110 * @param streamId Stream ID for distributed audio devices.
123 * @param streamId Stream ID for distributed audio devices.
[all …]

12345678910>>...16