TFndRun Class Reference

Inheritance diagram for TFndRun:

List of all members.

Public Member Functions
	TFndRun (const TString &name="FINUDA_run_processor", const TString &title="The FINUDA run processor")
	~TFndRun ()
Int_t	InitNewRun (TString runtype="ONLM", const Int_t &runnum=-1, const Bool_t &UsedByPrean=kFALSE)
Bool_t	IsProcessing ()
Bool_t	IsNewRun ()
TFndFeeMap *	GetFeeMap ()
Int_t	CheckMsqlConnection ()
Int_t	ConnectToDB ()
Int_t	FetchDBinfo (Int_t source, Bool_t verbose=kFALSE)
Int_t	DisconnectFromDB ()
Int_t	FinishRun (Bool_t last=kFALSE, const Bool_t &UsedByPrean=kFALSE)
void	ClearEvent ()
Int_t	GetNofProcessedRuns ()
Int_t	GetNofProcessedEvents ()
UInt_t	GetEvNum_Raw ()
Int_t	GetDebug ()
UInt_t	GetDebugRawEv ()
void	ReadConfigFile (TString ConfFileName="RunConfig.C")
TFndRunConfiguration *	RunConfiguration ()
void	SetDBHost (const TString &dbhost)
TString	GetDBHost ()
TString	GetDataPath ()
void	SetDataPath (const TString &data_path)
TString	GetRunType (Int_t &run_type_id)
TString	GetRunType ()
Int_t	SetRunType (TString runtype)
void	SetRunType (Int_t runtype)
UInt_t	GetCurOnlineRunNmber ()
Int_t	GetRunNumber ()
void	SetRunNumber (Int_t run_num)
Int_t	GetMaxNumberOfEvents ()
void	SetMaxNumberOfEvents (Int_t max_evts)
Int_t	GetGebIP ()
void	SetGebIP (Int_t geb_ip)
void	SetDebugLevel (Int_t level)
void	SetDebugRawEv (UInt_t levels)
virtual Int_t	GetNextEvent (Bool_t fill_hdt=kTRUE)
virtual UInt_t *	GetNextRawEvent (Int_t &exit_value)
Int_t	ReadRawEvent (Bool_t using_db=kTRUE)
UInt_t *	GetCurrentRawEvent ()
virtual Int_t	ReconstructEvent ()
UInt_t	GetRunTime ()
void	SetRunTime (const UInt_t &rtim)
Int_t	Onlflg ()
TFndGtsMonFrame *	GtsMonFrame ()
TFndTofMonFrame *	TofMonFrame ()
TFndSilMonFrame *	SilMonFrame ()
TFndLmdMonFrame *	LmdMonFrame ()
TFndStbMonFrame *	StbMonFrame ()
TFndGtsMon *	GtsMon ()
TFndTofMon *	TofMon ()
TFndSilMon *	IsmMon ()
TFndSilMon *	OsmMon ()
TFndLmdMon *	LmdMon ()
TFndStbMon *	StbMon ()
TFndGenInfo *	GetGenInfo ()
void	SetMustFillMonitor (EFndMonDetectors det_id, const Bool_t &val)
void	FillMonitors ()
void	WriteMonitors (Bool_t close=kFALSE)
void	StartMonitors ()
void	StartGtsMonitor ()
void	StartGtsMonitor (TString *)
void	StartTofMonitor (Int_t adc_bins=-1, Float_t adc_min=-1., Float_t adc_max=-1., Int_t tdc_bins=-1, Float_t tdc_min=-1., Float_t tdc_max=-1.)
void	StartTofMonitor (TString *)
void	StartIsmMonitor ()
void	StartOsmMonitor ()
void	StartIsmMonitor (TString *)
void	StartOsmMonitor (TString *)
void	StartLmdMonitor (Int_t adc_bins=-1, Float_t adc_min=-1., Float_t adc_max=-1., Int_t tdc_bins=-1, Float_t tdc_min=-1., Float_t tdc_max=-1.)
void	StartLmdMonitor (TString *)
void	StartStbMonitor (Int_t tdc_bins=-1, Float_t tdc_min=-1., Float_t tdc_max=-1.)
void	StartStbMonitor (TString *)
TFndHdt *	GetCurrentHdt ()
TFndRdt *	GetCurrentRdt ()
Int_t	StartMonFrame (Int_t det, TString RootFileName=0, TString RootFileName2=0)
TFndMonFrame *	GetMonFrame (Int_t det)
Int_t	DeleteMonFrame (Int_t det)
void	SetProcessRec (TFndProcessRec *proc)
TFndProcessRec *	GetProcessRec ()
Int_t *	Zebra_LQ ()
Int_t *	Zebra_IQ ()
Float_t *	Zebra_Q ()
virtual void	OpenLogFile (const TString &fdir, const TString &fnam)
void	CloseLogFile ()
void	WriteLogFile (const TString &line)
void	SetHdt (TFndHdt *hdt)
void	SetfProcessing (const Bool_t &flg)
void	SetfOnlineFlag (const Int_t &flg)
void	SetfRunFileName (const TString &nam)
Static Public Attributes
static TFndHdt *	fgFinHdt
Protected Types
enum	{ k_MinRawFileSize = 1024 }
Protected Member Functions
virtual Long_t	OpenRawFile (TString fdir, TString fnam, Bool_t check_only=kFALSE)
	support for log messages
