]>
Commit | Line | Data |
---|---|---|
7e0cf530 | 1 | // Author: Mihai Niculescu 2013 |
2 | ||
3 | /************************************************************************** | |
4 | * Copyright(c) 1998-2013, ALICE Experiment at CERN, all rights reserved. * | |
5 | * See http://aliceinfo.cern.ch/Offline/AliRoot/License.html for * | |
6 | * full copyright notice. * | |
7 | **************************************************************************/ | |
8 | ||
9 | #ifndef __AliRecoServerThread_H__ | |
10 | #define __AliRecoServerThread_H__ | |
11 | ||
12 | #include <TQObject.h> | |
13 | #include <RQ_OBJECT.h> | |
14 | #include <TMutex.h> | |
15 | #include <TCondition.h> | |
16 | ||
db352b46 | 17 | #include "AliThreadedSocket.h" |
18 | ||
7e0cf530 | 19 | class TCondition; |
7e0cf530 | 20 | class TThread; |
21 | ||
22 | class AliReconstruction; | |
23 | class AliESDEvent; | |
24 | ||
db352b46 | 25 | class AliRecoServerThread : public AliThreadedSocket |
7e0cf530 | 26 | { |
27 | public: | |
28 | AliRecoServerThread(zmq::context_t *context, AliReconstruction* reco); | |
29 | virtual ~AliRecoServerThread(); | |
30 | ||
7e0cf530 | 31 | |
db352b46 | 32 | Bool_t Start(const char* endpoint); |
33 | ||
34 | const char* GetHost() const { return fHost.Data(); } | |
7e0cf530 | 35 | AliReconstruction* GetReconstruction() { return fReco; } |
db352b46 | 36 | TCondition* Condition() { return fCond; } |
7e0cf530 | 37 | |
7e0cf530 | 38 | private: |
f05dd9ed | 39 | void RunThrdWrite(); |
7e0cf530 | 40 | |
7e0cf530 | 41 | AliReconstruction* fReco; |
42 | ||
43 | // local | |
7e0cf530 | 44 | TCondition* fCond; // condition whether to stop reco/clean exit thread |
db352b46 | 45 | TString fHost; |
7e0cf530 | 46 | |
47 | private: | |
48 | AliRecoServerThread(const AliRecoServerThread&); // Not implemented | |
49 | AliRecoServerThread& operator=(const AliRecoServerThread&); // Not implemented | |
50 | ||
51 | public: | |
52 | ||
53 | ClassDef(AliRecoServerThread, 0); | |
54 | }; | |
55 | #endif /* __AliReconstructionThread_H__ */ | |
56 |