From 23bd896243cefc55963b6c5572a807dfbfe70920 Mon Sep 17 00:00:00 2001 From: Max Wittal Date: Wed, 3 Apr 2024 21:39:04 +0700 Subject: [PATCH] verify refactor / tune --- src/pos/verify.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/pos/verify.cpp b/src/pos/verify.cpp index 07fea9e24..7c430cb46 100644 --- a/src/pos/verify.cpp +++ b/src/pos/verify.cpp @@ -86,7 +86,7 @@ compute(const std::vector& X_values, std::vector* X_out, con } const auto X_set = std::set(X_values.begin(), X_values.end()); - const bool use_threads = (xbits > 6); + const bool use_threads = (xbits >= 6); if(use_threads) { std::lock_guard lock(g_mutex); @@ -94,11 +94,11 @@ compute(const std::vector& X_values, std::vector* X_out, con const auto cpu_threads = std::thread::hardware_concurrency(); const auto num_threads = cpu_threads > 0 ? cpu_threads : 16; g_threads = std::make_shared(num_threads, 1024); - vnx::log_info() << "Using " << num_threads << " CPU threads (for proof compute)"; + vnx::log_info() << "Using " << num_threads << " CPU threads for proof compute"; } } const uint32_t kmask = ((uint64_t(1) << ksize) - 1); - const uint32_t num_entries_1 = X_set.size() << xbits; + const uint64_t num_entries_1 = X_set.size() << xbits; std::mutex mutex; std::vector jobs; @@ -116,7 +116,7 @@ compute(const std::vector& X_values, std::vector* X_out, con M_tmp.reserve(num_entries_1); entries.reserve(num_entries_1); - for(const auto X : std::set(X_set.begin(), X_set.end())) + for(const auto X : X_set) { if(use_threads) { const auto job = g_threads->add_task(