diff --git a/src/console_commands.cpp b/src/console_commands.cpp index 47ae8a2..f6992f4 100644 --- a/src/console_commands.cpp +++ b/src/console_commands.cpp @@ -289,9 +289,19 @@ void ConsoleCommands::stdinReadCallback(uv_stream_t* stream, ssize_t nread, cons void ConsoleCommands::loop(void* data) { LOGINFO(1, "event loop started"); + ConsoleCommands* pThis = static_cast(data); - uv_run(&pThis->m_loop, UV_RUN_DEFAULT); - uv_loop_close(&pThis->m_loop); + + int err = uv_run(&pThis->m_loop, UV_RUN_DEFAULT); + if (err) { + LOGWARN(1, "uv_run returned " << err); + } + + err = uv_loop_close(&pThis->m_loop); + if (err) { + LOGWARN(1, "uv_loop_close returned error " << uv_err_name(err)); + } + LOGINFO(1, "event loop stopped"); } diff --git a/src/pow_hash.cpp b/src/pow_hash.cpp index ab5ff12..4b863be 100644 --- a/src/pow_hash.cpp +++ b/src/pow_hash.cpp @@ -413,9 +413,19 @@ RandomX_Hasher_RPC::~RandomX_Hasher_RPC() void RandomX_Hasher_RPC::loop(void* data) { LOGINFO(1, "event loop started"); + RandomX_Hasher_RPC* hasher = static_cast(data); - uv_run(&hasher->m_loop, UV_RUN_DEFAULT); - uv_loop_close(&hasher->m_loop); + + int err = uv_run(&hasher->m_loop, UV_RUN_DEFAULT); + if (err) { + LOGWARN(1, "uv_run returned " << err); + } + + err = uv_loop_close(&hasher->m_loop); + if (err) { + LOGWARN(1, "uv_loop_close returned error " << uv_err_name(err)); + } + LOGINFO(1, "event loop stopped"); } diff --git a/src/tcp_server.inl b/src/tcp_server.inl index 4c21651..6adb1a9 100644 --- a/src/tcp_server.inl +++ b/src/tcp_server.inl @@ -576,8 +576,15 @@ void TCPServer::loop(void* data) server->m_preallocatedClients.emplace_back(server->m_allocateNewClient()); } - uv_run(&server->m_loop, UV_RUN_DEFAULT); - uv_loop_close(&server->m_loop); + int err = uv_run(&server->m_loop, UV_RUN_DEFAULT); + if (err) { + LOGWARN(1, "uv_run returned " << err); + } + + err = uv_loop_close(&server->m_loop); + if (err) { + LOGWARN(1, "uv_loop_close returned error " << uv_err_name(err)); + } for (WriteBuf* buf : server->m_writeBuffers) { delete buf;