Display number threads that are really used

Project-OSRM · May 1, 2014 · b4a762f · b4a762f
1 parent 9183063
commit b4a762f
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/extractor.cpp b/extractor.cpp
@@ -150,14 +150,16 @@ int main (int argc, char *argv[]) {
             return 1;
         }
 
+        int real_num_threads = std::min(omp_get_num_procs(), requested_num_threads);
+
         SimpleLogger().Write() << "Input file: " << input_path.filename().string();
         SimpleLogger().Write() << "Profile: " << profile_path.filename().string();
-        SimpleLogger().Write() << "Threads: " << requested_num_threads;
+        SimpleLogger().Write() << "Threads: " << real_num_threads << " (requested " << requested_num_threads << ")";
 
         /*** Setup Scripting Environment ***/
         ScriptingEnvironment scriptingEnvironment(profile_path.c_str());
 
-        omp_set_num_threads(std::min(omp_get_num_procs(), requested_num_threads));
+        omp_set_num_threads(real_num_threads);
 
         bool file_has_pbf_format(false);
         std::string output_file_name = input_path.string();

diff --git a/prepare.cpp b/prepare.cpp
@@ -149,12 +149,14 @@ int main (int argc, char *argv[]) {
             return 1;
         }
 
+        int real_num_threads = std::min(omp_get_num_procs(), requested_num_threads);
+
         SimpleLogger().Write() << "Input file: " << input_path.filename().string();
         SimpleLogger().Write() << "Restrictions file: " << restrictions_path.filename().string();
         SimpleLogger().Write() << "Profile: " << profile_path.filename().string();
-        SimpleLogger().Write() << "Threads: " << requested_num_threads;
+        SimpleLogger().Write() << "Threads: " << real_num_threads << " (requested " << requested_num_threads << ")";
 
-        omp_set_num_threads( std::min( omp_get_num_procs(), requested_num_threads) );
+        omp_set_num_threads(real_num_threads);
         LogPolicy::GetInstance().Unmute();
         boost::filesystem::ifstream restrictionsInstream(restrictions_path, std::ios::binary);
         TurnRestriction restriction;