Myfe Class Reference

Inheritance diagram for Myfe:

Collaboration diagram for Myfe:

Public Member Functions
	Myfe (TMFE *mfe, TMFeEquipment *eq)
	~Myfe ()
void	Init ()
void	SendEvent (double dvalue)
std::string	HandleRpc (const char *cmd, const char *args)
void	HandleBeginRun ()
void	HandleEndRun ()
void	HandlePeriodic ()
	Myfe (TMFE *mfe, TMFeEquipment *eq)
	~Myfe ()
void	Init ()
void	SendEvent (double dvalue)
std::string	HandleRpc (const char *cmd, const char *args)
void	HandleBeginRun ()
void	HandleEndRun ()
void	HandlePeriodic ()
	Myfe (const char *eqname, const char *eqfilename)
	~Myfe ()
void	SendData (double dvalue)
TMFeResult	HandleRpc (const char *cmd, const char *args, std::string &response)
TMFeResult	HandleBeginRun (int run_number)
TMFeResult	HandleEndRun (int run_number)
void	HandlePeriodic ()
Public Member Functions inherited from TMFeRpcHandlerInterface
virtual TMFeResult	HandleBinaryRpc (const char *cmd, const char *args, std::vector< char > &result)
virtual void	HandlePauseRun ()
virtual void	HandleResumeRun ()
virtual void	HandleStartAbortRun ()
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 TMFeResult	HandleInit (const std::vector< std::string > &args)
virtual void	HandleUsage ()
virtual TMFeResult	HandlePauseRun (int run_number)
virtual TMFeResult	HandleResumeRun (int run_number)
virtual TMFeResult	HandleStartAbortRun (int run_number)
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 Attributes
TMFE *	fMfe
TMFeEquipment *	fEq
int	fEventSize
char *	fEventBuf
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 15 of file fetest_tmfe.cxx.

Constructor & Destructor Documentation

Myfe() [1/3]

Myfe::Myfe ( TMFE *  mfe, TMFeEquipment *  eq  )

inline

Definition at line 26 of file fetest_tmfe.cxx.

   {
      fMfe = mfe;
      fEq  = eq;
      fEventSize = 0;
      fEventBuf  = NULL;
   }

Here is the call graph for this function:

~Myfe() [1/3]

Myfe::~Myfe ( )

inline

Definition at line 34 of file fetest_tmfe.cxx.

   {
      if (fEventBuf) {
         free(fEventBuf);
         fEventBuf = NULL;
      }
   }

Here is the call graph for this function:

Myfe() [2/3]

Myfe::Myfe ( TMFE *  mfe, TMFeEquipment *  eq  )

inline

Definition at line 27 of file fetest_tmfe_thread.cxx.

   {
      fMfe = mfe;
      fEq  = eq;
      fEventSize = 0;
      fEventBuf  = NULL;
   }

Here is the call graph for this function:

~Myfe() [2/3]

Myfe::~Myfe ( )

inline

Definition at line 35 of file fetest_tmfe_thread.cxx.

   {
      if (fEventBuf) {
         free(fEventBuf);
         fEventBuf = NULL;
      }
   }

Here is the call graph for this function:

Myfe() [3/3]

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

inline

Definition at line 21 of file tmfe_example_multithread.cxx.

      : TMFeEquipment(eqname, eqfilename)
   {
   }

~Myfe() [3/3]

Myfe::~Myfe ( )

inline

Definition at line 26 of file tmfe_example_multithread.cxx.

   {
   }

Member Function Documentation

HandleBeginRun() [1/3]

void Myfe::HandleBeginRun ( )

inlinevirtual

Reimplemented from TMFeRpcHandlerInterface.

Definition at line 70 of file fetest_tmfe.cxx.

   {
      fMfe->Msg(MINFO, "HandleBeginRun", "Begin run!");
      fEq->SetStatus("Running", "#00FF00");
   }

Here is the call graph for this function:

HandleBeginRun() [2/3]

void Myfe::HandleBeginRun ( )

inlinevirtual

Reimplemented from TMFeRpcHandlerInterface.

Definition at line 71 of file fetest_tmfe_thread.cxx.

   {
      fMfe->Msg(MINFO, "HandleBeginRun", "Thread %s, Begin run!", TMFE::GetThreadId().c_str());
      fEq->SetStatus("Running", "#00FF00");
   }

