Loading src/core/module/ModuleManager.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -729,7 +729,6 @@ void ModuleManager::run(RandomNumberGenerator& seeder) { if(terminate_) { LOG(INFO) << "Interrupting event loop after " << finished_events << " events because of request to terminate"; thread_pool_->destroy(); global_config.set<uint64_t>("number_of_events", finished_events); break; } Loading Loading @@ -810,7 +809,7 @@ void ModuleManager::run(RandomNumberGenerator& seeder) { } if(stop) { LOG(TRACE) << "Event " << event->number LOG(DEBUG) << "Event " << event->number << " was interrupted because of missing dependencies, rescheduling..."; // Store state of PRNG engine: event->store_random_engine_state(); Loading @@ -830,6 +829,7 @@ void ModuleManager::run(RandomNumberGenerator& seeder) { // All modules finished, mark as complete thread_pool_->markComplete(event->number); LOG(INFO) << "Finished event " << event_num << " with seed " << event_seed; auto buffered_events = thread_pool_->bufferedQueueSize(); if(plot) { Loading Loading
src/core/module/ModuleManager.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -729,7 +729,6 @@ void ModuleManager::run(RandomNumberGenerator& seeder) { if(terminate_) { LOG(INFO) << "Interrupting event loop after " << finished_events << " events because of request to terminate"; thread_pool_->destroy(); global_config.set<uint64_t>("number_of_events", finished_events); break; } Loading Loading @@ -810,7 +809,7 @@ void ModuleManager::run(RandomNumberGenerator& seeder) { } if(stop) { LOG(TRACE) << "Event " << event->number LOG(DEBUG) << "Event " << event->number << " was interrupted because of missing dependencies, rescheduling..."; // Store state of PRNG engine: event->store_random_engine_state(); Loading @@ -830,6 +829,7 @@ void ModuleManager::run(RandomNumberGenerator& seeder) { // All modules finished, mark as complete thread_pool_->markComplete(event->number); LOG(INFO) << "Finished event " << event_num << " with seed " << event_seed; auto buffered_events = thread_pool_->bufferedQueueSize(); if(plot) { Loading