Skip to content

Commit

Permalink
Fixed global init/shutdown order
Browse files Browse the repository at this point in the history
  • Loading branch information
SChernykh committed Dec 3, 2024
1 parent ecdaa83 commit 7e39839
Show file tree
Hide file tree
Showing 13 changed files with 89 additions and 41 deletions.
4 changes: 2 additions & 2 deletions src/console_commands.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -209,7 +209,7 @@ static void do_status(p2pool *m_pool, const char * /* args */)

m_pool->print_merge_mining_status();

bkg_jobs_tracker.print_status();
bkg_jobs_tracker->print_status();

if (p2p) {
p2p->check_for_updates(true);
Expand Down Expand Up @@ -313,7 +313,7 @@ static void do_stop_mining(p2pool* m_pool, const char* /*args*/)

static void do_exit(p2pool *m_pool, const char * /* args */)
{
bkg_jobs_tracker.wait();
bkg_jobs_tracker->wait();
m_pool->stop();
}

Expand Down
17 changes: 12 additions & 5 deletions src/crypto.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -37,9 +37,7 @@ class RandomBytes
public:
RandomBytes() : rng(RandomDeviceSeed::instance), dist(0, 255)
{
if (uv_mutex_init(&m) != 0) {
abort();
}
uv_mutex_init_checked(&m);

// Diffuse the initial state in case it has low quality
rng.discard(10000);
Expand All @@ -66,7 +64,7 @@ class RandomBytes
std::uniform_int_distribution<> dist;
};

static RandomBytes randomBytes;
static RandomBytes* randomBytes = nullptr;

}

Expand All @@ -86,7 +84,7 @@ static FORCEINLINE bool less32(const uint8_t* k0, const uint8_t* k1)
void generate_keys(hash& pub, hash& sec)
{
do {
do { randomBytes(sec.h); } while (!less32(sec.h, limit));
do { (*randomBytes)(sec.h); } while (!less32(sec.h, limit));
sc_reduce32(sec.h);
} while (!sc_isnonzero(sec.h));

Expand Down Expand Up @@ -472,13 +470,22 @@ void derive_view_tag(const hash& derivation, size_t output_index, uint8_t& view_

void init_crypto_cache()
{
if (!randomBytes) {
randomBytes = new RandomBytes();
}

if (!cache) {
cache = new Cache();
}
}

void destroy_crypto_cache()
{
if (randomBytes) {
delete randomBytes;
randomBytes = nullptr;
}

if (cache) {
delete cache;
cache = nullptr;
Expand Down
29 changes: 16 additions & 13 deletions src/log.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,6 @@ class Worker
{
#if defined(_WIN32) && defined(_MSC_VER) && !defined(NDEBUG)
SetUnhandledExceptionFilter(UnhandledExceptionFilter);
SymInitialize(GetCurrentProcess(), NULL, TRUE);
#endif

set_main_thread();
Expand Down Expand Up @@ -163,10 +162,8 @@ class Worker
CONSOLE_COLORS = false;
}

LOGINFO(0, "started");

if (!m_logFile.is_open()) {
LOGERR(0, "failed to open " << log_file_name);
fprintf(stderr, "failed to open %s\n", log_file_name);
}

init_uv_threadpool();
Expand Down Expand Up @@ -203,10 +200,6 @@ class Worker
#endif

m_logFile.close();

#if defined(_WIN32) && defined(_MSC_VER) && !defined(NDEBUG)
SymCleanup(GetCurrentProcess());
#endif
}

FORCEINLINE void write(const char* buf, uint32_t size)
Expand Down Expand Up @@ -252,13 +245,13 @@ class Worker
int err = putenv(buf);
if (err != 0) {
err = errno;
LOGWARN(0, "Couldn't set UV thread pool size to " << N << " threads, putenv returned error " << err);
fprintf(stderr, "Couldn't set UV thread pool size to %u threads, putenv returned error %d\n", N, err);
}

static uv_work_t dummy;
err = uv_queue_work(uv_default_loop_checked(), &dummy, [](uv_work_t*) {}, nullptr);
if (err) {
LOGERR(0, "init_uv_threadpool: uv_queue_work failed, error " << uv_err_name(err));
fprintf(stderr, "init_uv_threadpool: uv_queue_work failed, error %s\n", uv_err_name(err));
}
}

Expand Down Expand Up @@ -398,7 +391,7 @@ class Worker
std::ofstream m_logFile;
};

static Worker worker;
static Worker* worker = nullptr;

#endif // P2POOL_LOG_DISABLE

Expand Down Expand Up @@ -445,7 +438,16 @@ NOINLINE Writer::~Writer()
m_buf[2] = static_cast<uint8_t>(size >> 8);
m_buf[m_pos] = '\n';
#ifndef P2POOL_LOG_DISABLE
worker.write(m_buf, size);
worker->write(m_buf, size);
#endif
}

void start()
{
#ifndef P2POOL_LOG_DISABLE
worker = new Worker();

LOGINFO(0, "started");
#endif
}

Expand All @@ -458,7 +460,8 @@ void reopen()
void stop()
{
#ifndef P2POOL_LOG_DISABLE
worker.stop();
delete worker;
worker = nullptr;
#endif
}

Expand Down
1 change: 1 addition & 0 deletions src/log.h
Original file line number Diff line number Diff line change
Expand Up @@ -547,6 +547,7 @@ struct DummyStream

#endif

void start();
void reopen();
void stop();

Expand Down
20 changes: 20 additions & 0 deletions src/main.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,14 @@
#include "randomx.h"
#endif

#if defined(_WIN32) && defined(_MSC_VER) && !defined(NDEBUG)

#include <DbgHelp.h>

#pragma comment(lib, "Dbghelp.lib")

#endif

void p2pool_usage()
{
printf("P2Pool %s\n"
Expand Down Expand Up @@ -188,8 +196,14 @@ int main(int argc, char* argv[])
}
}

#if defined(_WIN32) && defined(_MSC_VER) && !defined(NDEBUG)
SymInitialize(GetCurrentProcess(), NULL, TRUE);
#endif

memory_tracking_start();

p2pool::log::start();

p2pool::init_crypto_cache();

int result = static_cast<int>(curl_global_init_mem(CURL_GLOBAL_ALL, p2pool::malloc_hook, p2pool::free_hook, p2pool::realloc_hook, p2pool::strdup_hook, p2pool::calloc_hook));
Expand All @@ -209,9 +223,15 @@ int main(int argc, char* argv[])

p2pool::destroy_crypto_cache();

p2pool::log::stop();

if (!memory_tracking_stop()) {
result = 1;
}

#if defined(_WIN32) && defined(_MSC_VER) && !defined(NDEBUG)
SymCleanup(GetCurrentProcess());
#endif

return result;
}
10 changes: 4 additions & 6 deletions src/memory_leak_debug.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ struct TrackedAllocation

static_assert(sizeof(TrackedAllocation) == 256, "");

uv_mutex_t allocation_lock;
std::mutex allocation_lock;
std::hash<void*> hasher;
uint32_t first[N];
uint32_t next[N];
Expand All @@ -98,7 +98,7 @@ void show_top_10_allocations()
const HANDLE h = GetCurrentProcess();

{
p2pool::MutexLock lock(allocation_lock);
std::lock_guard<std::mutex> lock(allocation_lock);

TrackedAllocation* end = buf;
for (size_t i = 0; i < N; ++i) {
Expand Down Expand Up @@ -173,7 +173,7 @@ FORCEINLINE static void add_alocation(void* p, size_t size)

const size_t index = hasher(p) & (N - 1);

p2pool::MutexLock lock(allocation_lock);
std::lock_guard<std::mutex> lock(allocation_lock);

++num_allocations;
if (num_allocations >= N / 2) {
Expand Down Expand Up @@ -204,7 +204,7 @@ FORCEINLINE static void remove_allocation(void* p)
return;
}

p2pool::MutexLock lock(allocation_lock);
std::lock_guard<std::mutex> lock(allocation_lock);

--num_allocations;

Expand Down Expand Up @@ -295,7 +295,6 @@ void memory_tracking_start()
using namespace p2pool;

uv_replace_allocator(malloc_hook, realloc_hook, calloc_hook, free_hook);
uv_mutex_init_checked(&allocation_lock);
track_memory = true;
}

Expand All @@ -304,7 +303,6 @@ bool memory_tracking_stop()
using namespace p2pool;

track_memory = false;
uv_mutex_destroy(&allocation_lock);

const HANDLE h = GetCurrentProcess();

Expand Down
9 changes: 8 additions & 1 deletion src/p2pool.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -161,6 +161,8 @@ p2pool::p2pool(int argc, char* argv[])
throw std::exception();
}

bkg_jobs_tracker = new BackgroundJobTracker();

m_sideChain = new SideChain(this, type, p->m_mini ? "mini" : nullptr);

if (p->m_p2pAddresses.empty()) {
Expand All @@ -184,6 +186,8 @@ p2pool::p2pool(int argc, char* argv[])
m_hasher = new RandomX_Hasher_RPC(this);
#endif

PoolBlock::s_precalculatedSharesLock = new ReadWriteLock();

m_blockTemplate = new BlockTemplate(m_sideChain, m_hasher);
m_mempool = new Mempool();

Expand Down Expand Up @@ -232,6 +236,9 @@ p2pool::~p2pool()
delete m_blockTemplate;
delete m_mempool;
delete m_params;

delete bkg_jobs_tracker;
delete PoolBlock::s_precalculatedSharesLock;
}

