---

/Go4ExampleUserSource/TYYYEventSource.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 "TYYYEventSource.h"

#include <iostream.h>

#include "Go4Event/TGo4EventErrorException.h"
#include "Go4Event/TGo4EventTimeoutException.h"
#include "Go4EventServer/TGo4UserSourceParameter.h"
#include "TYYYRawEvent.h"

TYYYEventSource::TYYYEventSource(const Text_t * name,
                                    const Text_t * args, Int_t port)
: TGo4EventSource(name),
 fbIsOpen(kFALSE), fxArgs(args), fiPort(port), fxFile(0)
{
   Open();
}

TYYYEventSource::TYYYEventSource(TGo4UserSourceParameter* par)
: TGo4EventSource(" "),
fbIsOpen(kFALSE), fxArgs(" "), fiPort(0),fxFile(0)
{
   if(par)
      {
        SetName(par->GetName());
        SetPort(par->GetPort());
        SetArgs(par->GetExpression());
        Open();
      }
   else
      {
        cout <<"TYYYEventSource constructor with zero parameter!" << endl;
      }
}



TYYYEventSource::TYYYEventSource()
: TGo4EventSource("default YYY source"),
   fbIsOpen(kFALSE), fxArgs(" "), fiPort(0),fxFile(0)
{

}

TYYYEventSource::~TYYYEventSource()
{
   Close();
}

void TYYYEventSource::BuildYYYEvent(TYYYRawEvent* target)
{
   Int_t status=1;
   // process on event information in our buffer
   // scan the last input line for values:
   Text_t buffer[TGo4EventSource::fguTXTLEN];
   Int_t scanresult=0;
   Int_t numval=0;
   const char* cursor = fxNextline.Data();
   do{
      target->ReAllocate(numval+1); // check if realloc necessary
      scanresult=sscanf(cursor,"%s",buffer);
      //cout <<"BuildYYYEvent got buffer:"<<buffer<<", scanresult:";
      //cout << scanresult << endl;
      if(scanresult!=0 && scanresult!=-1)
         {
           target->fdData[numval]=atof(buffer);
           //cout <<"filled data:"<<target->fdData[numval] << endl;
            status=0; // only ok if at least one value scanned
         }
      numval++;
      cursor+=strlen(buffer)+1;
      //cout <<"cursor set to:"<<cursor << endl;
   } while( scanresult!=0 && scanresult!=-1);



   // test here for error in input event

   if(status==0)
      {
      target->SetValid(kTRUE); // reset target if previously was set to false
      // here build event from source!
      }
   else
      {
         target->SetValid(kFALSE);
         // somethings wrong, display error message from f_evt_error()
            SetErrMess("YYY Event Source --  ERROR !!!");
            throw TGo4EventErrorException(this);
      }
}

Int_t TYYYEventSource::NextEvent()
{
// read another event from open file into our buffer
do{
        fxFile->getline(const_cast<Text_t*>(fxNextline.Data()),
                        TGo4EventSource::fguTXTLEN,
                        '\n' ); // read whole line
        if(fxFile->eof() || !fxFile->good())
          {
              // reached last line or read error?
              SetCreateStatus(1);
              Text_t buffer[TGo4EventSource::fguTXTLEN];
              snprintf(buffer,TGo4EventSource::fguTXTLEN,
                  "End of input file %s", GetName());
              SetErrMess(buffer);
              throw TGo4EventErrorException(this);
          }
      //cout <<"read line:"<<fxNextline.Data() << endl;
}while(strstr(fxNextline.Data(),"#") || strstr(fxNextline.Data(),"!") ); // skip any comments

return 0;
}

Int_t TYYYEventSource::Open()
{
if(fbIsOpen)
   return -1;
cout << "Open of TYYYEventSource"<< endl;
// open connection/file
fxNextline.Capacity(TGo4EventSource::fguTXTLEN);
Int_t status=0; // openstatus of source
fxFile=new std::ifstream(GetName());
if(fxFile==0)
   {
      status=1;
      SetCreateStatus(status);
      Text_t buffer[TGo4EventSource::fguTXTLEN];
      snprintf(buffer,TGo4EventSource::fguTXTLEN,
               "Eror opening user file:%s",GetName());
      SetErrMess(buffer);
      throw TGo4EventErrorException(this);
   }
fbIsOpen=kTRUE;
return status;
}

Int_t TYYYEventSource::Close()
{
if(!fbIsOpen)
   return -1;

cout << "Close of TYYYEventSource"<< endl;
Int_t status=0; // closestatus of source
delete fxFile;
fbIsOpen=kFALSE;
return status;

}
ClassImp(TYYYEventSource)




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

---