diff --git a/nano/lib/threading.cpp b/nano/lib/threading.cpp index ba55d3fa..f5a6416b 100644 --- a/nano/lib/threading.cpp +++ b/nano/lib/threading.cpp @@ -85,6 +85,9 @@ std::string nano::thread_role::get_string (nano::thread_role::name role) case nano::thread_role::name::epoch_upgrader: thread_role_name_string = "Epoch upgrader"; break; + case nano::thread_role::name::db_parallel_traversal: + thread_role_name_string = "DB par traversl"; + break; } /* diff --git a/nano/lib/threading.hpp b/nano/lib/threading.hpp index f6ab4e18..6a132b1e 100644 --- a/nano/lib/threading.hpp +++ b/nano/lib/threading.hpp @@ -35,7 +35,8 @@ namespace thread_role worker, request_aggregator, state_block_signature_verification, - epoch_upgrader + epoch_upgrader, + db_parallel_traversal }; /* * Get/Set the identifier for the current thread diff --git a/nano/secure/blockstore_partial.hpp b/nano/secure/blockstore_partial.hpp index e0b62e23..0dbf7085 100644 --- a/nano/secure/blockstore_partial.hpp +++ b/nano/secure/blockstore_partial.hpp @@ -935,6 +935,7 @@ void parallel_traversal (std::function c bool const is_last = thread == thread_count - 1; threads.emplace_back ([&action, start, end, is_last] { + nano::thread_role::set (nano::thread_role::name::db_parallel_traversal); action (start, end, is_last); }); }