Signed-off-by: stephb9959 <stephane.bourque@gmail.com>
This commit is contained in:
stephb9959
2022-07-07 10:23:01 -07:00
parent cf441de197
commit f9f4624add
2 changed files with 6 additions and 0 deletions

View File

@@ -37,6 +37,7 @@ namespace OpenWifi {
if(job!=nullptr) {
if(job->Started()==0 && Pool_.used()<Pool_.available()) {
std::cout << "Starting: " << job->Name() << " ID:" << job->JobId() << std::endl;
job->Logger().information(fmt::format("Starting {}: {}",job->JobId(),job->Name());
job->Start();
Pool_.start(*job);
}
@@ -47,6 +48,7 @@ namespace OpenWifi {
if(*it!=nullptr && (*it)->Completed()!=0) {
auto tmp = it;
it = jobs_.erase(it);
std::cout << "Completed: " << (*it)->Name() << " ID:" << (*it)->JobId() << std::endl;
delete *tmp;
} else {
++it;

View File

@@ -231,7 +231,11 @@ namespace OpenWifi{
auto JobId = MicroService::instance().CreateUUID();
Types::StringVec Parameters{UUID};;
auto NewJob = new VenueConfigUpdater(JobId,"VenueConfigurationUpdater", Parameters, 0, UserInfo_.userinfo, Logger());
std::cout << "Adding new job" << std::endl;
JobController()->AddJob(dynamic_cast<Job*>(NewJob));
std::cout << "Job added" << std::endl;
SNL.to_json(Answer);
Answer.set("jobId",JobId);
return ReturnObject(Answer);