[u/mrichter/AliRoot.git] / MONITOR / alistoragemanager / AliStorageClientThread.h

#ifndef AliStorageClientThread_H
#define AliStorageClientThread_H

#include "AliStorageDatabase.h"

#include <string>

#include <TThread.h>

class AliStorageClientThread
{
public:
	AliStorageClientThread();
	 ~AliStorageClientThread();
	void CollectData();

private:
	//status flags
	Int_t fConnectionStatus;
	Int_t fReceivingStatus;
	Int_t fSavingStatus;
	
	//communication with admin panel
    static void* Dispatch(void *arg){static_cast<AliStorageClientThread*>(arg)->CommunicationHandle();}
	void CommunicationHandle();
	TThread *fCommunicationThread;
	
	//storage file system
	void CheckCurrentStorageSize();
	void SetStorageParams(int maxStorageSize,
			      int maxOccupation,
			      int removeEvents,
			      int eventsInChunk);
	TFile *fCurrentFile;

	AliStorageDatabase *fDatabase;
	int fCurrentStorageSize;
	int fMaximumStorageSize;
	std::string fStoragePath;
	int fNumberOfEventsInFile;
	int fStorageOccupationLevel;
	int fRemoveEventsPercentage;

	Long64_t GetSizeOfAllChunks();
	
	AliStorageClientThread(const AliStorageClientThread&);
	AliStorageClientThread& operator=(const AliStorageClientThread&);
	
};

#endif
Commit	Line	Data
5eb34a26	1	#ifndef AliStorageClientThread_H
	2	#define AliStorageClientThread_H
	3
	4	#include "AliStorageDatabase.h"
	5
	6	#include <string>
	7
	8	#include <TThread.h>
	9
	10	class AliStorageClientThread
	11	{
	12	public:
	13	AliStorageClientThread();
	14	~AliStorageClientThread();
	15	void CollectData();
	16
	17	private:
	18	//status flags
	19	Int_t fConnectionStatus;
	20	Int_t fReceivingStatus;
	21	Int_t fSavingStatus;
	22
164d3d29	23	//communication with admin panel
	24	static void* Dispatch(void arg){static_cast<AliStorageClientThread>(arg)->CommunicationHandle();}
	25	void CommunicationHandle();
5eb34a26	26	TThread *fCommunicationThread;
	27
	28	//storage file system
	29	void CheckCurrentStorageSize();
	30	void SetStorageParams(int maxStorageSize,
	31	int maxOccupation,
	32	int removeEvents,
	33	int eventsInChunk);
	34	TFile *fCurrentFile;
	35
	36	AliStorageDatabase *fDatabase;
	37	int fCurrentStorageSize;
	38	int fMaximumStorageSize;
	39	std::string fStoragePath;
	40	int fNumberOfEventsInFile;
	41	int fStorageOccupationLevel;
	42	int fRemoveEventsPercentage;
	43
	44	Long64_t GetSizeOfAllChunks();
	45
	46	AliStorageClientThread(const AliStorageClientThread&);
	47	AliStorageClientThread& operator=(const AliStorageClientThread&);
	48
	49	};
	50
	51	#endif