]>
Commit | Line | Data |
---|---|---|
186c4b6e | 1 | #ifndef __AliCommunicationThread__ |
2 | #define __AliCommunicationThread__ | |
3 | ||
4 | #include "AliStorageClientThread.h" | |
5 | ||
6 | #include <TThread.h> | |
7 | ||
8 | class AliStorageClientThread; | |
9 | ||
10 | class AliCommunicationThread | |
11 | { | |
12 | public: | |
13 | AliCommunicationThread(AliStorageClientThread *onlineReconstructionManager); | |
14 | ~AliCommunicationThread(); | |
15 | ||
16 | void Kill(); | |
17 | private: | |
18 | bool fFinished; | |
19 | AliStorageClientThread *fManager; | |
20 | ||
21 | static void* Dispatch(void *arg) | |
22 | { | |
23 | static_cast<AliCommunicationThread*>(arg)->CommunicationHandle(); | |
24 | return nullptr; | |
25 | } | |
26 | void CommunicationHandle(); | |
27 | TThread *fCommunicationThread; | |
28 | ||
29 | void SetStorageParams(int maxStorageSize,int maxOccupation,int removeEvents,int eventsInChunk); | |
30 | }; | |
31 | ||
32 | #endif /* defined(__AliCommunicationThread__) */ |