More fixes
This commit is contained in:
parent
ad8b9c0429
commit
e267377111
1 changed files with 7 additions and 3 deletions
|
@ -25,9 +25,13 @@ void Server::Stop() {
|
||||||
}
|
}
|
||||||
|
|
||||||
void Server::NewRequestCallback(std::unique_ptr<RPC::Packet> new_request) {
|
void Server::NewRequestCallback(std::unique_ptr<RPC::Packet> new_request) {
|
||||||
|
if (new_request) {
|
||||||
LOG_INFO(RPC_Server, "Received request version={} id={} type={} size={}",
|
LOG_INFO(RPC_Server, "Received request version={} id={} type={} size={}",
|
||||||
new_request->GetVersion(), new_request->GetId(),
|
new_request->GetVersion(), new_request->GetId(),
|
||||||
static_cast<u32>(new_request->GetPacketType()), new_request->GetPacketDataSize());
|
static_cast<u32>(new_request->GetPacketType()), new_request->GetPacketDataSize());
|
||||||
|
} else {
|
||||||
|
LOG_INFO(RPC_Server, "Received end packet");
|
||||||
|
}
|
||||||
rpc_server.QueueRequest(std::move(new_request));
|
rpc_server.QueueRequest(std::move(new_request));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue