This commit is contained in:
stephb9959
2023-04-18 14:07:41 -07:00

View File

@@ -50,19 +50,23 @@ namespace OpenWifi {
void SimulationCoordinator::run() {
Running_ = true;
while (Running_) {
Poco::Thread::trySleep(30000);
Poco::Thread::trySleep(10000);
if (!Running_)
break;
uint64_t Now = Utils::Now();
std::lock_guard G(Mutex_);
std::cout << "Checking sims..." << std::endl;
for(auto it = Simulations_.begin(); it!=end(Simulations_); ) {
const auto &id = it->first;
const auto &simulation = it->second;
std::cout << "Checking sims..." << std::endl;
if (simulation->Details.simulationLength != 0 &&
(Now - SimStats()->GetStartTime(id)) > simulation->Details.simulationLength) {
std::string Error;
std::cout << "Sim is done: " << simulation->Details.name << std::endl;
simulation->Runner.Stop();
SimStats()->EndSim(id);
OWLSObjects::SimulationStatus S;
@@ -71,6 +75,7 @@ namespace OpenWifi {
SimStats()->RemoveSim(id);
it = Simulations_.erase(it);
} else {
std::cout << "Sim is good: " << simulation->Details.name << std::endl;
++it;
}
}