fixed thread bug and added worker poolstats via store

Author: brichards64

src/DataModelBase/Utilities.cpp

@@ -42,12 +42,13 @@ void *Utilities::Thread(void *arg){
       }  
       catch (std::exception& p) {
 	std::clog<<"Thread function Failed:"<<p.what() <<std::endl;
-        running = false;
+        args->running = false;
       }
       catch(...){
 	std::clog<<"Thread function Failed"<<std::endl;
-        running = false;
+        args->running = false;
       }
+    }
     else usleep(100);
 
   }

src/DataModelBase/WorkerPoolManager.cpp

@@ -265,6 +265,29 @@ std::string WorkerPoolManager::GetStats(){
 
 }
 
+void WorkerPoolManager::GetStats(Store& output){
+
+ 
+  m_job_queue->m_lock.lock();
+  m_manager_args.stats_mtx.lock(); 
+  
+  for(std::map<std::string, QueueStats>::iterator it = m_job_queue->m_stats.begin(); it!=m_job_queue->m_stats.end(); it++){
+    
+    
+    output.Set( it->first + "_submitted", it->second.submitted);
+    output.Set( it->first + "_queued", it->second.queued);
+    output.Set( it->first + "_processing", m_manager_args.stats[it->first].processing);
+    output.Set( it->first + "_completed", m_manager_args.stats[it->first].completed);
+    output.Set( it->first + "_failed", m_manager_args.stats[it->first].failed);
+    
+  }
+  
+  m_manager_args.stats_mtx.unlock();
+  m_job_queue->m_lock.unlock();
+
+  return;
+}
+
 void WorkerPoolManager::PrintStats(){
 
   printf("%s\n", GetStats().c_str());

src/DataModelBase/WorkerPoolManager.h

@@ -127,6 +127,7 @@ namespace ToolFramework{
     void ManageWorkers(); ///< Function to manage workers and distribute jobs to be run when unthreaded if you choose to not have the managment run on a thread.
     unsigned int NumThreads(); ///< Function to return the number of current worker threads
     std::string GetStats(); ///< Function to get the current stats
+    void GetStats(Store& output); ///< Function to get the current stats
     void PrintStats(); ///< Function to print the current stats to screen
     void ClearStats(); ///< Function to clear the current stats