void p2pool::update_host_ping(const std::string& display_name, double ping)
Expand Down Expand Up @@ -1955,7 +1962,7 @@ int p2pool::run()

m_stopped = true;

bkg_jobs_tracker.wait();
bkg_jobs_tracker->wait();

#ifdef WITH_RANDOMX
delete m_miner;
Expand Down
6 changes: 3 additions & 3 deletions src/pool_block.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ LOG_CATEGORY(PoolBlock)

namespace p2pool {

ReadWriteLock PoolBlock::s_precalculatedSharesLock;
ReadWriteLock* PoolBlock::s_precalculatedSharesLock = nullptr;

PoolBlock::PoolBlock()
: m_majorVersion(0)
Expand Down Expand Up @@ -118,7 +118,7 @@ PoolBlock& PoolBlock::operator=(const PoolBlock& b)
m_wantBroadcast = b.m_wantBroadcast;
m_precalculated = b.m_precalculated;
{
WriteLock lock(s_precalculatedSharesLock);
WriteLock lock(*s_precalculatedSharesLock);
m_precalculatedShares = b.m_precalculatedShares;
}

Expand Down Expand Up @@ -309,7 +309,7 @@ void PoolBlock::reset_offchain_data()

m_precalculated = false;
{
WriteLock lock(s_precalculatedSharesLock);
WriteLock lock(*s_precalculatedSharesLock);
m_precalculatedShares.clear();
m_precalculatedShares.shrink_to_fit();
}
Expand Down
2 changes: 1 addition & 1 deletion src/pool_block.h
Original file line number Diff line number Diff line change
Expand Up @@ -162,7 +162,7 @@ struct PoolBlock

bool m_precalculated;

static ReadWriteLock s_precalculatedSharesLock;
static ReadWriteLock* s_precalculatedSharesLock;
std::vector<MinerShare> m_precalculatedShares;

uint64_t m_localTimestamp;
Expand Down
6 changes: 3 additions & 3 deletions src/side_chain.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1683,7 +1683,7 @@ void SideChain::verify(PoolBlock* block)
std::vector<MinerShare> shares;

if (block->m_precalculated) {
WriteLock lock(PoolBlock::s_precalculatedSharesLock);
WriteLock lock(*PoolBlock::s_precalculatedSharesLock);
shares = std::move(block->m_precalculatedShares);
}

Expand Down Expand Up @@ -2356,7 +2356,7 @@ void SideChain::launch_precalc(const PoolBlock* block)
if (get_shares(b, shares, nullptr, true)) {
b->m_precalculated = true;
{
WriteLock lock(PoolBlock::s_precalculatedSharesLock);
WriteLock lock(*PoolBlock::s_precalculatedSharesLock);
b->m_precalculatedShares = std::move(shares);
}
{
Expand Down Expand Up @@ -2401,7 +2401,7 @@ void SideChain::precalc_worker()

wallets.clear();

ReadLock lock2(PoolBlock::s_precalculatedSharesLock);
ReadLock lock2(*PoolBlock::s_precalculatedSharesLock);

const size_t n = job->m_precalculatedShares.size();

Expand Down
2 changes: 1 addition & 1 deletion src/util.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -452,7 +452,7 @@ void BackgroundJobTracker::print_status()
m_impl->print_status();
}

BackgroundJobTracker bkg_jobs_tracker;
BackgroundJobTracker* bkg_jobs_tracker = nullptr;

static thread_local bool main_thread = false;
void set_main_thread() { main_thread = true; }
Expand Down
6 changes: 3 additions & 3 deletions src/util.h
Original file line number Diff line number Diff line change
Expand Up @@ -233,10 +233,10 @@ class BackgroundJobTracker : public nocopy_nomove
Impl* m_impl;
};

extern BackgroundJobTracker bkg_jobs_tracker;
extern BackgroundJobTracker* bkg_jobs_tracker;

#define BACKGROUND_JOB_START(x) do { bkg_jobs_tracker.start(#x); } while (0)
#define BACKGROUND_JOB_STOP(x) do { bkg_jobs_tracker.stop(#x); } while (0)
#define BACKGROUND_JOB_START(x) do { bkg_jobs_tracker->start(#x); } while (0)
#define BACKGROUND_JOB_STOP(x) do { bkg_jobs_tracker->stop(#x); } while (0)

void set_main_thread();
bool is_main_thread();
Expand Down
Loading

0 comments on commit 7e39839

Please sign in to comment.