00001 //------------------------------------------------------------- 00002 // Go4 Release Package v3.04-01 (build 30401) 00003 // 28-November-2008 00004 //--------------------------------------------------------------- 00005 // The GSI Online Offline Object Oriented (Go4) Project 00006 // Experiment Data Processing at EE department, GSI 00007 //--------------------------------------------------------------- 00008 // 00009 //Copyright (C) 2000- Gesellschaft f. Schwerionenforschung, GSI 00010 // Planckstr. 1, 64291 Darmstadt, Germany 00011 //Contact: http://go4.gsi.de 00012 //---------------------------------------------------------------- 00013 //This software can be used under the license agreements as stated 00014 //in Go4License.txt file which is part of the distribution. 00015 //---------------------------------------------------------------- 00016 #include "TGo4ObjConnectorRunnable.h" 00017 00018 #include "Riostream.h" 00019 00020 #include "TGo4Thread.h" 00021 #include "TGo4Task.h" 00022 #include "TGo4HistogramServer.h" 00023 #include "TGo4AnalysisClientImp.h" 00024 00025 TGo4ObjConnectorRunnable::TGo4ObjConnectorRunnable(const char* name, TGo4HistogramServer* hserv) 00026 : TGo4Runnable(name, hserv->GetAnalysisClient()->GetTask()) 00027 { 00028 fxHistogramServer=hserv; 00029 } 00030 00031 TGo4ObjConnectorRunnable::TGo4ObjConnectorRunnable() : TGo4Runnable(0,0) 00032 { 00033 } 00034 00035 TGo4ObjConnectorRunnable::~TGo4ObjConnectorRunnable() 00036 { 00037 } 00038 00039 Int_t TGo4ObjConnectorRunnable::Run(void*) 00040 { 00041 if(!fxHistogramServer) 00042 { 00043 cout <<"error, no histogram server!!" << endl; 00044 fxGo4Thread->Stop(); 00045 return -1; 00046 } 00047 Int_t rev=fxHistogramServer->ServeObjectClient(); 00048 if(rev< -1) 00049 { 00050 fxGo4Thread->Stop(); // stop runnable for termination 00051 } 00052 else{} 00053 return 0; 00054 } 00055 00056 //----------------------------END OF GO4 SOURCE FILE ---------------------