Int_t	Init ()
virtual void	CheckRawSwapping ()
void	CleanEvent ()
virtual Int_t	CreateSocketToDAQ (E_Fnd_DaqRaw_Udp_Ports det_port)
virtual Int_t	ShutdownSocketToDAQ ()
virtual Int_t	CheckSocketToDAQ ()
virtual Int_t	RecreateSocketToDAQ (E_Fnd_DaqRaw_Udp_Ports det_port=FIN_DAQ_RAW_UDP_PORT)
virtual UInt_t *	GetNextRawEventFromSocket (int &exit_val)
virtual UInt_t *	GetNextRawEventFromFile (int &exit_val)
Protected Attributes
Int_t	fDebug
UInt_t	fDebugRawEv
TFndRunConfiguration *	fRunConfiguration
TString	fDBHost
TFndFeeMap *	fFeeMap
TString	fDataPath
TString	fRunType
Int_t	fRunTypeID
Int_t	fRunNumber
TString	fRunFilename
TString	fMonHisFilename
Int_t	fGebIp
Int_t	fOnlineFlag
TString	fCurRunType
UInt_t	fCurRunNum
Bool_t	fIsNewRun
Bool_t	fProcessing
Int_t	fNumOfProcessedRuns
Int_t	fNumOfProcessedEvents
Int_t	fMaxNofEvents
Int_t	fMaxNofRuns
Int_t	fSockLength
sockaddr_in	fLocSockAddr
Int_t	fUdpSd
sockaddr_in	fShrSockAddr
Int_t	fShrSockAddr_size
Int_t	request_counter
FILE *	fRawFile
UInt_t	fRawEvent [FIN_RAW_DATA_BUF_SIZE]
	Raw file pointer /////////////////////////////.
UInt_t	fRunTime
TFndGenInfo *	fGenInfo
TFndGtsMonFrame *	fGtsMonFrame
TFndTofMonFrame *	fTofMonFrame
TFndSilMonFrame *	fSilMonFrame
TFndLmdMonFrame *	fLmdMonFrame
TFndStbMonFrame *	fStbMonFrame
Bool_t	fMustFillMonitor [D_STB+1]
TFndGtsMon *	fGtsMon
TFndTofMon *	fTofMon
TFndSilMon *	fIsmMon
TFndSilMon *	fOsmMon
TFndLmdMon *	fLmdMon
TFndStbMon *	fStbMon
TFndRdt *	fFinRdt
TFndHdt *	fFinHdt
TFndProcessRec *	fProcessRec
ofstream *	fCurLogFile

---

Detailed Description

Definition at line 53 of file TFndRun.h.

---

Member Enumeration Documentation

anonymous enum [protected]

Enumerator:

k_MinRawFileSize

Definition at line 55 of file TFndRun.h.

{ k_MinRawFileSize = 1024 }; // minimum file size requested (bytes)

---

Member Function Documentation

UInt_t * TFndRun::GetNextRawEventFromSocket

