diff --git a/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_controller.cpp b/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_controller.cpp index 414f8f6079c93e0fc3f7c13f208afb6d2b651f0a..bcbd27c39f8b3c3ce5dd704d99138b785be11a20 100644 --- a/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_controller.cpp +++ b/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_controller.cpp @@ -248,7 +248,7 @@ int32_t DCameraSinkController::Init(std::vector& indexs) } channel_ = std::make_shared(); - eventBus_ = std::make_shared(); + eventBus_ = std::make_shared("SinkCtlHandler"); DCameraFrameTriggerEvent triggerEvent(*this); DCameraPostAuthorizationEvent authEvent(*this); eventBus_->AddHandler(triggerEvent.GetType(), *this); diff --git a/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_data_process.cpp b/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_data_process.cpp index d870b710ef4fbe0b16b1ff1c5a691851d21c0188..a4959e77087803ecf48727b69f4c0fe290e4e449 100644 --- a/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_data_process.cpp +++ b/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_data_process.cpp @@ -29,7 +29,7 @@ DCameraSinkDataProcess::DCameraSinkDataProcess(const std::string& dhId, std::sha : dhId_(dhId), channel_(channel) { DHLOGI("DCameraSinkDataProcess Constructor dhId: %s", GetAnonyString(dhId_).c_str()); - eventBus_ = std::make_shared(); + eventBus_ = std::make_shared("SinkDPHandler"); DCameraPhotoOutputEvent photoEvent(*this); DCameraVideoOutputEvent videoEvent(*this); eventBus_->AddHandler(photoEvent.GetType(), *this); diff --git a/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_data_process_common.cpp b/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_data_process_common.cpp index c44c69296591a9639cc86960173e7f62f6fc0ff0..addaca00b454252ecc0a9591ec1f1c31dfc862d3 100644 --- a/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_data_process_common.cpp +++ b/services/cameraservice/sinkservice/src/distributedcameramgr/dcamera_sink_data_process_common.cpp @@ -29,7 +29,7 @@ DCameraSinkDataProcess::DCameraSinkDataProcess(const std::string& dhId, std::sha : dhId_(dhId), channel_(channel) { DHLOGI("DCameraSinkDataProcess Constructor dhId: %s", GetAnonyString(dhId_).c_str()); - eventBus_ = std::make_shared(); + eventBus_ = std::make_shared("SinkDPHandler"); DCameraPhotoOutputEvent photoEvent(*this); DCameraVideoOutputEvent videoEvent(*this); eventBus_->AddHandler(photoEvent.GetType(), *this); diff --git a/services/cameraservice/sourceservice/src/distributedcameramgr/dcamera_source_dev.cpp b/services/cameraservice/sourceservice/src/distributedcameramgr/dcamera_source_dev.cpp index 821f5fadfc60f9b0cb25f29d335a8fc90cc0b4a4..403f09b764b4f249195a171bddfeb20ac9cfd58e 100644 --- a/services/cameraservice/sourceservice/src/distributedcameramgr/dcamera_source_dev.cpp +++ b/services/cameraservice/sourceservice/src/distributedcameramgr/dcamera_source_dev.cpp @@ -76,7 +76,7 @@ int32_t DCameraSourceDev::InitDCameraSourceDev() { DHLOGI("DCameraSourceDev InitDCameraSourceDev devId %s dhId %s", GetAnonyString(devId_).c_str(), GetAnonyString(dhId_).c_str()); - eventBus_ = std::make_shared(); + eventBus_ = std::make_shared("SrcDevHandler"); DCameraSourceEvent event(*this); eventBus_->AddHandler(event.GetType(), *this); auto cameraSourceDev = std::shared_ptr(shared_from_this()); diff --git a/services/data_process/src/pipeline/dcamera_pipeline_source.cpp b/services/data_process/src/pipeline/dcamera_pipeline_source.cpp index 11abb907ef005913c15ca557f096f6deaad5dab3..fa5e3a38f23456f84f3bbcf2cd87689d8b3d25f0 100644 --- a/services/data_process/src/pipeline/dcamera_pipeline_source.cpp +++ b/services/data_process/src/pipeline/dcamera_pipeline_source.cpp @@ -83,7 +83,7 @@ bool DCameraPipelineSource::IsInRange(const VideoConfigParams& curConfig) void DCameraPipelineSource::InitDCameraPipEvent() { DHLOGD("Init source DCamera pipeline event to asynchronously process data."); - eventBusSource_ = std::make_shared(); + eventBusSource_ = std::make_shared("PipelineSrcHandler"); DCameraPipelineEvent pipelineEvent(*this, std::make_shared()); eventBusSource_->AddHandler(pipelineEvent.GetType(), *this); } diff --git a/services/data_process/src/pipeline_node/multimedia_codec/decoder/decode_data_process.cpp b/services/data_process/src/pipeline_node/multimedia_codec/decoder/decode_data_process.cpp index f7daa46d83c2284b3be9eaea4d4e359197600b71..d5f6a9c3fa692d9cbe61029314bbe2462b9cf162 100644 --- a/services/data_process/src/pipeline_node/multimedia_codec/decoder/decode_data_process.cpp +++ b/services/data_process/src/pipeline_node/multimedia_codec/decoder/decode_data_process.cpp @@ -91,7 +91,7 @@ bool DecodeDataProcess::IsConvertible(const VideoConfigParams& sourceConfig, con void DecodeDataProcess::InitCodecEvent() { DHLOGD("Init DecodeNode eventBus, and add handler for it."); - eventBusDecode_ = std::make_shared(); + eventBusDecode_ = std::make_shared("DeDtProcHandler"); DCameraCodecEvent codecEvent(*this, std::make_shared()); eventBusRegHandleDecode_ = eventBusDecode_->AddHandler(codecEvent.GetType(), *this); diff --git a/services/data_process/src/pipeline_node/multimedia_codec/decoder/decode_data_process_common.cpp b/services/data_process/src/pipeline_node/multimedia_codec/decoder/decode_data_process_common.cpp index b00dfa52cfcf869166a5644ec06601a75e02d187..26166903b807a23168777dc4b39e5d663b2472eb 100644 --- a/services/data_process/src/pipeline_node/multimedia_codec/decoder/decode_data_process_common.cpp +++ b/services/data_process/src/pipeline_node/multimedia_codec/decoder/decode_data_process_common.cpp @@ -91,7 +91,7 @@ bool DecodeDataProcess::IsConvertible(const VideoConfigParams& sourceConfig, con void DecodeDataProcess::InitCodecEvent() { DHLOGD("Common Init DecodeNode eventBus, and add handler for it."); - eventBusDecode_ = std::make_shared(); + eventBusDecode_ = std::make_shared("DeDtProcHandler"); DCameraCodecEvent codecEvent(*this, std::make_shared()); eventBusRegHandleDecode_ = eventBusDecode_->AddHandler(codecEvent.GetType(), *this);