diff Core/JobsEngine/JobsRegistry.h @ 2570:2e879c796ec7 jobs

JobsRegistry::SubmitAndWait(), StoreScuJob
author Sebastien Jodogne <s.jodogne@gmail.com>
date Mon, 07 May 2018 21:42:04 +0200
parents 2af17cd5eb1f
children 3372c5255333
line wrap: on
line diff
--- a/Core/JobsEngine/JobsRegistry.h	Mon May 07 15:37:20 2018 +0200
+++ b/Core/JobsEngine/JobsRegistry.h	Mon May 07 21:42:04 2018 +0200
@@ -77,6 +77,7 @@
     RetryJobs                  retryJobs_;
 
     boost::condition_variable  pendingJobAvailable_;
+    boost::condition_variable  someJobComplete_;
     size_t                     maxCompletedJobs_;
 
 
@@ -99,6 +100,9 @@
                             unsigned int timeout);
     
     void MarkRunningAsPaused(JobHandler& job);
+    
+    bool GetStateInternal(JobState& state,
+                          const std::string& id);
 
   public:
     JobsRegistry() :
@@ -122,6 +126,9 @@
     
     void Submit(IJob* job,        // Takes ownership
                 int priority);
+
+    bool SubmitAndWait(IJob* job,        // Takes ownership
+                       int priority);
     
     void SetPriority(const std::string& id,
                      int priority);