143 "Analysis %s TIMEOUT for event source %s:%s.",
151 "End of event source %s:\n %s - %s",
159 Int_t prio=ex.GetPriority();
164 "Event source %s:\n %s - %s",
171 "Analysis %s ERROR: %s from event source %s:%s",
195 "Event Store %s throws exception: %s - %s",
205 "Analysis %s ERROR: %s from dynamic list entry %s:%s",
207 ex.GetEntryName(), ex.GetEntryClass()));
217 "Analysis %s ERROR: %s in Analysis Step %s",
227 if(strlen(ex.GetMessage()) != 0)
228 fxAnalysisClient->SendStatusMessage(ex.GetPriority(),kTRUE, ex.GetMessage());
229 if(
fxAnalysis->IsErrorStopEnabled() && ex.GetPriority()>2)
234 catch(std::exception& ex)
237 "Analysis %s got standard exception %s",
Int_t Run(void *) override
The working function which runs in the thread.
TGo4AnalysisMainRunnable()
Int_t PostRun(void *) override
Function which is called once after the Run()method on threadstop.
Int_t PreRun(void *) override
Function which is called once before the Run() method on threadstart.
TGo4Analysis * fxAnalysis
1
virtual ~TGo4AnalysisMainRunnable()
static const UInt_t fguPOLLINTERVAL
frequency in ms for polling the run flag (server mode without command queue)
TGo4AnalysisClient * fxAnalysisClient
1