Here is the call graph for this function:

HandleBeginRun() [3/3]

TMFeResult Myfe::HandleBeginRun ( int  run_number )

inlinevirtual

Reimplemented from TMFeRpcHandlerInterface.

Definition at line 49 of file tmfe_example_multithread.cxx.

   {
      fMfe->Msg(MINFO, "HandleBeginRun", "Thread %s, Begin run %d!", TMFE::GetThreadId().c_str(), run_number);
      EqSetStatus("Running", "#00FF00");
      return TMFeOk();
   }

Here is the call graph for this function:

HandleEndRun() [1/3]

void Myfe::HandleEndRun ( )

inlinevirtual

Reimplemented from TMFeRpcHandlerInterface.

Definition at line 76 of file fetest_tmfe.cxx.

   {
      fMfe->Msg(MINFO, "HandleEndRun", "End run!");
      fEq->SetStatus("Stopped", "#00FF00");
   }

Here is the call graph for this function:

HandleEndRun() [2/3]

void Myfe::HandleEndRun ( )

inlinevirtual

Reimplemented from TMFeRpcHandlerInterface.

Definition at line 77 of file fetest_tmfe_thread.cxx.

   {
      fMfe->Msg(MINFO, "HandleEndRun", "Thread %s, End run!", TMFE::GetThreadId().c_str());
      fEq->SetStatus("Stopped", "#00FF00");
   }

Here is the call graph for this function:

HandleEndRun() [3/3]

TMFeResult Myfe::HandleEndRun ( int  run_number )

inlinevirtual

Reimplemented from TMFeRpcHandlerInterface.

Definition at line 56 of file tmfe_example_multithread.cxx.

   {
      fMfe->Msg(MINFO, "HandleEndRun", "Thread %s, End run %d!", TMFE::GetThreadId().c_str(), run_number);
      EqSetStatus("Stopped", "#00FF00");
      return TMFeOk();
   }

Here is the call graph for this function:

HandlePeriodic() [1/3]

void Myfe::HandlePeriodic ( )

inlinevirtual

Implements TMFePeriodicHandlerInterface.

Definition at line 88 of file fetest_tmfe.cxx.

   {
      printf("periodic!\n");
      //char buf[256];
      //sprintf(buf, "buffered %d (max %d), dropped %d, unknown %d, max flushed %d", gUdpPacketBufSize, fMaxBuffered, fCountDroppedPackets, fCountUnknownPackets, fMaxFlushed);
      //fEq->SetStatus(buf, "#00FF00");
      //fEq->WriteStatistics();
   }

Here is the call graph for this function:

HandlePeriodic() [2/3]

void Myfe::HandlePeriodic ( )

inlinevirtual

Implements TMFePeriodicHandlerInterface.

Definition at line 83 of file fetest_tmfe_thread.cxx.

   {
      printf("Thread %s, periodic!\n", TMFE::GetThreadId().c_str());
      //char buf[256];
      //sprintf(buf, "buffered %d (max %d), dropped %d, unknown %d, max flushed %d", gUdpPacketBufSize, fMaxBuffered, fCountDroppedPackets, fCountUnknownPackets, fMaxFlushed);
      //fEq->SetStatus(buf, "#00FF00");
      //fEq->WriteStatistics();
   }

Here is the call graph for this function:

HandlePeriodic() [3/3]

void Myfe::HandlePeriodic ( )

inlinevirtual

Implements TMFePeriodicHandlerInterface.

Definition at line 70 of file tmfe_example_multithread.cxx.

   {
      printf("Thread %s, periodic!\n", TMFE::GetThreadId().c_str());
      double t = TMFE::GetTime();
      double data = 100.0*sin(M_PI/2.0+M_PI*t/60);
      SendData(data);
      fOdbEqVariables->WD("data", data);
      char status_buf[256];
      sprintf(status_buf, "value %.1f", data);
      EqSetStatus(status_buf, "#00FF00");
   }

Here is the call graph for this function:

HandleRpc() [1/3]

std::string Myfe::HandleRpc ( const char *  cmd, const char *  args  )

inlinevirtual

Reimplemented from TMFeRpcHandlerInterface.

