Logo ROOT  
Reference Guide
TXSlave.h
Go to the documentation of this file.
1 // @(#)root/proofx:$Id$
2 // Author: G. Ganis Oct 2005
3 
4 /*************************************************************************
5  * Copyright (C) 1995-2005, Rene Brun and Fons Rademakers. *
6  * All rights reserved. *
7  * *
8  * For the licensing terms see $ROOTSYS/LICENSE. *
9  * For the list of contributors see $ROOTSYS/README/CREDITS. *
10  *************************************************************************/
11 
12 #ifndef ROOT_TXSlave
13 #define ROOT_TXSlave
14 
15 
16 //////////////////////////////////////////////////////////////////////////
17 // //
18 // TXSlave //
19 // //
20 // This is the version of TSlave for slave servers based on XRD. //
21 // See TSlave for details. //
22 // //
23 //////////////////////////////////////////////////////////////////////////
24 
25 #include "TSlave.h"
26 #include "TXHandler.h"
27 
28 class TObjString;
29 class TSocket;
30 class TSignalHandler;
31 
32 class TXSlave : public TSlave, public TXHandler {
33 
34 friend class TProof;
35 friend class TXProofMgr;
36 
37 private:
39  Int_t fNWrks; // Number of workers when submaster in remote plite
40  TSignalHandler *fIntHandler; //interrupt signal handler (ctrl-c)
41 
42  void Init(const char *host, Int_t stype);
43  void ParseBuffer();
44 
45  // Static methods
47 
48 protected:
49  void FlushSocket();
50  void Interrupt(Int_t type);
51  Int_t Ping();
52  TObjString *SendCoordinator(Int_t kind, const char *msg = 0, Int_t int2 = 0);
53  Int_t SendGroupPriority(const char *grp, Int_t priority);
54  void SetAlias(const char *alias);
55  void StopProcess(Bool_t abort, Int_t timeout);
56 
57 public:
58  TXSlave(const char *url, const char *ord, Int_t perf,
59  const char *image, TProof *proof, Int_t stype,
60  const char *workdir, const char *msd, Int_t nwk = 1);
61  virtual ~TXSlave();
62 
63  void Close(Option_t *opt = "");
64  void DoError(int level, const char *location, const char *fmt,
65  va_list va) const;
66 
67  Bool_t HandleError(const void *in = 0); // Error Handler
68  Bool_t HandleInput(const void *in = 0); // Input handler
69 
70  void SetInterruptHandler(Bool_t on = kTRUE);
71 
72  Int_t SetupServ(Int_t stype, const char *conffile);
73 
74  void Touch();
75 
76  ClassDef(TXSlave,0) //Xrd PROOF slave server
77 };
78 
79 #endif
TXSlave::FlushSocket
void FlushSocket()
Clean any input on the socket.
Definition: TXSlave.cxx:698
TSlave
Definition: TSlave.h:46
kTRUE
const Bool_t kTRUE
Definition: RtypesCore.h:91
TXSlave::Interrupt
void Interrupt(Int_t type)
Send interrupt to master or slave servers.
Definition: TXSlave.cxx:418
TXSlave::SetupServ
Int_t SetupServ(Int_t stype, const char *conffile)
Init a PROOF slave object.
Definition: TXSlave.cxx:333
TSlave.h
TSignalHandler
Definition: TSysEvtHandler.h:127
TXSlave::SendGroupPriority
Int_t SendGroupPriority(const char *grp, Int_t priority)
Communicate to the coordinator the priprity of the group to which the user belongs Return 0 on succes...
Definition: TXSlave.cxx:550
TXSlave::~TXSlave
virtual ~TXSlave()
Destroy slave.
Definition: TXSlave.cxx:374
TGeant4Unit::s
static constexpr double s
Definition: TGeant4SystemOfUnits.h:168
TXHandler.h
TXSlave::StopProcess
void StopProcess(Bool_t abort, Int_t timeout)
Sent stop/abort request to PROOF server.
Definition: TXSlave.cxx:456
bool
TXSlave
Definition: TXSlave.h:32
TObjString
Definition: TObjString.h:28
TSocket
Definition: TSocket.h:41
TXSlave::fValid
Bool_t fValid
Definition: TXSlave.h:38
Option_t
const typedef char Option_t
Definition: RtypesCore.h:66
TXSlave::ParseBuffer
void ParseBuffer()
Parse fBuffer after a connection attempt.
Definition: TXSlave.cxx:302
TXSlave::SendCoordinator
TObjString * SendCoordinator(Int_t kind, const char *msg=0, Int_t int2=0)
Send message to intermediate coordinator.
Definition: TXSlave.cxx:525
TXProofMgr
Definition: TXProofMgr.h:40
TXSlave::GetProofdProtocol
static Int_t GetProofdProtocol(TSocket *s)
Find out the remote proofd protocol version.
Definition: TXSlave.cxx:469
TXSlave::fIntHandler
TSignalHandler * fIntHandler
Definition: TXSlave.h:40
TXSlave::DoError
void DoError(int level, const char *location, const char *fmt, va_list va) const
Interface to ErrorHandler (protected).
Definition: TXSlave.cxx:68
TXSlave::SetInterruptHandler
void SetInterruptHandler(Bool_t on=kTRUE)
Set/Unset the interrupt handler.
Definition: TXSlave.cxx:680
TXSlave::Touch
void Touch()
Touch the client admin file to proof we are alive.
Definition: TXSlave.cxx:406
TXHandler
Definition: TXHandler.h:28
TXSlave::Ping
Int_t Ping()
Ping the remote master or slave servers.
Definition: TXSlave.cxx:396
TXSlave::HandleError
Bool_t HandleError(const void *in=0)
Handle error on the input socket.
Definition: TXSlave.cxx:563
TXSlave::SetAlias
void SetAlias(const char *alias)
Set an alias for this session.
Definition: TXSlave.cxx:535
TXSlave::Init
void Init(const char *host, Int_t stype)
Init a PROOF slave object.
Definition: TXSlave.cxx:132
ClassDef
#define ClassDef(name, id)
Definition: Rtypes.h:325
TProof
Definition: TProof.h:316
TSlave::TXSlave
friend class TXSlave
Definition: TSlave.h:51
type
int type
Definition: TGX11.cxx:121
TXSlave::fNWrks
Int_t fNWrks
Definition: TXSlave.h:39
TXSlave::HandleInput
Bool_t HandleInput(const void *in=0)
Handle asynchronous input on the socket.
Definition: TXSlave.cxx:636
int
TXSlave::Close
void Close(Option_t *opt="")
Close slave socket.
Definition: TXSlave.cxx:382