File size: 1,249 Bytes
034d0a2 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 | // Copyright 2019 Citra Emulator Project
// Licensed under GPLv2 or any later version
// Refer to the license.txt file included.
#include "core/core.h"
#include "core/rpc/packet.h"
#include "core/rpc/rpc_server.h"
#include "core/rpc/server.h"
#include "core/rpc/udp_server.h"
namespace Core::RPC {
Server::Server(Core::System& system_) : rpc_server{system_} {
const auto callback = [this](std::unique_ptr<Packet> new_request) {
NewRequestCallback(std::move(new_request));
};
try {
udp_server = std::make_unique<UDPServer>(callback);
} catch (...) {
LOG_ERROR(RPC_Server, "Error starting UDP server");
}
}
Server::~Server() {
udp_server.reset();
NewRequestCallback(nullptr); // Notify the RPC server to end
}
void Server::NewRequestCallback(std::unique_ptr<RPC::Packet> new_request) {
if (new_request) {
LOG_INFO(RPC_Server, "Received request version={} id={} type={} size={}",
new_request->GetVersion(), new_request->GetId(), new_request->GetPacketType(),
new_request->GetPacketDataSize());
} else {
LOG_INFO(RPC_Server, "Received end packet");
}
rpc_server.QueueRequest(std::move(new_request));
}
}; // namespace Core::RPC
|