Changeset 8618 for trunk/MagicSoft/Mars/mbase/MTaskList.cc

Timestamp:

06/28/07 21:30:25 (17 years ago)

Author:

tbretz

Message:

*** empty log message ***

File:

• trunk/MagicSoft/Mars/mbase/MTaskList.cc (modified) (5 diffs)

trunk/MagicSoft/Mars/mbase/MTaskList.cc

@@ -89 +89 @@
 // this name in the parameter list (by MEvtLoop::SetParList)
 //
-MTaskList::MTaskList(const char *name, const char *title)
+MTaskList::MTaskList(const char *name, const char *title) : fNumPasses(0), fNumPass(0)
 {
     fName  = name  ? name  : gsDefName.Data();
@@ -108 +108 @@
 //   TaskList in the new TaskList.
 //
-MTaskList::MTaskList(MTaskList &ts) : MTask()
+MTaskList::MTaskList(const MTaskList &ts) : MTask(), fNumPasses(ts.fNumPasses)
 {
     fTasks->AddAll(ts.fTasks);
@@ -612 +612 @@
 }
 
-// --------------------------------------------------------------------------
-//
-// do the event execution of all tasks in the task-list
-//
-Int_t MTaskList::Process()
-{
-    //
-    // Check whether there is something which can be processed, otherwise
-    // stop the eventloop.
-    //
-    if (fTasksProcess.GetSize()==0)
-    {
-        *fLog << warn << "Warning: No entries in " << GetDescriptor() << " for Processing." << endl;
-        return kFALSE;
-    }
-
-    //
-    // Reset the ReadyToSave flag.
-    // Reset all containers.
-    //
-    // Make sure, that the parameter list is not reset from a tasklist
-    // running as a task in another tasklist.
-    //
-    const Bool_t noreset = fParList->TestBit(MParList::kIsProcessing);
-    if (!noreset)
-    {
-        fParList->SetBit(MParList::kIsProcessing);
-        if (!HasAccelerator(kAccDontReset))
-            fParList->Reset();
-    }
-
+Int_t MTaskList::ProcessTaskList()
+{
     //
     //  create the Iterator for the TaskList
@@ -707 +678 @@
     }
 
+    return rc;
+}
+
+// --------------------------------------------------------------------------
+//
+// do the event execution of all tasks in the task-list.
+//
+// If a task returns kCONTINUE, kCONTINUE is propagated if the
+// number of passes==0, otherwise kTRUE is returned instead.
+//
+Int_t MTaskList::Process()
+{
+    //
+    // Check whether there is something which can be processed, otherwise
+    // stop the eventloop.
+    //
+    if (fTasksProcess.GetSize()==0)
+    {
+        *fLog << warn << "Warning: No entries in " << GetDescriptor() << " for Processing." << endl;
+        return kFALSE;
+    }
+
+    //
+    // Reset the ReadyToSave flag.
+    // Reset all containers.
+    //
+    // Make sure, that the parameter list is not reset from a tasklist
+    // running as a task in another tasklist.
+    //
+    const Bool_t noreset = fParList->TestBit(MParList::kIsProcessing);
+    if (!noreset)
+    {
+        fParList->SetBit(MParList::kIsProcessing);
+        if (!HasAccelerator(kAccDontReset))
+            fParList->Reset();
+    }
+
+    // Initialize storage variable for the return code
+    Int_t rc = kTRUE;
+
+    // Execute the task list at least once
+    const UInt_t cnt = fNumPasses==0 ? 1 : fNumPasses;
+    for (fNumPass=0; fNumPass<cnt; fNumPass++)
+    {
+        // Execute the tasklist once
+        rc = ProcessTaskList();
+        // In cae of error or a stop-request leave loop
+        if (rc==kERROR || rc==kFALSE)
+            break;
+    }
+
+    // Reset to the default
     if (!noreset)
     {
@@ -713 +736 @@
     }
 
+    // If the number of passes==0 <default> propagete kCONTINUE
+    if (rc==kCONTINUE)
+        return fNumPasses==0 ? kCONTINUE : kTRUE;
+
+    // Return return code
     return rc;
 }