openharmony/distributedhardware_distributed_input
1
0
Fork 0
mirror of https://github.com/openharmony/distributedhardware_distributed_input.git synced 2026-07-19 17:43:35 -04:00
Code Issues Packages Projects Releases Wiki Activity

remove no use log

Browse Source 
Signed-off-by: hwzhangchuang <zhangchuang.zhang@huawei.com>
This commit is contained in:
hwzhangchuang
2023-12-11 20:56:15 +08:00
parent 64731b4e23
commit 423cdbaae5
4 changed files with 2 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/sink/inputcollector/src/distributed_input_collector.cpp
+1 -3
View File
@@ -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;
}
services/sink/transport/src/distributed_input_sink_transport.cpp
-1
View File
@@ -69,7 +69,6 @@ DistributedInputSinkTransport &DistributedInputSinkTransport::GetInstance()
void DistributedInputSinkTransport::DInputSinkEventHandler::ProcessEvent(const AppExecFwk::InnerEvent::Pointer &event)
{
DHLOGD("ProcessEvent");
EHandlerMsgType eventId = static_cast<EHandlerMsgType>(event->GetInnerEventId());
switch (eventId) {
case EHandlerMsgType::DINPUT_SINK_EVENT_HANDLER_MSG: {
services/transportbase/src/distributed_input_transport_base.cpp
+1 -7
View File
@@ -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,10 @@ void DistributedInputTransportBase::OnBytesReceived(int32_t sessionId, const voi
}
std::string message(buf, buf + dataLen);
DHLOGD("OnBytesReceived message:%s.", SetAnonyId(message).c_str());
DHLOGD("OnBytesReceived sessionId: %d, message:%s.", sessionId, SetAnonyId(message).c_str());
HandleSession(sessionId, message);
free(buf);
DHLOGD("OnBytesReceived completed");
return;
}
@@ -491,13 +489,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 +502,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;