EqRpc Class Reference

Inheritance diagram for EqRpc:

Collaboration diagram for EqRpc:

Public Member Functions
	EqRpc (const char *eqname, const char *eqfilename)
	~EqRpc ()
TMFeResult	HandleInit (const std::vector< std::string > &args)
TMFeResult	HandleRpc (const char *cmd, const char *args, std::string &response)
TMFeResult	HandleBinaryRpc (const char *cmd, const char *args, std::vector< char > &response)
TMFeResult	HandleBeginRun (int run_number)
TMFeResult	HandleEndRun (int run_number)
TMFeResult	HandlePauseRun (int run_number)
TMFeResult	HandleResumeRun (int run_number)
TMFeResult	HandleStartAbortRun (int run_number)
Public Member Functions inherited from TMFeEquipment
	TMFeEquipment (const char *eqname, const char *eqfilename)
virtual	~TMFeEquipment ()
TMFeResult	EqInit (const std::vector< std::string > &args)
	Initialize equipment.
TMFeResult	EqPreInit ()
	Initialize equipment, before EquipmentBase::Init()
TMFeResult	EqPostInit ()
	Initialize equipment, after EquipmentBase::Init()
TMFeResult	EqReadCommon ()
	Read TMFeEqInfo from ODB /Equipment/NAME/Common.
TMFeResult	EqWriteCommon (bool create=false)
	Write TMFeEqInfo to ODB /Equipment/NAME/Common.
virtual void	HandleUsage ()
virtual void	HandlePeriodic ()
virtual bool	HandlePoll ()
virtual void	HandlePollRead ()
void	EqPollThread ()
void	EqStartPollThread ()
void	EqStopPollThread ()
TMFeResult	ComposeEvent (char *pevent, size_t size) const
TMFeResult	BkInit (char *pevent, size_t size) const
void *	BkOpen (char *pevent, const char *bank_name, int bank_type) const
TMFeResult	BkClose (char *pevent, void *ptr) const
int	BkSize (const char *pevent) const
TMFeResult	EqSendEvent (const char *pevent, bool write_to_odb=true)
TMFeResult	EqSendEvent (const std::vector< char > &event, bool write_to_odb=true)
TMFeResult	EqSendEvent (const std::vector< std::vector< char > > &event, bool write_to_odb=true)
TMFeResult	EqSendEvent (int sg_n, const char *sg_ptr[], const size_t sg_len[], bool write_to_odb=true)
TMFeResult	EqWriteEventToOdb (const char *pevent)
TMFeResult	EqZeroStatistics ()
TMFeResult	EqWriteStatistics ()
TMFeResult	EqSetStatus (const char *status, const char *color)
	TMFeEquipment (TMFE *mfe, const char *name, TMFeCommon *common)
TMFeError	Init ()
	Initialize equipment.
TMFeError	SendData (const char *data, int size)
	...
TMFeError	ComposeEvent (char *pevent, int size)
TMFeError	BkInit (char *pevent, int size)
void *	BkOpen (char *pevent, const char *bank_name, int bank_type)
TMFeError	BkClose (char *pevent, void *ptr)
int	BkSize (const char *pevent)
TMFeError	SendEvent (const char *pevent)
TMFeError	ZeroStatistics ()
TMFeError	WriteStatistics ()
TMFeError	SetStatus (const char *status, const char *color)
Public Member Functions inherited from TMFeRpcHandlerInterface
virtual	~TMFeRpcHandlerInterface ()
virtual void	HandleBeginRun ()
virtual void	HandleEndRun ()
virtual void	HandlePauseRun ()
virtual void	HandleResumeRun ()
virtual void	HandleStartAbortRun ()
virtual std::string	HandleRpc (const char *cmd, const char *args)

Additional Inherited Members
Public Attributes inherited from TMFeEquipment
std::string	fEqName
std::string	fEqFilename
bool	fEqConfEnableRpc = true
bool	fEqConfEnablePeriodic = true
bool	fEqConfEnablePoll = false
bool	fEqConfReadConfigFromOdb = true
bool	fEqConfEnabled = true
uint16_t	fEqConfEventID = 1
uint16_t	fEqConfTriggerMask = 0
std::string	fEqConfBuffer = "SYSTEM"
int	fEqConfType = 0
int	fEqConfSource = 0
std::string	fEqConfFormat = "MIDAS"
int	fEqConfReadOn = 0
int	fEqConfPeriodMilliSec = 1000
double	fEqConfEventLimit = 0
uint32_t	fEqConfNumSubEvents = 0
int	fEqConfLogHistory = 0
bool	fEqConfHidden = false
int	fEqConfWriteCacheSize = 10000000
bool	fEqConfReadOnlyWhenRunning = true
bool	fEqConfWriteEventsToOdb = false
double	fEqConfPeriodStatisticsSec = 1.0
double	fEqConfPollSleepSec = 0.000100
size_t	fEqConfMaxEventSize = 0
size_t	fEqConfBufferSize = 0
std::mutex	fEqMutex
TMFE *	fMfe = NULL
TMFrontend *	fFe = NULL
MVOdb *	fOdbEq = NULL
	ODB Equipment/EQNAME.
