diff --git a/common/include/input_hub.cpp b/common/include/input_hub.cpp index ceac8927fe577e6a5e15c40243918d6cdd664a84..e243ab45a5b83a680f69f0b642c6c887b919f15c 100644 --- a/common/include/input_hub.cpp +++ b/common/include/input_hub.cpp @@ -182,8 +182,6 @@ size_t InputHub::GetEvents(RawEvent *buffer, size_t bufferSize) GetAnonyString(device->identifier.descriptor).c_str()); continue; } - DHLOGD("shared device dhId: %s, name: %s", GetAnonyString(device->identifier.descriptor).c_str(), - device->identifier.name.c_str()); if (eventItem.events & EPOLLIN) { event += CollectEvent(event, capacity, device, readBuffer, count); @@ -213,7 +211,6 @@ bool InputHub::IsTouchPad(Device *device) bool InputHub::IsTouchPad(const InputDevice &inputDevice) { std::string dhName = inputDevice.name; - DHLOGD("device name is %s.", dhName.c_str()); transform(dhName.begin(), dhName.end(), dhName.begin(), ::tolower); if (dhName.find(DH_TOUCH_PAD) == std::string::npos) { return false; @@ -270,7 +267,6 @@ void InputHub::MatchAndDealEvent(Device *device, const RawEvent &event) void InputHub::RecordDeviceChangeStates(Device *device, struct input_event readBuffer[], const size_t count) { - DHLOGD("RecordDeviceChangeStates enter."); bool isTouchEvent = false; if ((device->classes & INPUT_DEVICE_CLASS_TOUCH_MT) || (device->classes & INPUT_DEVICE_CLASS_TOUCH)) { if (!IsTouchPad(device->identifier)) { @@ -289,7 +285,6 @@ void InputHub::RecordDeviceChangeStates(Device *device, struct input_event readB event.descriptor = isTouchEvent ? touchDescriptor : device->identifier.descriptor; MatchAndDealEvent(device, event); } - DHLOGD("RecordDeviceChangeStates end."); } size_t InputHub::CollectEvent(RawEvent *buffer, size_t &capacity, Device *device, struct input_event readBuffer[], @@ -1115,12 +1110,9 @@ InputHub::Device* InputHub::GetDeviceByFdLocked(int fd) InputHub::Device* InputHub::GetSupportDeviceByFd(int fd) { - DHLOGD("GetSupportDeviceByFd fd: %d", fd); std::lock_guard deviceLock(devicesMutex_); for (const auto &[id, device] : devices_) { if (device != nullptr && device->fd == fd) { - DHLOGD("GetSupportDeviceByFd device fd: %d, path: %s, dhId: %s, classes=0x%x", device->fd, - device->path.c_str(), GetAnonyString(device->identifier.descriptor).c_str(), device->classes); return device.get(); } } diff --git a/services/sink/inputcollector/src/distributed_input_collector.cpp b/services/sink/inputcollector/src/distributed_input_collector.cpp index e70c1988b4e115d38c8eb977660a9ae17c9b3feb..bd33f4f9afd99b6676a3520df9b5e59fb347d5cf 100644 --- a/services/sink/inputcollector/src/distributed_input_collector.cpp +++ b/services/sink/inputcollector/src/distributed_input_collector.cpp @@ -116,9 +116,7 @@ void DistributedInputCollector::StartCollectEventsThread() return; } size_t count = inputHub_->StartCollectInputEvents(mEventBuffer, INPUT_EVENT_BUFFER_SIZE); - if (count > 0) { - DHLOGD("Count: %zu", count); - } else { + if (count <= 0) { continue; } diff --git a/services/sink/transport/src/distributed_input_sink_transport.cpp b/services/sink/transport/src/distributed_input_sink_transport.cpp index 69368ca13c47c20d1df4f5ccf6e4bbd497eff066..7e6ae564fcd50f393c44cd3e483c82bf4cce0747 100644 --- a/services/sink/transport/src/distributed_input_sink_transport.cpp +++ b/services/sink/transport/src/distributed_input_sink_transport.cpp @@ -69,7 +69,6 @@ DistributedInputSinkTransport &DistributedInputSinkTransport::GetInstance() void DistributedInputSinkTransport::DInputSinkEventHandler::ProcessEvent(const AppExecFwk::InnerEvent::Pointer &event) { - DHLOGD("ProcessEvent"); EHandlerMsgType eventId = static_cast(event->GetInnerEventId()); switch (eventId) { case EHandlerMsgType::DINPUT_SINK_EVENT_HANDLER_MSG: { @@ -199,7 +198,6 @@ int32_t DistributedInputSinkTransport::RespLatency(const int32_t sessionId, std: return ERR_DH_INPUT_SERVER_SINK_TRANSPORT_RESP_LATENCY_FAIL; } - DHLOGD("RespLatency sessionId: %d, smsg:%s.", sessionId, SetAnonyId(smsg).c_str()); return DH_SUCCESS; } diff --git a/services/source/inputinject/src/distributed_input_node_manager.cpp b/services/source/inputinject/src/distributed_input_node_manager.cpp index a429a984a1ec1c2ba1a4cd34e4b9f63210a8d6c6..8b3954cd89d0380c045aabbad46a59746a90c7ab 100644 --- a/services/source/inputinject/src/distributed_input_node_manager.cpp +++ b/services/source/inputinject/src/distributed_input_node_manager.cpp @@ -485,10 +485,8 @@ void DistributedInputNodeManager::InjectEvent() injectQueue_.pop(); } - DHLOGD("process event, inject queue size: %zu", injectQueue_.size()); ProcessInjectEvent(events); } - DHLOGD("end"); } void DistributedInputNodeManager::RegisterInjectEventCb(sptr callback) diff --git a/services/source/inputinject/src/virtual_device.cpp b/services/source/inputinject/src/virtual_device.cpp index f75dcbfa311d5af6f82756e0dc74be595de594ea..566a906d64cdb1cf94383ca669af7d143f1bdc43 100644 --- a/services/source/inputinject/src/virtual_device.cpp +++ b/services/source/inputinject/src/virtual_device.cpp @@ -173,15 +173,11 @@ bool VirtualDevice::SetUp(const InputDevice &inputDevice, const std::string &dev bool VirtualDevice::InjectInputEvent(const input_event &event) { - DHLOGI("InjectInputEvent %d", fd_); - if (write(fd_, &event, sizeof(event)) < static_cast(sizeof(event))) { DHLOGE("could not inject event, removed? (fd: %d", fd_); return false; } RecordEventLog(event); - DHLOGI("InjectInputEvent end\n"); - return true; } diff --git a/services/source/transport/src/distributed_input_source_transport.cpp b/services/source/transport/src/distributed_input_source_transport.cpp index 48fd7a7b5d607f1a49a6f8d2cc81f5b0c7d6dcd2..ceea71e75f9211c9ff4ee5b923f60e194945e3dc 100644 --- a/services/source/transport/src/distributed_input_source_transport.cpp +++ b/services/source/transport/src/distributed_input_source_transport.cpp @@ -651,8 +651,6 @@ int32_t DistributedInputSourceTransport::LatencyCount(const std::string &deviceI return ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_LATENCY_FAIL; } - DHLOGD("LatencyCount deviceId:%s, sessionId: %d, smsg:%s.", - GetAnonyString(deviceId).c_str(), sessionId, SetAnonyId(smsg).c_str()); return DH_SUCCESS; } @@ -662,7 +660,6 @@ void DistributedInputSourceTransport::StartLatencyCount(const std::string &devic if (ret != 0) { DHLOGE("StartLatencyCount setname failed."); } - DHLOGI("start"); while (isLatencyThreadRunning_.load()) { if (sendNum_ >= INPUT_LATENCY_DELAY_TIMES) { uint64_t latency = (uint64_t)(deltaTimeAll_ / 2 / INPUT_LATENCY_DELAY_TIMES); @@ -679,7 +676,6 @@ void DistributedInputSourceTransport::StartLatencyCount(const std::string &devic sendNum_ += 1; usleep(INPUT_LATENCY_DELAYTIME_US); } - DHLOGI("end"); } void DistributedInputSourceTransport::StartLatencyThread(const std::string &deviceId) @@ -1095,7 +1091,6 @@ void DistributedInputSourceTransport::NotifyReceivedEventRemoteInput(int32_t ses void DistributedInputSourceTransport::CalculateLatency(int32_t sessionId, const nlohmann::json &recMsg) { - DHLOGD("OnBytesReceived cmdType is TRANS_SINK_MSG_LATENCY."); std::string deviceId = DistributedInputTransportBase::GetInstance().GetDevIdBySessionId(sessionId); if (deviceId.empty()) { DHLOGE("OnBytesReceived cmdType is TRANS_SINK_MSG_LATENCY, deviceId is error."); diff --git a/services/transportbase/src/distributed_input_transport_base.cpp b/services/transportbase/src/distributed_input_transport_base.cpp index c9d29217d727be65b4fee008896f04a95b9fbe3b..9c3e4310d2e5fae9a3e5399cb70c0414d7987b6c 100644 --- a/services/transportbase/src/distributed_input_transport_base.cpp +++ b/services/transportbase/src/distributed_input_transport_base.cpp @@ -449,7 +449,6 @@ bool DistributedInputTransportBase::CheckRecivedData(const std::string &message) void DistributedInputTransportBase::OnBytesReceived(int32_t sessionId, const void *data, uint32_t dataLen) { - DHLOGD("OnBytesReceived, sessionId: %d, dataLen:%d", sessionId, dataLen); if (sessionId < 0 || data == nullptr || dataLen <= 0) { DHLOGE("OnBytesReceived param check failed"); return; @@ -468,11 +467,9 @@ void DistributedInputTransportBase::OnBytesReceived(int32_t sessionId, const voi } std::string message(buf, buf + dataLen); - DHLOGD("OnBytesReceived message:%s.", SetAnonyId(message).c_str()); HandleSession(sessionId, message); free(buf); - DHLOGD("OnBytesReceived completed"); return; } @@ -491,13 +488,11 @@ void DistributedInputTransportBase::HandleSession(int32_t sessionId, const std:: return; } uint32_t cmdType = recMsg[DINPUT_SOFTBUS_KEY_CMD_TYPE]; - DHLOGD("HandleSession cmdType %u.", cmdType); if (cmdType < TRANS_MSG_SRC_SINK_SPLIT) { if (srcCallback_ == nullptr) { DHLOGE("srcCallback is nullptr."); return; } - DHLOGD("HandleSession to source."); srcCallback_->HandleSessionData(sessionId, message); return; } @@ -506,14 +501,12 @@ void DistributedInputTransportBase::HandleSession(int32_t sessionId, const std:: DHLOGE("sinkCallback is nullptr."); return; } - DHLOGD("HandleSession to sink."); sinkCallback_->HandleSessionData(sessionId, message); } } int32_t DistributedInputTransportBase::SendMsg(int32_t sessionId, std::string &message) { - DHLOGD("start SendMsg"); if (message.size() > MSG_MAX_SIZE) { DHLOGE("SendMessage error: message.size() > MSG_MAX_SIZE"); return ERR_DH_INPUT_SERVER_SOURCE_TRANSPORT_SENDMESSSAGE;