---

/Go4TaskHandler/TGo4TaskOwner.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 "TGo4TaskOwner.h"
#include "TGo4Task.h"
#include "TGo4ServerTask.h"
#include "TGo4ClientTask.h"
#include "Go4Log/TGo4Log.h"
#include <Rtypes.h>
#include <iostream>

using namespace std;

TGo4TaskOwner::TGo4TaskOwner() 
: fxTask(0),fbServerMode(kTRUE) 
{ 

}


TGo4TaskOwner::TGo4TaskOwner(Bool_t isserver)
: fxTask(0), fbServerMode(isserver) 
{ 
 
}

TGo4TaskOwner::~TGo4TaskOwner() 
{ 
   if(fxTask)
      fxTask->SetOwner(0); // avoid the task to delete us again in dtor  
   delete fxTask;       
}
void TGo4TaskOwner::Quit()
{
   fxTask->Quit();
}

Int_t TGo4TaskOwner::StartWorkThreads()
{
   TGo4Log::Debug(" Task Owner: default StartWorkThreads() ");
   fxTask->SetWorkIsStopped(kFALSE);
   return 0;
}
Int_t TGo4TaskOwner::StopWorkThreads()
{
   TGo4Log::Debug(" Task Owner: default StopWorkThreads() ");
   fxTask->SetWorkIsStopped(kTRUE);
   return 0;
}


Bool_t TGo4TaskOwner::IsConnected()
{
if(IsServer())
   {
      TGo4ServerTask* server=dynamic_cast<TGo4ServerTask*>(GetTask());  
      if(server==0) 
         {
            cerr <<"NEVER COME HERE: servermode without servertask in taskowner "<< GetName() << endl;
            return kFALSE;
         }
      return (server->GetCurrentTaskHandler()!=0);
   }
else
   {
      TGo4ClientTask* client=dynamic_cast<TGo4ClientTask*>(GetTask()); 
      if(client==0) 
         {
            cerr <<"NEVER COME HERE: clientmode without clienttask in taskowner "<< GetName() << endl;
            return kFALSE;
         }
      return (client->IsConnected());
   }      
   
}

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

---