---

/Go4HistogramServer/TGo4ObjClient.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.
//----------------------------------------------------------------
#include "TGo4ObjClient.h"

#include <signal.h>
#include <iostream.h>

#include "TROOT.h"
#include "TClass.h"
#include "TBuffer.h"
#include "TDirectory.h"

#include "Go4Log/TGo4Log.h"
#include "Go4LockGuard/TGo4LockGuard.h"
#include "Go4Socket/TGo4Socket.h"
#include "Go4Socket/TGo4SocketSignalHandler.h"
#include "Go4TaskHandler/TGo4TaskHandler.h"
#include "Go4StatusAnalysis/TGo4AnalysisObjectNames.h"
#include "TGo4HistogramServer.h"

TGo4ObjClient::TGo4ObjClient(const Text_t* name,
                                 const Text_t* base,
                                 const Text_t* passwd,
                                 const Text_t* host,
                                 Int_t port)
: TNamed(name, "This is a Go4 object client")
{
   SetParms(base,passwd,host,port);
   fxTransport=new TGo4Socket(kTRUE);
}

TGo4ObjClient::~TGo4ObjClient()
{
delete fxTransport;

}

void TGo4ObjClient::SetParms(const Text_t* base,
               const Text_t* passwd,
               const Text_t* host,
               Int_t port)
{
   if(base) SetBase(base);
   if(passwd) SetPasswd(passwd);
   if(host) SetHost(host);
   if(port) SetPort(port);
}



TGo4AnalysisObjectNames * TGo4ObjClient::RequestNamesList(const Text_t* base,
                                               const Text_t* passwd,
                                               const Text_t* host,
                                               Int_t port)
{
//
TGo4AnalysisObjectNames* nameslist=0;
SetParms(base,passwd,host,port);
if(ConnectServer()==0)
   {
      // connection successful, go on
      SendCommand(TGo4HistogramServer::fgcCOMGETLIST); // send nameslist request
      TObject* obj=ReceiveObject(); // get incoming buffer and stream object
      if(obj && obj->InheritsFrom("TGo4AnalysisObjectNames"))
        {
          nameslist=dynamic_cast<TGo4AnalysisObjectNames*>(obj);
        }
      else
        {
          cout <<"error receiving nameslist !!!" << endl;
        }
   }
else
   {
      cout <<"error on connection in RequestNamesList" << endl;
      nameslist=0;
   }
DisconnectServer();
return nameslist;
}


TObject* TGo4ObjClient::RequestObject(const Text_t* objectname,
                                       const Text_t* base,
                                       const Text_t* passwd,
                                       const Text_t* host,
                                       Int_t port)
{
TObject* obj=0;
SetParms(base,passwd,host,port);
if(ConnectServer()==0)
   {
      // connection successful, go on
      SendCommand(objectname); // command is name of object to get
      obj=ReceiveObject(); // get incoming buffer and stream object
   }
else
   {
      cout <<"error on connection in RequestObject" << endl;
      obj=0;
   }
DisconnectServer();
return obj;
}


TObject* TGo4ObjClient::ReceiveObject()
{
TObject* obj=0;
// check for OK signal (object is existing on server)
Text_t* recvchar=fxTransport->RecvRaw("dummy");
if(recvchar && !strcmp(recvchar,TGo4TaskHandler::fgcOK))
   {
      TBuffer* buffer=ReceiveBuffer();
      if(buffer)
         {
             // reconstruct object from buffer
             {
               TGo4LockGuard mainguard;
               // lock go4 main mutex for streaming
               TDirectory* savdir=gDirectory;
               gROOT->cd(); // be sure to be in the top directory when creating histo
               buffer->SetReadMode();
               //cout << "Reading object from buffer..."<< endl;
               buffer->Reset();
               obj=buffer->ReadObject(0); // ReadObject(cl)
               if(obj) cout <<"read object of class"<<obj->IsA()->GetName() << endl;
               savdir->cd();
            } //  TGo4LockGuard
         }
      else
         {
            cout <<"error receiving object" << endl;
         } // if(buffer)
   }
else
   {
      cout <<"Server did not send object, probably unknown!" << endl;
   } // if(!strcmp(recvchar,TGo4TaskHandler::fgcOK))
  fxTransport->Send(TGo4TaskHandler::fgcOK); // final OK
return obj;
}

void TGo4ObjClient::SendCommand(const Text_t* com)
{
   if (fxTransport) fxTransport->Send(com);
}


Int_t TGo4ObjClient::ConnectServer()
{

Text_t* recvchar=0;
Int_t openok=fxTransport->Open(GetHost(),GetPort());
if(openok!=0) return 1;
// send basename:
fxTransport->Send(GetBase());
recvchar=fxTransport->RecvRaw("dummy");
if(recvchar==0) return 1;
if(strcmp(recvchar,TGo4TaskHandler::fgcOK))
{
   TGo4Log::Debug(" Wrong basename for object server (host %s ,port %d)", GetHost(), GetPort());
   return 2;
}
// send password:
fxTransport->Send(GetPasswd());
recvchar=fxTransport->RecvRaw("dummy");
if(recvchar==0) return 1;
if(strcmp(recvchar,TGo4TaskHandler::fgcOK))
{
   TGo4Log::Debug(" Wrong password for object server (host %s ,port %d)", GetHost(), GetPort());
   return 4;
}
return 0;
}

Int_t TGo4ObjClient::DisconnectServer()
{
   fxTransport->Close();
return 0;
}

TBuffer* TGo4ObjClient::ReceiveBuffer()
{

TBuffer* rev=0;
Int_t state=fxTransport->ReceiveBuffer();
if(state>=0)
   {
      rev=const_cast<TBuffer*> (fxTransport->GetBuffer());
      // currently, we pass out the internal buffer of the TGo4Socket
      // maybe we have to put a queue of length 1 in between?
      //fxBufferQueue->AddBuffer(buf, kTRUE);
   } 
else
   {
      // error
      if (TGo4SocketSignalHandler::fgiLastSignal == SIGWINCH)
        {
            // TSocket error because of window resize, do not abort!
            TGo4Log::Debug(" %s: caught SIGWINCH ",GetName());
            TGo4SocketSignalHandler::fgiLastSignal = 0; // reset
            rev = 0;
         }
      else
         {
            TGo4Log::Debug(" !!!Receive Error in Object Client %s!!!",GetName());
            rev=0;  // here we might throw some exception later....
          } // end if (TGo4SocketSignalHandler::fgiLastSignal == SIGWINCH)
   } // end if(rev>=0)
return rev;
}

ClassImp(TGo4ObjClient)

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

---