From d80a06bc8e3f3429b957534f41ef07cda58d7e57 Mon Sep 17 00:00:00 2001
From: SChernykh <sergey.v.chernykh@gmail.com>
Date: Thu, 8 Sep 2022 09:18:30 +0200
Subject: [PATCH] Added more error logging

---
 src/console_commands.cpp | 14 ++++++++++++--
 src/pow_hash.cpp         | 14 ++++++++++++--
 src/tcp_server.inl       | 11 +++++++++--
 3 files changed, 33 insertions(+), 6 deletions(-)

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<ConsoleCommands*>(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<RandomX_Hasher_RPC*>(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<READ_BUF_SIZE, WRITE_BUF_SIZE>::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;