28 std::vector<std::string>
fArgs;
33 TARunInfo(
int runno,
const char* filename,
const std::vector<std::string>& args);
56 template<
class T> T*
Find()
60 T *ptr =
dynamic_cast<T*
>(f);
74 #define TAFlag_SKIP (1<<0)
75 #define TAFlag_QUIT (1<<1)
76 #define TAFlag_WRITE (1<<2)
77 #define TAFlag_DISPLAY (1<<3)
78 #define TAFlag_SKIP_PROFILE (1<<4)
118 virtual void Init(
const std::vector<std::string> &args);
126 return new T(runinfo);
142 #include "TDirectory.h"
143 #include "TApplication.h"
155 static TApplication*
fgApp;
201 #define HAVE_MANALYZER_PROFILER 1
206 typedef std::chrono::high_resolution_clock::time_point
TAClock;
virtual void Init(const std::vector< std::string > &args)
virtual TARunObject * NewRunObject(TARunInfo *runinfo)=0
T * NewRunObject(TARunInfo *runinfo)
TAFlowEvent(TAFlowEvent *)
int fMtQueueFullUSleepTime
std::vector< TAFlagsQueue > fMtFlagQueue
std::vector< std::mutex > fMtFlowQueueMutex
std::vector< bool > fMtThreadIsBusy
int fMtQueueEmptyUSleepTime
std::vector< std::thread * > fMtThreads
static int gfMtMaxBacklog
static bool gfMultithread
std::vector< TAFlowEventQueue > fMtFlowQueue
std::vector< bool > fMtThreadIsRunning
bool fMtShutdownRequested
static std::string fOutputDirectory
TARootHelper(const TARunInfo *)
static TApplication * fgApp
static std::string fOutputFileName
static THttpServer * fgHttpServer
static TDirectory * fgDir
void AddToFlowQueue(TAFlowEvent *)
TARunInfo(int runno, const char *filename, const std::vector< std::string > &args)
std::vector< std::string > fArgs
TAFlowEvent * ReadFlowQueue()
std::deque< TAFlowEvent * > fFlowQueue
static std::vector< std::string > fgFileList
TAMultithreadHelper * fMtInfo
static int fgCurrentFileIndex
virtual void ResumeRun(TARunInfo *runinfo)
virtual void PreEndRun(TARunInfo *runinfo)
virtual void NextSubrun(TARunInfo *runinfo)
virtual void PauseRun(TARunInfo *runinfo)
virtual TAFlowEvent * Analyze(TARunInfo *runinfo, TMEvent *event, TAFlags *flags, TAFlowEvent *flow)
virtual TAFlowEvent * AnalyzeFlowEvent(TARunInfo *runinfo, TAFlags *flags, TAFlowEvent *flow)
virtual void BeginRun(TARunInfo *runinfo)
virtual void EndRun(TARunInfo *runinfo)
TARunObject(TARunInfo *runinfo)
virtual void AnalyzeSpecialEvent(TARunInfo *runinfo, TMEvent *event)
TAUserProfilerFlow(TAFlowEvent *flow, const char *name, const TAClock &start)
const std::string fModuleName
std::chrono::high_resolution_clock::time_point TAClock
int manalyzer_main(int argc, char *argv[])
std::chrono::duration< double > TAClockDuration
std::deque< TAFlowEvent * > TAFlowEventQueue
std::deque< TAFlags * > TAFlagsQueue