From f149613d5403ae956d85de94d6391c42c7db9a10 Mon Sep 17 00:00:00 2001 From: SChernykh Date: Mon, 4 Sep 2023 20:32:19 +0200 Subject: [PATCH] Removed unnecessary async call --- src/pow_hash.cpp | 7 ++----- src/pow_hash.h | 2 -- 2 files changed, 2 insertions(+), 7 deletions(-) diff --git a/src/pow_hash.cpp b/src/pow_hash.cpp index c3ec08e..16343dc 100644 --- a/src/pow_hash.cpp +++ b/src/pow_hash.cpp @@ -396,7 +396,6 @@ RandomX_Hasher_RPC::RandomX_Hasher_RPC(p2pool* pool) GetLoopUserData(&m_loop); uv_async_init_checked(&m_loop, &m_shutdownAsync, on_shutdown); - uv_async_init_checked(&m_loop, &m_kickTheLoopAsync, nullptr); m_shutdownAsync.data = this; uv_mutex_init_checked(&m_requestMutex); @@ -456,8 +455,8 @@ bool RandomX_Hasher_RPC::calculate(const void* data_ptr, size_t size, uint64_t h ",\"block_blob\":\"" << log::hex_buf(data, size) << '"' << ",\"seed_hash\":\"\"}}\0"; - volatile int result = 0; - volatile bool done = false; + std::atomic result{ 0 }; + std::atomic done{ false }; const Params& params = m_pool->params(); const Params::Host& host = m_pool->current_host(); @@ -485,8 +484,6 @@ bool RandomX_Hasher_RPC::calculate(const void* data_ptr, size_t size, uint64_t h uv_cond_signal(&m_cond); }, &m_loop); - uv_async_send(&m_kickTheLoopAsync); - { MutexLock lock2(m_condMutex); while (!done) { diff --git a/src/pow_hash.h b/src/pow_hash.h index 104adad..4482401 100644 --- a/src/pow_hash.h +++ b/src/pow_hash.h @@ -115,13 +115,11 @@ private: uv_cond_t m_cond; uv_async_t m_shutdownAsync; - uv_async_t m_kickTheLoopAsync; static void on_shutdown(uv_async_t* async) { RandomX_Hasher_RPC* server = reinterpret_cast(async->data); uv_close(reinterpret_cast(&server->m_shutdownAsync), nullptr); - uv_close(reinterpret_cast(&server->m_kickTheLoopAsync), nullptr); delete GetLoopUserData(&server->m_loop, false); }