MVOdb *	fOdbEqCommon = NULL
	ODB Equipment/EQNAME/Common.
MVOdb *	fOdbEqSettings = NULL
	ODB Equipment/EQNAME/Settings.
MVOdb *	fOdbEqVariables = NULL
	ODB Equipment/EQNAME/Variables.
MVOdb *	fOdbEqStatistics = NULL
	ODB Equipment/EQNAME/Statistics.
TMEventBuffer *	fEqEventBuffer = NULL
int	fEqSerial = 0
double	fEqStatEvents = 0
double	fEqStatBytes = 0
double	fEqStatEpS = 0
double	fEqStatKBpS = 0
double	fEqStatLastTime = 0
double	fEqStatLastEvents = 0
double	fEqStatLastBytes = 0
double	fEqStatLastWrite = 0
double	fEqStatNextWrite = 0
double	fEqPeriodicLastCallTime = 0
double	fEqPeriodicNextCallTime = 0
std::atomic_bool	fEqPollThreadStarting {false}
std::atomic_bool	fEqPollThreadRunning {false}
std::atomic_bool	fEqPollThreadShutdownRequested {false}
std::thread *	fEqPollThread = NULL
std::string	fName
TMFeCommon *	fCommon
int	fBufferHandle
int	fSerial
double	fStatEvents
double	fStatBytes
double	fStatEpS
double	fStatKBpS
double	fStatLastTime
double	fStatLastEvents
double	fStatLastBytes

Detailed Description

Definition at line 364 of file fetest.cxx.

Constructor & Destructor Documentation

EqRpc()

EqRpc::EqRpc ( const char *  eqname, const char *  eqfilename  )

inline

Definition at line 368 of file fetest.cxx.

      : TMFeEquipment(eqname, eqfilename)
   {
      fEqConfEventID = 1;
   }

~EqRpc()

EqRpc::~EqRpc ( )

inline

Definition at line 374 of file fetest.cxx.

   {
   }

Member Function Documentation

HandleBeginRun()

TMFeResult EqRpc::HandleBeginRun ( int  run_number )

inlinevirtual

Reimplemented from TMFeEquipment.

Definition at line 421 of file fetest.cxx.

   {
      fMfe->Msg(MINFO, "HandleBeginRun", "Begin run %d!", run_number);
      EqSetStatus("Running", "#00FF00");
      
      printf("begin_of_run %d\n", run_number);
      
      int fail = 0;
      fOdbEqSettings->RI("begin_of_run_fail", &fail, true);
      
      if (fail) {
         printf("fail_begin_of_run: returning error status %d\n", fail);
         return TMFeErrorMessage("begin of run failed by ODB setting!");
      }
      
      double s = 0;
      fOdbEqSettings->RD("begin_of_run_sleep_sec", &s, true);
      
      if (s) {
         fMfe->SetWatchdogSec(s + 1);
         int ms = int(s*1000.0);
         printf("sleep_begin_of_run: calling ss_sleep(%d)\n", ms);
         ss_sleep(ms);
      }
      
      return TMFeOk();
   }

Here is the call graph for this function:

HandleBinaryRpc()

TMFeResult EqRpc::HandleBinaryRpc ( const char *  cmd, const char *  args, std::vector< char > &  response  )

inlinevirtual

Reimplemented from TMFeEquipment.

Definition at line 403 of file fetest.cxx.

   {
      fMfe->Msg(MINFO, "HandleBinaryRpc", "Binary RPC cmd [%s], args [%s]", cmd, args);
 
      // RPC handler
      
      response.resize(8*64);
 
      uint64_t* p64 = (uint64_t*)response.data();
      uint64_t one = 1;
 
      for (size_t i=0; i<response.size()/sizeof(p64[0]); i++) {
         *p64++ = (one<<i);
      }
      
      return TMFeOk();
   }

Here is the call graph for this function:

HandleEndRun()

TMFeResult EqRpc::HandleEndRun ( int  run_number )

