---

/Go4TaskHandler/TGo4Slave.cxx

Go to the documentation of this file.

//---------------------------------------------------------------
//        Go4 Release Package v2.10-5 (build 21005) 
//                      03-Nov-2005
//---------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//       Experiment Data Processing at DVEE department, GSI
//---------------------------------------------------------------
//
//Copyright (C) 2000- Gesellschaft f. Schwerionenforschung, GSI
//                    Planckstr. 1, 64291 Darmstadt, Germany
//Contact:            http://go4.gsi.de
//----------------------------------------------------------------
//This software can be used under the license agreements as stated
//in Go4License.txt file which is part of the distribution.
//----------------------------------------------------------------
/* Generated by Together */

#include "TGo4Slave.h"

#include "Go4Log/TGo4Log.h"
#include "Go4LockGuard/TGo4LockGuard.h"
#include "TGo4Task.h"
#include "TGo4ServerTask.h"
#include "TGo4ClientTask.h"
#include "Go4ThreadManager/TGo4ThreadHandler.h"
#include "Go4CommandsBase/TGo4CommandInvoker.h"

TGo4Slave::TGo4Slave(const char* name, Bool_t isserver, const char* serverhost, UInt_t negotport) 
:TGo4TaskOwner(isserver), 
 fbMainIsRunning(kTRUE)
{ 
   TGo4CommandInvoker::Instance(); // make sure a command invoker exists
   TGo4CommandInvoker::Register("SlaveTask", this);
   TGo4Task* task=0;
   if(IsServer())
      {
         task=new TGo4ServerTask(name, negotport, 
               kFALSE, //blockingmode
               kFALSE, //standalone 
               kTRUE,  //autostart
               kTRUE,  //autocreate 
               kFALSE   //ismaster 
               );  
      }     
   else
      {
         task=new TGo4ClientTask(name, serverhost, negotport,
                     kFALSE, //blockingmode
                     kFALSE, //standalone
                     kFALSE, //autostart
                     kTRUE,  //autocreate
                     kFALSE, //ismaster
                     kTRUE );//autoconnect 
      }
   SetTask(task);
}

TGo4Slave::TGo4Slave():fbMainIsRunning(kTRUE) 
{ 
   
}

TGo4Slave::~TGo4Slave() 
{ 
   
}


void TGo4Slave::Start()
{
   TGo4Log::Debug(" Slave ''%s'' default Start method, please override",GetName());
   fbMainIsRunning=kTRUE;
}
void TGo4Slave::Stop()
{
   TGo4Log::Debug(" Slave ''%s'' default Stop method, please override",GetName());
   fbMainIsRunning=kFALSE;
}

void TGo4Slave::KillMain()
{
// may be overridden by concrete slave implementation

}
void TGo4Slave::RestartMain()
{
// may be overridden by concrete slave implementation
}

void TGo4Slave::Terminate (Bool_t termapp)
{
   if(GetTask())
      GetTask()->TGo4ThreadManager::Terminate(termapp);   
}    

void TGo4Slave::TerminateFast ()
{
   Terminate();    
}


TGo4TaskStatus* TGo4Slave::CreateStatus()
{
   TGo4TaskStatus* stat= new TGo4TaskStatus((Text_t*) GetName());
   UpdateStatus(stat); // set the internals
   return stat;
}

void TGo4Slave::UpdateStatus(TGo4TaskStatus* state)
{
   if(GetTask())
      GetTask()->UpdateStatus(state);
}

TGo4Command* TGo4Slave::NextCommand()
{
   if(GetTask())
      return (GetTask()->NextCommand());
   else
      return 0;
}

void TGo4Slave::SendObject(TObject * obj, const char* receiver)
{
   if(GetTask())
      GetTask()->SendObject(obj, receiver);
}

void TGo4Slave::SendStatus(TGo4Status * stat, const char* receiver)
{
   if(GetTask())
      GetTask()->SendStatus(stat, receiver);
}

Int_t TGo4Slave::Initialization()
{
// may be overridden by concrete slave implementation
    return 0;
}

TGo4ThreadHandler* TGo4Slave::GetThreadHandler()
{
   if(GetTask())
      return(GetTask()->GetWorkHandler());   
   else 
      return 0;
}


void TGo4Slave::SendStatusBuffer()
{
   if(GetTask()) GetTask()->SendStatusBuffer();
}

void TGo4Slave::SendStatusMessage(Int_t level, Bool_t printout, const char* text,...)
{
   if(GetTask()==0) return;
   Int_t lbuflen=256;
   // put potential printf arguments in text:
   Text_t txtbuf[lbuflen];
   va_list args;
   va_start(args, text);
   vsnprintf(txtbuf, lbuflen, text, args);
   va_end(args);
   GetTask()->SendStatusMessage(level, printout, txtbuf);
}


void TGo4Slave::UpdateStatusBuffer()
{
   if(GetTask()) GetTask()->UpdateStatusBuffer();
}
void TGo4Slave::ExecuteString(const Text_t* command)
{
   gROOT->ProcessLine(command);
}


//----------------------------END OF GO4 SOURCE FILE ---------------------

---