Inheritance diagram for ERecoEventSampler:

Collaboration diagram for ERecoEventSampler:

[legend]

Public Member Functions
	ERecoEventSampler (std::string conffile)

int	Configure (NSMmsg , NSMcontext ) override

int	UnConfigure (NSMmsg , NSMcontext ) override

int	Start (NSMmsg , NSMcontext ) override

int	Stop (NSMmsg , NSMcontext ) override

int	Restart (NSMmsg , NSMcontext ) override

void	server ()

virtual int	Pause (NSMmsg , NSMcontext )

virtual int	Resume (NSMmsg , NSMcontext )

virtual int	Status (NSMmsg , NSMcontext )

virtual void	SetNodeInfo (RfNodeInfo *ptr)

virtual RfNodeInfo *	GetNodeInfo ()

Static Public Attributes
static RFServerBase *	s_instance

Private Attributes
RFConf *	m_conf

std::string	m_conffile

RFProcessManager *	m_proc

RFLogManager *	m_log

RingBuffer *	m_rbufout

int	m_pid_sampler

int	m_pid_server

RfNodeInfo *	m_nsmmem

Detailed Description

Definition at line 29 of file ERecoEventSampler.h.

Constructor & Destructor Documentation

◆ ERecoEventSampler()

ERecoEventSampler ( std::string conffile )

Definition at line 24 of file ERecoEventSampler.cc.

{
 
  // 0. Initialize configuration manager
  m_conffile = conffile;
  m_conf = new RFConf(conffile.c_str());
  char* nodename = m_conf->getconf("eventsampler", "nodename");
 
  // 1. Set execution directory
  string execdir = string(m_conf->getconf("system", "execdir_base")) + "/sampler";
 
  mkdir(execdir.c_str(), 0755);
  chdir(execdir.c_str());
 
  // 2. Initialize RingBuffers
  char* rbufout = m_conf->getconf("eventsampler", "ringbufout");
  int rbufsize = m_conf->getconfi("eventsampler", "ringbufoutsize");
  m_rbufout = new RingBuffer(rbufout, rbufsize);
 
  // 3. Initialize process manager
  m_proc = new RFProcessManager(nodename);
 
  // 4. Initialize LogManager
  m_log = new RFLogManager(nodename, m_conf->getconf("system", "lognode"));
 
  m_pid_sampler = 0;
 
}

◆ ~ERecoEventSampler()

~ERecoEventSampler ( )

Definition at line 53 of file ERecoEventSampler.cc.

{
  delete m_log;
  delete m_proc;
  delete m_conf;
  delete m_rbufout;
}

Member Function Documentation

◆ Configure()

int Configure	(	NSMmsg *	,
		NSMcontext *	)

overridevirtual

Reimplemented from RFServerBase.

Definition at line 64 of file ERecoEventSampler.cc.

{
 
  /*
  // 1. Run EventSampler
  char* sampler = m_conf->getconf("eventsampler", "script");
  m_pid_sampler = m_proc->Execute(sampler, (char*)m_conffile.c_str());
  */
 
  /* Public event server moved outside
  // 2. Run EventServer
  char* server = m_conf->getconf("eventsampler", "server", "script");
  char* rbuf = m_conf->getconf("eventsampler", "ringbufout");
  char* port = m_conf->getconf("eventsampler", "server", "port");
  m_pid_server = m_proc->Execute(server, rbuf, port);
  */
 
  printf("ERecoEventSampler : Configure done\n");
  return 0;
}

◆ GetNodeInfo()

virtual RfNodeInfo * GetNodeInfo ( )

inlinevirtualinherited

Definition at line 38 of file RFServerBase.h.

    {
      return m_nsmmem;
    };

◆ Pause()

virtual int Pause	(	NSMmsg *	,
		NSMcontext *	)

inlinevirtualinherited

Definition at line 28 of file RFServerBase.h.

28{ return 0; };

◆ Restart()

int Restart	(	NSMmsg *	,
		NSMcontext *	)

overridevirtual

Reimplemented from RFServerBase.

Definition at line 145 of file ERecoEventSampler.cc.

{
  return 0;
}

◆ Resume()

virtual int Resume	(	NSMmsg *	,
		NSMcontext *	)

inlinevirtualinherited

Definition at line 29 of file RFServerBase.h.

29{ return 0; };

◆ server()

void server ( )

Definition at line 152 of file ERecoEventSampler.cc.

{
  while (true) {
    pid_t pid = m_proc->CheckProcess();
    if (pid > 0) {
      if (pid == m_pid_sampler)
        printf("ERecoEventSampler : eventsampler process dead. pid = %d\n", pid);
      else
        printf("ERecoEventSampler : unknown process dead. pid = %d\n", pid);
    }
 
    int st = m_proc->CheckOutput();
    if (st < 0) {
      perror("ERecoEventSampler::server");
      //      exit ( -1 );
    } else if (st > 0) {
      m_log->ProcessLog(m_proc->GetFd());
    }
  }
}

