[u/mrichter/AliRoot.git] / STORAGE / 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;
	
	//zmq - receive events
	std::string fEventServer;
	
	//zmq - communication with admin panel
	static void* CommunicationHandler(void *arg);
	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
	23	//zmq - receive events
	24	std::string fEventServer;
	25
	26	//zmq - communication with admin panel
	27	static void* CommunicationHandler(void *arg);
	28	TThread *fCommunicationThread;
	29
	30	//storage file system
	31	void CheckCurrentStorageSize();
	32	void SetStorageParams(int maxStorageSize,
	33	int maxOccupation,
	34	int removeEvents,
	35	int eventsInChunk);
	36	TFile *fCurrentFile;
	37
	38	AliStorageDatabase *fDatabase;
	39	int fCurrentStorageSize;
	40	int fMaximumStorageSize;
	41	std::string fStoragePath;
	42	int fNumberOfEventsInFile;
	43	int fStorageOccupationLevel;
	44	int fRemoveEventsPercentage;
	45
	46	Long64_t GetSizeOfAllChunks();
	47
	48	AliStorageClientThread(const AliStorageClientThread&);
	49	AliStorageClientThread& operator=(const AliStorageClientThread&);
	50
	51	};
	52
	53	#endif