[u/mrichter/AliRoot.git] / MONITOR / MONITORzmq / AliEventsCollectorThread.h

#ifndef __AliEventsCollectorThread__
#define __AliEventsCollectorThread__

#include "AliStorageDatabase.h"
#include "AliStorageClientThread.h"

#include <TThread.h>
#include <TFile.h>

class AliStorageClientThread;

class AliEventsCollectorThread
{
public:
    AliEventsCollectorThread(AliStorageClientThread *onlineReconstructionManager);
    ~AliEventsCollectorThread();
    
    void Kill();
private:
    AliStorageClientThread *fManager;
    
    static void* Dispatch(void *arg)
    {
        static_cast<AliEventsCollectorThread*>(arg)->CollectorHandle();
        return nullptr;
    }
    void CollectorHandle();
    TThread *fCollectorThread;
    
    TFile *fCurrentFile;
    AliStorageDatabase *fDatabase;
    void CheckCurrentStorageSize();
    Long64_t GetSizeOfAllChunks();
    
    bool fFinished;
};


#endif /* defined(__AliEventsCollectorThread__) */
Commit	Line	Data
186c4b6e	1	#ifndef __AliEventsCollectorThread__
	2	#define __AliEventsCollectorThread__
	3
	4	#include "AliStorageDatabase.h"
	5	#include "AliStorageClientThread.h"
	6
	7	#include <TThread.h>
	8	#include <TFile.h>
	9
	10	class AliStorageClientThread;
	11
	12	class AliEventsCollectorThread
	13	{
	14	public:
	15	AliEventsCollectorThread(AliStorageClientThread *onlineReconstructionManager);
	16	~AliEventsCollectorThread();
	17
	18	void Kill();
	19	private:
	20	AliStorageClientThread *fManager;
	21
	22	static void* Dispatch(void *arg)
	23	{
	24	static_cast<AliEventsCollectorThread*>(arg)->CollectorHandle();
	25	return nullptr;
	26	}
	27	void CollectorHandle();
	28	TThread *fCollectorThread;
	29
	30	TFile *fCurrentFile;
	31	AliStorageDatabase *fDatabase;
	32	void CheckCurrentStorageSize();
	33	Long64_t GetSizeOfAllChunks();
	34
	35	bool fFinished;
	36	};
	37
	38
	39	#endif /* defined(__AliEventsCollectorThread__) */