Set thread names in db parallel traversal (#2987)
This commit is contained in:
		
					parent
					
						
							
								228522aca9
							
						
					
				
			
			
				commit
				
					
						93c825279b
					
				
			
		
					 3 changed files with 6 additions and 1 deletions
				
			
		| 
						 | 
				
			
			@ -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;
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	/*
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -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
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
| 
						 | 
				
			
			@ -935,6 +935,7 @@ void parallel_traversal (std::function<void(T const &, T const &, bool const)> 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);
 | 
			
		||||
		});
 | 
			
		||||
	}
 | 
			
		||||
| 
						 | 
				
			
			
 | 
			
		|||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue