cyonjan/WeChatFerry
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(rpc): close cmdSock on error

Browse Source
This commit is contained in:
Changhua 2025-02-18 01:54:05 +08:00
parent 6371f83b87
commit ba8865d348
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
WeChatFerry/spy/rpc_server.cpp
View File

@ -310,11 +310,15 @@ void RpcServer::run_rpc_server()
if ((rv = nng_listen(cmdSock, url.c_str(), nullptr, 0)) != 0) { if ((rv = nng_listen(cmdSock, url.c_str(), nullptr, 0)) != 0) {
LOG_ERROR("nng_listen error: {}", nng_strerror(rv)); LOG_ERROR("nng_listen error: {}", nng_strerror(rv));
nng_close(cmdSock);
nng_fini();
return; return;
} }
if ((rv = nng_setopt_ms(cmdSock, NNG_OPT_SENDTIMEO, 1000)) != 0) { if ((rv = nng_setopt_ms(cmdSock, NNG_OPT_SENDTIMEO, 1000)) != 0) {
LOG_ERROR("nng_setopt_ms error: {}", nng_strerror(rv)); LOG_ERROR("nng_setopt_ms error: {}", nng_strerror(rv));
nng_close(cmdSock);
nng_fini();
return; return;
} }