diff --git a/services/src/sensor_data_processer.cpp b/services/src/sensor_data_processer.cpp index 9a23c4e3e4ea1acfe0df48582f73508e4c04289e..f67513209cc663c41c859e3e927860492026a60f 100644 --- a/services/src/sensor_data_processer.cpp +++ b/services/src/sensor_data_processer.cpp @@ -15,6 +15,7 @@ #include "sensor_data_processer.h" +#include #include #include #include @@ -208,7 +209,8 @@ void SensorDataProcesser::SendRawData(std::unordered_map &c size_t eventSize = events.size(); auto ret = channel->SendData(events.data(), eventSize * sizeof(SensorData)); if (ret != ERR_OK) { - SEN_HILOGE("Send data failed, ret:%{public}d", ret); + SEN_HILOGE("Send data failed, ret:%{public}d, sensorId:%{public}d, timestamp:%{public}" PRId64, + ret, events[eventSize - 1].sensorTypeId, events[eventSize - 1].timestamp); int32_t sensorId = events[eventSize - 1].sensorTypeId; cacheBuf[sensorId] = events[eventSize - 1]; } @@ -223,13 +225,16 @@ int32_t SensorDataProcesser::CacheSensorEvent(const SensorData &data, sptrSendData(&cacheEvent->second, sizeof(SensorData)); + const SensorData &cacheData = cacheEvent->second; + ret = channel->SendData(&cacheData, sizeof(SensorData)); if (ret != ERR_OK) { - SEN_HILOGE("ret:%{public}d", ret); + SEN_HILOGE("retry send cache data failed, ret:%{public}d, sensorId:%{public}d, timestamp:%{public}" PRId64, + ret, cacheData.sensorTypeId, cacheData.timestamp); } ret = channel->SendData(&data, sizeof(SensorData)); if (ret != ERR_OK) { - SEN_HILOGE("ret:%{public}d", ret); + SEN_HILOGE("retry send data failed, ret:%{public}d, sensorId:%{public}d, timestamp:%{public}" PRId64, + ret, data.sensorTypeId, data.timestamp); cacheBuf[sensorId] = data; } else { cacheBuf.erase(cacheEvent); @@ -237,7 +242,8 @@ int32_t SensorDataProcesser::CacheSensorEvent(const SensorData &data, sptrSendData(&data, sizeof(SensorData)); if (ret != ERR_OK) { - SEN_HILOGE("ret:%{public}d", ret); + SEN_HILOGE("directly retry failed, ret:%{public}d, sensorId:%{public}d, timestamp:%{public}" PRId64, + ret, data.sensorTypeId, data.timestamp); cacheBuf[sensorId] = data; } } diff --git a/services/src/sensor_manager.cpp b/services/src/sensor_manager.cpp index 941dd45d90fbe197e2256d7a6b52778cc7e0c5a0..dcfbb3fec0db984a85c7339d2f7d881506ddaa5e 100644 --- a/services/src/sensor_manager.cpp +++ b/services/src/sensor_manager.cpp @@ -155,7 +155,7 @@ bool SensorManager::IsOtherClientUsingSensor(int32_t sensorId, int32_t clientPid { CALL_LOG_ENTER; if (clientInfo_.OnlyCurPidSensorEnabled(sensorId, clientPid)) { - SEN_HILOGW("Only current client using this sensor"); + SEN_HILOGD("Only current client using this sensor"); return false; } clientInfo_.ClearCurPidSensorInfo(sensorId, clientPid); diff --git a/utils/common/src/sensor_basic_data_channel.cpp b/utils/common/src/sensor_basic_data_channel.cpp index 1e01b867433ccb20a019a5c3d6c3fa5907cb691c..6114778fa5e24cda306542b019f86d8492b38bbe 100644 --- a/utils/common/src/sensor_basic_data_channel.cpp +++ b/utils/common/src/sensor_basic_data_channel.cpp @@ -151,7 +151,7 @@ int32_t SensorBasicDataChannel::SendData(const void *vaddr, size_t size) length = send(sendFd_, vaddr, size, MSG_DONTWAIT | MSG_NOSIGNAL); } while (errno == EINTR); if (length < 0) { - SEN_HILOGE("Send fail:%{public}d, length:%{public}d", errno, (int32_t)length); + SEN_HILOGD("Send fail:%{public}d, length:%{public}d", errno, (int32_t)length); return SENSOR_CHANNEL_SEND_DATA_ERR; } return ERR_OK;