◆ SetNodeInfo()

virtual void SetNodeInfo ( RfNodeInfo * ptr )

inlinevirtualinherited

Definition at line 33 of file RFServerBase.h.

    {
      m_nsmmem = ptr;
    };

◆ Start()

int Start	(	NSMmsg *	,
		NSMcontext *	)

overridevirtual

Reimplemented from RFServerBase.

Definition at line 108 of file ERecoEventSampler.cc.

{
  // 1. Run EventSampler
  char* sampler = m_conf->getconf("eventsampler", "script");
  m_pid_sampler = m_proc->Execute(sampler, (char*)m_conffile.c_str());
 
  /* Public event server moved outside
  // 2. Run EventServer
  char* server = m_conf->getconf("eventsampler", "server", "script");
  char* rbuf = m_conf->getconf("eventsampler", "ringbufout");
  char* port = m_conf->getconf("eventsampler", "server", "port");
  m_pid_server = m_proc->Execute(server, rbuf, port);
  */
 
  printf("ERecoEventSampler : Configure done\n");
 
 
  //  m_rbufin->clear();
  return 0;
}

◆ Status()

virtual int Status	(	NSMmsg *	,
		NSMcontext *	)

inlinevirtualinherited

Definition at line 31 of file RFServerBase.h.

31{ return 0; };

◆ Stop()

int Stop	(	NSMmsg *	,
		NSMcontext *	)

overridevirtual

Reimplemented from RFServerBase.

Definition at line 129 of file ERecoEventSampler.cc.

{
  int status;
  printf("ERecoEventSampler: Unconfigure pids = %d %d\n", m_pid_sampler, m_pid_server);
  fflush(stdout);
  if (m_pid_sampler != 0) {
    kill(m_pid_sampler, SIGINT);
    waitpid(m_pid_sampler, &status, 0);
    m_pid_sampler = 0;
  }
 
//  m_rbufin->clear();
  return 0;
}

◆ UnConfigure()

int UnConfigure	(	NSMmsg *	,
		NSMcontext *	)

overridevirtual

Reimplemented from RFServerBase.

Definition at line 85 of file ERecoEventSampler.cc.

{
  /*
  int status;
  printf("ERecoEventSampler: Unconfigure pids = %d %d\n", m_pid_sampler, m_pid_server);
  fflush(stdout);
  if (m_pid_sampler != 0) {
    kill(m_pid_sampler, SIGINT);
    waitpid(m_pid_sampler, &status, 0);
    m_pid_sampler = 0;
  }
  */
  /*
  if (m_pid_server != 0) {
    kill(m_pid_server, SIGINT);
    waitpid(m_pid_server, &status, 0);
    m_pid_server = 0;
  }
  */
  printf("ERecoEventSampler : Unconfigure done\n");
  return 0;
}

Member Data Documentation

◆ m_conf

RFConf* m_conf

private

Definition at line 45 of file ERecoEventSampler.h.

◆ m_conffile

std::string m_conffile

private

Definition at line 46 of file ERecoEventSampler.h.

◆ m_log

RFLogManager* m_log

private

Definition at line 48 of file ERecoEventSampler.h.

◆ m_nsmmem

RfNodeInfo* m_nsmmem

privateinherited

Definition at line 47 of file RFServerBase.h.

◆ m_pid_sampler

int m_pid_sampler

private

Definition at line 51 of file ERecoEventSampler.h.

◆ m_pid_server

int m_pid_server

private

Definition at line 52 of file ERecoEventSampler.h.

◆ m_proc

RFProcessManager* m_proc

private

Definition at line 47 of file ERecoEventSampler.h.

◆ m_rbufout

RingBuffer* m_rbufout

private

Definition at line 49 of file ERecoEventSampler.h.

◆ s_instance

RFServerBase* s_instance

staticinherited

Definition at line 44 of file RFServerBase.h.

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

daq/expreco/include/ERecoEventSampler.h
daq/expreco/src/ERecoEventSampler.cc

Public Member Functions

Static Public Attributes

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ ERecoEventSampler()

◆ ~ERecoEventSampler()

Member Function Documentation

◆ Configure()

◆ GetNodeInfo()

◆ Pause()

◆ Restart()

◆ Resume()

◆ server()

◆ SetNodeInfo()

◆ Start()

◆ Status()

◆ Stop()

◆ UnConfigure()

Member Data Documentation

◆ m_conf

◆ m_conffile

◆ m_log

◆ m_nsmmem

◆ m_pid_sampler

◆ m_pid_server

◆ m_proc

◆ m_rbufout

◆ s_instance