From 0e222afd6a6f2397b7a32f3e1c432b5664c34a0c Mon Sep 17 00:00:00 2001 From: SChernykh Date: Mon, 23 May 2022 15:46:15 +0200 Subject: [PATCH] Exit if server startup fails --- src/p2p_server.cpp | 2 +- src/stratum_server.cpp | 2 +- src/tcp_server.inl | 12 ++++++++++-- 3 files changed, 12 insertions(+), 4 deletions(-) diff --git a/src/p2p_server.cpp b/src/p2p_server.cpp index 6599064..abd12a8 100644 --- a/src/p2p_server.cpp +++ b/src/p2p_server.cpp @@ -77,7 +77,7 @@ P2PServer::P2PServer(p2pool* pool) int err = uv_async_init(&m_loop, &m_broadcastAsync, on_broadcast); if (err) { LOGERR(1, "uv_async_init failed, error " << uv_err_name(err)); - return; + panic(); } m_broadcastAsync.data = this; m_broadcastQueue.reserve(2); diff --git a/src/stratum_server.cpp b/src/stratum_server.cpp index bdedcdc..3835c58 100644 --- a/src/stratum_server.cpp +++ b/src/stratum_server.cpp @@ -70,7 +70,7 @@ StratumServer::StratumServer(p2pool* pool) const int err = uv_async_init(&m_loop, &m_blobsAsync, on_blobs_ready); if (err) { LOGERR(1, "uv_async_init failed, error " << uv_err_name(err)); - return; + panic(); } m_blobsAsync.data = this; m_blobsQueue.reserve(2); diff --git a/src/tcp_server.inl b/src/tcp_server.inl index 6abf54b..84d3325 100644 --- a/src/tcp_server.inl +++ b/src/tcp_server.inl @@ -37,10 +37,18 @@ TCPServer::TCPServer(allocate_client_callback all panic(); } - uv_async_init(&m_loop, &m_dropConnectionsAsync, on_drop_connections); + err = uv_async_init(&m_loop, &m_dropConnectionsAsync, on_drop_connections); + if (err) { + LOGERR(1, "uv_async_init failed, error " << uv_err_name(err)); + panic(); + } m_dropConnectionsAsync.data = this; - uv_async_init(&m_loop, &m_shutdownAsync, on_shutdown); + err = uv_async_init(&m_loop, &m_shutdownAsync, on_shutdown); + if (err) { + LOGERR(1, "uv_async_init failed, error " << uv_err_name(err)); + panic(); + } m_shutdownAsync.data = this; uv_mutex_init_checked(&m_clientsListLock);