ERecoEventSampler Class Reference

Inheritance diagram for ERecoEventSampler:

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.

{ 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.

{ 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.

{ 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