Definition at line 64 of file fetest_tmfe.cxx.

   {
      fMfe->Msg(MINFO, "HandleRpc", "RPC cmd [%s], args [%s]", cmd, args);
      return "OK";
   }

Here is the call graph for this function:

HandleRpc() [2/3]

std::string Myfe::HandleRpc ( const char *  cmd, const char *  args  )

inlinevirtual

Reimplemented from TMFeRpcHandlerInterface.

Definition at line 65 of file fetest_tmfe_thread.cxx.

   {
      fMfe->Msg(MINFO, "HandleRpc", "Thread %s, RPC cmd [%s], args [%s]", TMFE::GetThreadId().c_str(), cmd, args);
      return "OK";
   }

Here is the call graph for this function:

HandleRpc() [3/3]

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

inlinevirtual

Reimplemented from TMFeRpcHandlerInterface.

Definition at line 43 of file tmfe_example_multithread.cxx.

   {
      fMfe->Msg(MINFO, "HandleRpc", "Thread %s, RPC cmd [%s], args [%s]", TMFE::GetThreadId().c_str(), cmd, args);
      return TMFeOk();
   }

Here is the call graph for this function:

Init() [1/2]

void Myfe::Init ( )

inline

Definition at line 42 of file fetest_tmfe.cxx.

   {
      fEventSize = 100;
      fEq->fOdbEqSettings->RI("event_size", &fEventSize, true);
      if (fEventBuf) {
         free(fEventBuf);
      }
      fEventBuf = (char*)malloc(fEventSize);
   }

Here is the call graph for this function:

Init() [2/2]

void Myfe::Init ( )

inline

Definition at line 43 of file fetest_tmfe_thread.cxx.

   {
      fEventSize = 100;
      fEq->fOdbEqSettings->RI("event_size", &fEventSize, true);
      if (fEventBuf) {
         free(fEventBuf);
      }
      fEventBuf = (char*)malloc(fEventSize);
   }

Here is the call graph for this function:

SendData()

void Myfe::SendData ( double  dvalue )

inline

Definition at line 30 of file tmfe_example_multithread.cxx.

   {
      char buf[1024];
      ComposeEvent(buf, sizeof(buf));
      BkInit(buf, sizeof(buf));
         
      double* ptr = (double*)BkOpen(buf, "test", TID_DOUBLE);
      *ptr++ = dvalue;
      BkClose(buf, ptr);
 
      EqSendEvent(buf);
   }

Here is the call graph for this function:

Here is the caller graph for this function:

SendEvent() [1/2]

void Myfe::SendEvent ( double  dvalue )

inline

Definition at line 52 of file fetest_tmfe.cxx.

   {
      fEq->ComposeEvent(fEventBuf, fEventSize);
      fEq->BkInit(fEventBuf, fEventSize);
         
      double* ptr = (double*)fEq->BkOpen(fEventBuf, "test", TID_DOUBLE);
      *ptr = dvalue;
      fEq->BkClose(fEventBuf, ptr+1);
 
      fEq->SendEvent(fEventBuf);
   }

Here is the call graph for this function:

SendEvent() [2/2]

void Myfe::SendEvent ( double  dvalue )

inline

Definition at line 53 of file fetest_tmfe_thread.cxx.

   {
      fEq->ComposeEvent(fEventBuf, fEventSize);
      fEq->BkInit(fEventBuf, fEventSize);
         
      double* ptr = (double*)fEq->BkOpen(fEventBuf, "test", TID_DOUBLE);
      *ptr = dvalue;
      fEq->BkClose(fEventBuf, ptr+1);
 
      fEq->SendEvent(fEventBuf);
   }

Here is the call graph for this function:

Member Data Documentation

fEq

TMFeEquipment * Myfe::fEq

Definition at line 21 of file fetest_tmfe.cxx.

fEventBuf

char * Myfe::fEventBuf

Definition at line 24 of file fetest_tmfe.cxx.

fEventSize

int Myfe::fEventSize

Definition at line 23 of file fetest_tmfe.cxx.

fMfe

TMFE * Myfe::fMfe

Definition at line 20 of file fetest_tmfe.cxx.

---

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

• progs/fetest_tmfe.cxx
• progs/fetest_tmfe_thread.cxx
• progs/tmfe_example_multithread.cxx