inlinevirtual

Reimplemented from TMFeEquipment.

Definition at line 449 of file fetest.cxx.

   {
      fMfe->Msg(MINFO, "HandleEndRun", "End run %d!", run_number);
      EqSetStatus("Stopped", "#00FF00");
 
      printf("end_of_run %d\n", run_number);
      
      int fail = 0;
      fOdbEqSettings->RI("end_of_run_fail", &fail, true);
      
      if (fail) {
         printf("fail_end_of_run: returning error status %d\n", fail);
         return TMFeResult(fail, "end of run failed by ODB setting!");
      }
      
      double s = 0;
      fOdbEqSettings->RD("end_of_run_sleep_sec", &s, true);
      
      if (s) {
         fMfe->SetWatchdogSec(s + 1);
         int ms = int(s*1000.0);
         printf("sleep_end_of_run: calling ss_sleep(%d)\n", ms);
         ss_sleep(ms);
      }
      
      return TMFeOk();
   }

Here is the call graph for this function:

HandleInit()

TMFeResult EqRpc::HandleInit ( const std::vector< std::string > &  args )

inlinevirtual

Reimplemented from TMFeEquipment.

Definition at line 378 of file fetest.cxx.

   {
      fEqConfBuffer = "SYSTEM";
      EqSetStatus("Started...", "white");
      fMfe->Msg(MINFO, "HandleInit", std::string("Init") + " Ok!");
      return TMFeOk();
   }

Here is the call graph for this function:

HandlePauseRun()

TMFeResult EqRpc::HandlePauseRun ( int  run_number )

inlinevirtual

Reimplemented from TMFeEquipment.

Definition at line 477 of file fetest.cxx.

   {
      fMfe->Msg(MINFO, "HandlePauseRun", "Pause run %d!", run_number);
      EqSetStatus("Stopped", "#00FF00");
 
      printf("pause_run %d\n", run_number);
 
      int fail = 0;
      fOdbEqSettings->RI("pause_run_fail", &fail, true);
      
      if (fail) {
         printf("fail_pause_run: returning error status %d\n", fail);
         return TMFeResult(fail, "pause run failed by ODB setting!");
      }
      
      return TMFeOk();
   }

Here is the call graph for this function:

HandleResumeRun()

TMFeResult EqRpc::HandleResumeRun ( int  run_number )

inlinevirtual

Reimplemented from TMFeEquipment.

Definition at line 495 of file fetest.cxx.

   {
      fMfe->Msg(MINFO, "HandleResumeRun", "Resume run %d!", run_number);
      EqSetStatus("Stopped", "#00FF00");
 
      printf("resume_run %d\n", run_number);
 
      int fail = 0;
      fOdbEqSettings->RI("resume_run_fail", &fail, true);
      
      if (fail) {
         printf("fail_resume_run: returning error status %d\n", fail);
         return TMFeResult(fail, "resume run failed by ODB setting!");
      }
      
      return TMFeOk();
   }

Here is the call graph for this function:

HandleRpc()

TMFeResult EqRpc::HandleRpc ( const char *  cmd, const char *  args, std::string &  response  )

inlinevirtual

Reimplemented from TMFeEquipment.

Definition at line 386 of file fetest.cxx.

   {
      fMfe->Msg(MINFO, "HandleRpc", "RPC cmd [%s], args [%s]", cmd, args);
 
      // RPC handler
      
      char tmp[256];
      time_t now = time(NULL);
      sprintf(tmp, "{ \"current_time\" : [ %d, \"%s\"] }", (int)now, ctime(&now));
      
      response = tmp;
 
      fMfe->Msg(MINFO, "HandleRpc", "RPC response [%s]", response.c_str());
 
      return TMFeOk();
   }

Here is the call graph for this function:

HandleStartAbortRun()

TMFeResult EqRpc::HandleStartAbortRun ( int  run_number )

inlinevirtual

Reimplemented from TMFeEquipment.

Definition at line 513 of file fetest.cxx.

   {
      fMfe->Msg(MINFO, "HandleStartAbortRun", "Begin run %d aborted!", run_number);
      EqSetStatus("Stopped", "#00FF00");
 
      printf("start abort run %d\n", run_number);
 
      int fail = 0;
      fOdbEqSettings->RI("start_abort_fail", &fail, true);
      
      if (fail) {
         printf("fail_start_abort: returning error status %d\n", fail);
         return TMFeResult(fail, "start abort failed by ODB setting!");
      }
      
      return TMFeOk();
   }

Here is the call graph for this function:

---

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

• progs/fetest.cxx