Changeset 1399:01de1d7cc31d

Timestamp:

11/07/09 21:48:36 (2 years ago)

Author:

niam

Branch:

default

Message:

pc::execution::manager: get pointer to job itself

Location:

src/include/libdodo

Files:

• pcExecutionJob.h (modified) (1 diff)
• pcExecutionManager.h (modified) (7 diffs)
• pcExecutionManager.inline (modified) (1 diff)
• pcExecutionManagerEx.h (modified) (1 diff)

src/include/libdodo/pcExecutionJob.h

@@ -97 +97 @@
                 virtual bool isRunning() const = 0;
 
+              protected:
+
                 mutable bool cloned; ///< true if object was cloned
             };

src/include/libdodo/pcExecutionManager.h

@@ -55 +55 @@
                  * destructor
                  */
-                virtual ~manager();
+                ~manager();
 
                 /**
@@ -62 +62 @@
                  * @param job defines job for managing
                  */
-                virtual unsigned long add(const T &job);
+                unsigned long add(const T &job);
 
                 /**
@@ -69 +69 @@
                  * @param terminate defines termination condition
                  */
-                virtual void remove(unsigned long id,
+                void remove(unsigned long id,
                                     bool          terminate = false);
 
@@ -77 +77 @@
                  * @param force defines run condition; if true and job is running run job anyway
                  */
-                virtual void run(unsigned long id);
+                void run(unsigned long id);
 
                 /**
@@ -83 +83 @@
                  * @param id defines job identificator
                  */
-                virtual void stop(unsigned long id);
+                void stop(unsigned long id);
 
                 /**
                  * stop all registered jobs
                  */
-                virtual void stop();
+                void stop();
 
                 /**
@@ -95 +95 @@
                  * @param id defines job identificator
                  */
-                virtual int wait(unsigned long id);
+                int wait(unsigned long id);
 
                 /**
                  * wait for all registered jobs termination
                  */
-                virtual void wait();
+                void wait();
 
                 /**
@@ -106 +106 @@
                  * @param id defines job identificator
                  */
-                virtual bool isRunning(unsigned long id) const;
+                bool isRunning(unsigned long id) const;
 
                 /**
                  * @return amount of running jobs
                  */
-                virtual unsigned long running() const;
+                unsigned long running() const;
 
                 /**
                  * @return list of jobs in object
                  */
-                virtual dodoList<unsigned long> jobs();
+                dodoList<unsigned long> jobs();
+
+                /**
+                 * @return job object
+                 * @param id defines job identificator
+                 */
+                T *job(unsigned long id);
 
               protected:

src/include/libdodo/pcExecutionManager.inline

@@ -223 +223 @@
 
 //-------------------------------------------------------------------
+
+template <typename T>
+T *
+dodo::pc::execution::manager<T
+                             >::job(unsigned long id)
+{
+    pc::sync::stack tg(keeper);
+
+    typename dodoMap<unsigned long, T>::const_iterator job = handles.find(id);
+
+    if (job == handles.end())
+        throw exception::basic(exception::MODULE_PCEXECUTIONMANAGER, MANAGEREX_JOB, exception::ERRNO_LIBDODO, MANAGEREX_NOTFOUND, PCEXECUTIONMANAGEREX_NOTFOUND_STR, __LINE__, __FILE__);
+
+    return (T *)&job->second;
+}
+
+//-------------------------------------------------------------------

src/include/libdodo/pcExecutionManagerEx.h

@@ -57 +57 @@
                 MANAGEREX_STOP,
                 MANAGEREX_ISRUNNING,
+                MANAGEREX_JOB,
             };
         };