GSI Object Oriented Online Offline (Go4)
GO4-5.3.2
|
#include <TGo4ExampleClient.h>
Public Member Functions | |
TGo4ExampleClient (const char *name, const char *host="localhost", UInt_t negport=0, Bool_t blockingmode=kTRUE) | |
virtual | ~TGo4ExampleClient () |
TGo4ExampleApplication * | GetApplication () |
virtual void | Start () |
virtual void | Stop () |
virtual TGo4TaskStatus * | CreateStatus () |
Public Member Functions inherited from TGo4ClientTask | |
TGo4ClientTask (const char *name, const char *serverhost="localhost", UInt_t negotiationport=0, Bool_t blockingmode=kTRUE, Bool_t standalone=kFALSE, Bool_t autostart=kFALSE, Bool_t autocreate=kTRUE, Bool_t ismaster=kFALSE, Bool_t autoconnect=kTRUE) | |
virtual | ~TGo4ClientTask () |
virtual Int_t | Initialization () |
virtual void | Quit () |
TGo4TaskHandler * | GetTaskHandler () |
void | AddLocalCommand (TGo4Command *com) |
TGo4BufferQueue * | GetCommandQueue (const char *task=0) |
TGo4BufferQueue * | GetStatusQueue (const char *task=0) |
TGo4BufferQueue * | GetDataQueue (const char *task=0) |
Bool_t | ConnectServer (const char *node, UInt_t negport, Go4CommandMode_t role=kGo4ComModeRefused, const char *passwd=0) |
Bool_t | DisconnectServer (Bool_t isterminating=kFALSE) |
const char * | GetServerHostName () |
Bool_t | IsConnected () const |
Public Member Functions inherited from TGo4Task | |
TGo4Task (const char *name, Bool_t blockingmode, Bool_t autostart=kFALSE, Bool_t autocreate=kTRUE, Bool_t ismaster=kFALSE) | |
virtual | ~TGo4Task () |
virtual void | KillMain () |
virtual void | RestartMain () |
virtual void | Terminate (Bool_t termapp=kTRUE) |
virtual void | TerminateFast () |
virtual void | ExecuteString (const char *command) |
Bool_t | IsMaster () |
void | SetOwner (TGo4TaskOwner *owner) |
void | AddUserCommand (TGo4Command *com) |
void | AddUserCommandList (TGo4CommandProtoList *comlist) |
TGo4Status * | NextStatus (Bool_t wait=kTRUE) |
TObject * | NextObject (Bool_t wait=kTRUE) |
virtual TGo4Command * | NextCommand () |
void | SendObject (TObject *obj, const char *receiver=0) |
virtual void | SendStatus (TGo4Status *stat, const char *receiver=0) |
virtual void | SendStatusBuffer () |
TMutex * | GetStatusBufferMutex () |
void | SendStatusMessage (Int_t level, Bool_t printout, const char *text,...) |
void | UpdateStatusBuffer () |
Bool_t | SubmitCommand (const char *name) |
Bool_t | SubmitEmergencyCommand (Go4EmergencyCommand_t val) |
Bool_t | SubmitEmergencyData (Go4EmergencyCommand_t val, const char *receiver=0) |
Bool_t | SubmitLocalCommand (TGo4Command *com) |
Bool_t | SubmitCommand (TGo4Command *com) |
TGo4Command * | MakeCommand (const char *name) |
void | WakeCommandQueue (Int_t id=0) |
virtual Int_t | StartWorkThreads () |
virtual Int_t | StopWorkThreads () |
Bool_t | IsWorkStopped () |
virtual void | GetStatus () |
const char * | GetCommanderName () const |
TGo4Master * | GetMaster () |
TGo4Slave * | GetSlave () |
void | SendStopBuffers (const char *taskname=0) |
TBuffer * | GetAbortBuffer () |
Public Member Functions inherited from TGo4ThreadManager | |
TGo4ThreadManager (const TGo4ThreadManager &right) | |
TGo4ThreadManager (const char *name, Bool_t blockingmode=kTRUE, Bool_t autostart=kTRUE, Bool_t autocreate=kTRUE) | |
virtual | ~TGo4ThreadManager () |
void | SetTimer (TGo4AppControlTimer *ctrltimer) |
TGo4ThreadHandler * | GetWorkHandler () const |
Bool_t | BlockApp () |
Bool_t | UnBlockApp (Int_t mode=0) |
Bool_t | IsInitDone () const |
Bool_t | IsTerminating () const |
Bool_t | IsTerminateApp () const |
Bool_t | IsAppBlocking () const |
Bool_t | IsBeingQuit () const |
void | SetBeingQuit (Bool_t on) |
void | Launch () |
Public Member Functions inherited from TGo4CommandReceiver | |
virtual | ~TGo4CommandReceiver () |
TGo4CommandReceiver () | |
Static Public Attributes | |
static const char * | fgcMAINTHREAD ="MAIN-" |
static const char * | fgcWATCHTHREAD ="WATCH-" |
Static Public Attributes inherited from TGo4ThreadManager | |
static const Long_t | fglTIMERPERIOD = 200 |
Protected Member Functions | |
virtual void | UpdateStatus (TGo4ClientStatus *state) |
Protected Member Functions inherited from TGo4ClientTask | |
virtual void | UpdateStatus (TGo4TaskStatus *state) |
Protected Member Functions inherited from TGo4Task | |
virtual TGo4TaskHandlerCommandList * | CreateCommandList () |
TGo4TaskHandlerCommandList * | GetPrototype () |
TGo4ObjectQueue * | GetLocalCommandQueue () |
void | SetMaster (Bool_t on=kTRUE) |
void | SetWorkIsStopped (Bool_t on) |
Private Member Functions | |
TGo4ExampleClient () | |
Private Attributes | |
TGo4ExampleApplication * | fxApplication |
TString | fcMainName |
TString | fcWatchName |
Additional Inherited Members | |
Public Types inherited from TGo4ThreadManager | |
enum | { fguTEXTLENGTH = 256 } |
Static Public Member Functions inherited from TGo4Task | |
static Int_t | Get_fgiTERMID () |
Protected Attributes inherited from TGo4Task | |
TMutex * | fxStatusMutex |
TBuffer * | fxStatusBuffer |
Protected Attributes inherited from TGo4ThreadManager | |
Bool_t | fbInitDone |
Bool_t | fbTerminating |
Bool_t | fbTerminateApplication |
Bool_t | fbAppBlocking |
Bool_t | fbAutoCreate |
Bool_t | fbAutoStart |
Int_t | fbBeingQuit |
TGo4AppControlTimer * | fxBlocker |
TGo4ThreadHandler * | fxWorkHandler |
Example class for a client application; this may be the analysis client later on which keeps the analysis class itself as aggregate and provides threads to work on analysis
Definition at line 29 of file TGo4ExampleClient.h.
TGo4ExampleClient::TGo4ExampleClient | ( | const char * | name, |
const char * | host = "localhost" , |
||
UInt_t | negport = 0 , |
||
Bool_t | blockingmode = kTRUE |
||
) |
Definition at line 31 of file TGo4ExampleClient.cxx.
References TGo4Log::Debug(), fcMainName, fcWatchName, fgcMAINTHREAD, fgcWATCHTHREAD, fxApplication, TGo4ThreadManager::fxWorkHandler, TGo4ClientTask::GetDataQueue(), TGo4ClientTask::GetTaskHandler(), GO4TRACE, TGo4ThreadManager::Launch(), TGo4ThreadHandler::NewThread(), and TGo4Task::SetMaster().
|
virtual |
Definition at line 51 of file TGo4ExampleClient.cxx.
References TGo4ThreadHandler::CancelAll(), fxApplication, TGo4ThreadManager::fxWorkHandler, and GO4TRACE.
|
private |
|
virtual |
create a status object with information on the current client state. this object may be sent to the server or may be used to restore current status by memento mechanism. Overridden from superclass
Reimplemented from TGo4ClientTask.
Definition at line 58 of file TGo4ExampleClient.cxx.
References GO4TRACE, and UpdateStatus().
TGo4ExampleApplication * TGo4ExampleClient::GetApplication | ( | ) |
Definition at line 92 of file TGo4ExampleClient.cxx.
References fxApplication, and GO4TRACE.
Referenced by TGo4MainRunnable::TGo4MainRunnable(), TGo4WatchRunnable::TGo4WatchRunnable(), and UpdateStatus().
|
virtual |
General start method of client application to be called from remote command; should be re-implemented by application
Reimplemented from TGo4Task.
Definition at line 84 of file TGo4ExampleClient.cxx.
References TGo4Log::Debug(), fcMainName, TGo4ThreadManager::fxWorkHandler, GO4TRACE, and TGo4ThreadHandler::Start().
|
virtual |
General stop method of client application to be called from remote command; should be re-implemented by application
Reimplemented from TGo4Task.
Definition at line 76 of file TGo4ExampleClient.cxx.
References TGo4Log::Debug(), fcMainName, TGo4ThreadManager::fxWorkHandler, GO4TRACE, and TGo4ThreadHandler::Stop().
|
protectedvirtual |
method needed by method CreateStatus of any status subclasses to set the values of the clienttask specific part of the status object.
Definition at line 66 of file TGo4ExampleClient.cxx.
References fcMainName, fcWatchName, GetApplication(), GetHistogram(), GO4TRACE, TGo4ExampleClientStatus::SetHistoStatus(), TGo4ExampleClientStatus::SetNames(), and TGo4ClientTask::UpdateStatus().
Referenced by CreateStatus().
|
private |
Remember name of main thread
Definition at line 80 of file TGo4ExampleClient.h.
Referenced by Start(), Stop(), TGo4ExampleClient(), and UpdateStatus().
|
private |
Remember name of watch thread
Definition at line 83 of file TGo4ExampleClient.h.
Referenced by TGo4ExampleClient(), and UpdateStatus().
|
static |
Suffix for main thread name
Definition at line 46 of file TGo4ExampleClient.h.
Referenced by TGo4ExampleClient().
|
static |
Suffix for watch thread name
Definition at line 49 of file TGo4ExampleClient.h.
Referenced by TGo4ExampleClient().
|
private |
Definition at line 77 of file TGo4ExampleClient.h.
Referenced by GetApplication(), TGo4ExampleClient(), and ~TGo4ExampleClient().