(

int &

exit_val

)

[protected, virtual]

--- CHECKS added (Feb 2007)

Reimplemented in TFndPreanMan.

Definition at line 582 of file TFndRun.cxx.

References CheckRawSwapping(), CheckSocketToDAQ(), fDebug, fRawEvent, fShrSockAddr, fShrSockAddr_size, fUdpSd, and request_counter.

Referenced by GetNextRawEvent().

                                                       {
  // get the next raw-event (from socket)
  // send the request
  // NOTE:
  //   A loop of requests is required, unless you are sure
  //   that the server is already running and witing for client requests
  //    "ioctl" is used to know if the request has been received by the server
  //
  // tested with simulated DAQ rate in the range [0.3 - 200] ev/s
  //
  // exit_val value: 
  //                0: ok
  //               -2: must re-create socket
  
  bzero(fRawEvent,sizeof(fRawEvent));
  //   char request_buf[100];
  //   sprintf(request_buf,"send me an event");

  Int_t request_buf=1;
  
  Int_t n_max_requests = 50; // after 50 requests recreate socket (was 10)
  
  int n_trials = 0;
  while(1){
    n_trials++; if(n_trials> n_max_requests){
      exit_val = -2;
      return 0;
    }
    request_counter++;
    //Info("GetNextRawEventFromSocket","sending request to the server (%d)",request_counter);
    //int send_err = sendto(fUdpSd,(char*)request_buf ,sizeof(request_buf) ,0 ,(struct sockaddr *) &fShrSockAddr,fShrSockAddr_size);
    int send_err = sendto(fUdpSd,(char*)&request_buf ,sizeof(Int_t) ,0 ,(struct sockaddr *) &fShrSockAddr,fShrSockAddr_size);    
    if(send_err==-1){
      Error("GetNextRawEventFromSocket","send-request operation failed!");
      sleep(1);
      continue;
    }

    int check_result=CheckSocketToDAQ(); // wait for answer
    // cout << "check_result: " << check_result << endl;
    if(check_result) break;
    else Info("GetNextRawEventFromSocket","...server not ready: trying again");
  }
  // the data fRawEvent is sent from the server to the "sockaddr_in" who sent the request (so it is used to receive)
  Int_t nread = recvfrom(fUdpSd ,(char*)fRawEvent ,sizeof(fRawEvent) ,0 ,(struct sockaddr*)&fShrSockAddr , (socklen_t *) &fShrSockAddr_size);

  if(fDebug > 0) printf("UDP fRawEvent received from server: nread = %d; event = \"%x\".\n",nread,fRawEvent);

  if(nread == -1){
    Error("GetNextRawEventFromSocket","nread = -1");
    exit_val = -2;
    return 0;
  }
  else if(nread == 0){
    Error("GetNextRawEventFromSocket","connection closed by GEB");
    exit_val = -2;
    return 0;
  }

  Int_t u_length = nread / sizeof(fRawEvent[0]);
  if( u_length >= sizeof(fRawEvent) ){
    Warning("GetNextRawEventFromSocket","received buffer size greater than local buf-size");
    exit_val = -2;
    return 0;
  }
  if( u_length != fRawEvent[0] ){
    Warning("GetNextRawEventFromSocket","received buffer size different from event size");    
    exit_val = -2;
    return 0;
  }

  if(fDebug > 0) if(u_length == fRawEvent[0]) Info("GetNextRawEventFromSocket","received event OK");
  // --- CHECKS completed

  if(fDebug > 1){
    for(unsigned int j=0; j<5; j++){
      if(fRawEvent[j] != 0) cout << "fRawEvent[" << j << "] = " << fRawEvent[j] << endl;
    }
  }
  else if(fDebug > 2){
    unsigned int len_test = fRawEvent[0];
    for(unsigned int j=0; j<len_test; j++){
      if(fRawEvent[j] != 0) cout << "fRawEvent[" << j << "] = " << fRawEvent[j] << endl;
    }
  }
 
  CheckRawSwapping();

  exit_val = 0;
  return fRawEvent;  
}

---

The documentation for this class was generated from the following files:

• STEER/TFndRun.h
• STEER/TFndRun.cxx

---