From 48dd910f2aa88386a3eba6d63bc0ce4b67ee1169 Mon Sep 17 00:00:00 2001 From: wuzhihuitmac Date: Wed, 17 Jul 2024 09:42:28 +0800 Subject: [PATCH] thread change to ffrt Signed-off-by: wuzhihuitmac Change-Id: I4db258e2ca48c9bfa65a2c5d1b6c05f344630be2 --- frameworks/native/src/sensor_data_channel.cpp | 7 ++----- services/src/sensor_service.cpp | 2 ++ 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/frameworks/native/src/sensor_data_channel.cpp b/frameworks/native/src/sensor_data_channel.cpp index 141ee803..c5473295 100644 --- a/frameworks/native/src/sensor_data_channel.cpp +++ b/frameworks/native/src/sensor_data_channel.cpp @@ -27,9 +27,6 @@ namespace OHOS { namespace Sensors { using namespace OHOS::HiviewDFX; using namespace OHOS::AppExecFwk; -namespace { -const std::string LISTENER_THREAD_NAME = "OS_SenConsumer"; -} // namespace int32_t SensorDataChannel::CreateSensorDataChannel(DataChannelCB callBack, void *data) { @@ -61,7 +58,7 @@ int32_t SensorDataChannel::InnerSensorDataChannel() auto listener = std::make_shared(); listener->SetChannel(this); if (eventHandler_ == nullptr) { - auto myRunner = AppExecFwk::EventRunner::Create(LISTENER_THREAD_NAME); + auto myRunner = AppExecFwk::EventRunner::Create(true, AppExecFwk::ThreadMode::FFRT); CHKPR(myRunner, ERROR); eventHandler_ = std::make_shared(myRunner); } @@ -97,7 +94,7 @@ int32_t SensorDataChannel::AddFdListener(int32_t fd, ReceiveMessageFun receiveMe disconnect_ = disconnect; std::lock_guard eventRunnerLock(eventRunnerMutex_); if (eventHandler_ == nullptr) { - auto myRunner = AppExecFwk::EventRunner::Create(LISTENER_THREAD_NAME); + auto myRunner = AppExecFwk::EventRunner::Create(true, AppExecFwk::ThreadMode::FFRT); CHKPR(myRunner, ERROR); eventHandler_ = std::make_shared(myRunner); } diff --git a/services/src/sensor_service.cpp b/services/src/sensor_service.cpp index 2aa55dc4..eef9a2f3 100644 --- a/services/src/sensor_service.cpp +++ b/services/src/sensor_service.cpp @@ -189,9 +189,11 @@ void SensorService::ReportSensorSysEvent(int32_t sensorId, bool enable, int32_t if (enable) { HiSysEventWrite(HiSysEvent::Domain::SENSOR, "ENABLE_SENSOR", HiSysEvent::EventType::STATISTIC, "LEVEL", logLevel, "UID", uid, "PKG_NAME", packageName, "TYPE", sensorId); + SEN_HILOGI("PackageName:%{public}s open the sensor, sensorId:%{public}d", packageName.c_str(), sensorId); } else { HiSysEventWrite(HiSysEvent::Domain::SENSOR, "DISABLE_SENSOR", HiSysEvent::EventType::STATISTIC, "LEVEL", logLevel, "UID", uid, "PKG_NAME", packageName, "TYPE", sensorId); + SEN_HILOGI("PackageName:%{public}s close the sensor, sensorId:%{public}d", packageName.c_str(), sensorId); } } -- Gitee