mirror of
https://github.com/Lime3DS/Lime3DS
synced 2024-12-30 11:02:39 -06:00
Merge pull request #4669 from wwylele/rpc-server-freeze
rpc: send ending packet in Server instead of UDPServer
This commit is contained in:
commit
5954dc11ba
2 changed files with 2 additions and 4 deletions
|
@ -25,6 +25,7 @@ void Server::Start() {
|
||||||
|
|
||||||
void Server::Stop() {
|
void Server::Stop() {
|
||||||
udp_server.reset();
|
udp_server.reset();
|
||||||
|
NewRequestCallback(nullptr); // Notify the RPC server to end
|
||||||
}
|
}
|
||||||
|
|
||||||
void Server::NewRequestCallback(std::unique_ptr<RPC::Packet> new_request) {
|
void Server::NewRequestCallback(std::unique_ptr<RPC::Packet> new_request) {
|
||||||
|
|
|
@ -20,10 +20,7 @@ public:
|
||||||
new_request_callback(std::move(new_request_callback)) {
|
new_request_callback(std::move(new_request_callback)) {
|
||||||
|
|
||||||
StartReceive();
|
StartReceive();
|
||||||
worker_thread = std::thread([this] {
|
worker_thread = std::thread([this] { io_context.run(); });
|
||||||
io_context.run();
|
|
||||||
this->new_request_callback(nullptr);
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
~Impl() {
|
~Impl() {
|
||||||
|
|
Loading…
Reference in a new issue