RFFlowStat Class Reference

Collaboration diagram for RFFlowStat:

Public Member Functions
	RFFlowStat (const char *shmname, int id, RingBuffer *rbuf)
	RFFlowStat (const char *shmname)
void	log (int size)
void	clear (int id)
RfShm_Cell &	getinfo (int id)
void	fillNodeInfo (int id, RfNodeInfo *info, bool inout)
void	fillProcessStatus (RfNodeInfo *info, int pid_input=0, int pid_output=0, int pid_basf2=0, int pid_hserver=0, int pid_hrelay=0)

Private Attributes
RFSharedMem *	m_rfshm
RfShm_Cell *	m_cell
RingBuffer *	m_rbuf
float	m_flowsize
int	m_nevtint
int	m_interval
struct timeval	m_t0

Detailed Description

Definition at line 27 of file RFFlowStat.h.

Constructor & Destructor Documentation

RFFlowStat() [1/2]

RFFlowStat	(	const char *	shmname,
		int	id,
		RingBuffer *	rbuf
	)

Definition at line 15 of file RFFlowStat.cc.

{
  m_rfshm = new RFSharedMem(shmname);
  m_cell = &(m_rfshm->GetCell(id));
  m_rbuf = rbuf;
  m_flowsize = 0.0;
  m_nevtint = 0;
  m_interval = 100;
  gettimeofday(&m_t0, 0);
}

RFFlowStat() [2/2]

RFFlowStat

(

const char *

shmname

)

Definition at line 26 of file RFFlowStat.cc.

{
  m_rfshm = new RFSharedMem(shmname);
}

~RFFlowStat()

~RFFlowStat

(

)

Definition at line 31 of file RFFlowStat.cc.

{
}

Member Function Documentation

clear()

void clear

(

int

id

)

Definition at line 61 of file RFFlowStat.cc.

{
  RfShm_Cell& cell = getinfo(cellid);
  cell.nevent = 0;
  cell.nqueue = 0;
  cell.flowrate = 0;
  cell.avesize = 0;
  cell.evtrate = 0;
  cell.elapsed = 0;
}

fillNodeInfo()

void fillNodeInfo	(	int	id,
		RfNodeInfo *	info,
		bool	inout
	)

Definition at line 78 of file RFFlowStat.cc.

{
  const RfShm_Cell& cell = getinfo(id);
  //DEBUG  printf ( "fillNodeInfo: celleid = %d, nevent = %d\n", id, cell.nevent );
  if (!outflag) {
    info->nevent_in = cell.nevent;
    info->nqueue_in = cell.nqueue;
    info->flowrate_in = cell.flowrate;
    info->avesize_in = cell.avesize;
    info->evtrate_in = cell.evtrate;
  } else {
    info->nevent_out = cell.nevent;
    info->nqueue_out = cell.nqueue;
    info->flowrate_out = cell.flowrate;
    info->avesize_out = cell.avesize;
    info->evtrate_out = cell.evtrate;
  }
  double loads[3];
  if (getloadavg(loads, 3) > 0)
    info->loadave = (float)loads[0];
 
  /* Test
  info->nevent_in = 99999;
  info->nqueue_in = 123;
  info->flowrate_in = 10.0;
  info->avesize_in = 100.0;
  info->evtrate_in = 1000.0;
  */
 
}

fillProcessStatus()

void fillProcessStatus	(	RfNodeInfo *	info,
		int	pid_input = 0,
		int	pid_output = 0,
		int	pid_basf2 = 0,
		int	pid_hserver = 0,
		int	pid_hrelay = 0
	)

Definition at line 109 of file RFFlowStat.cc.

{
  info->pid_input = input;
  info->pid_output = output;
  info->pid_basf2 = basf2;
  info->pid_hserver = hserver;
  info->pid_hrelay = hrelay;
}

getinfo()

RfShm_Cell & getinfo

(

int

id

)

Definition at line 73 of file RFFlowStat.cc.

{
  return m_rfshm->GetCell(id);
}

log()

void log

(

int

size

)

Definition at line 36 of file RFFlowStat.cc.

{
  struct timeval tnow;
 
  m_cell->nevent++;
  if (m_rbuf != NULL)
    m_cell->nqueue = m_rbuf->numq();
  else
    m_cell->nqueue = 0;
  m_flowsize += (float)size;
  m_nevtint++;
  if (m_cell->nevent % m_interval == 0) {
    gettimeofday(&tnow, 0);
    float delta = (float)((tnow.tv_sec - m_t0.tv_sec) * 1000000 +
                          (tnow.tv_usec - m_t0.tv_usec));
    m_cell->flowrate = m_flowsize / delta;
    //    m_cell->flowrate = delta;
    m_cell->avesize = m_flowsize / (float)m_nevtint / 1000.0;
    m_cell->evtrate = (float)m_nevtint / delta * 1000000.0;
    m_cell->elapsed = time(NULL);
    m_flowsize = 0.0;
    m_nevtint = 0;
    m_t0 = tnow;
  }
}

Member Data Documentation

m_cell

RfShm_Cell* m_cell

private

Definition at line 46 of file RFFlowStat.h.

m_flowsize

float m_flowsize

private

Definition at line 48 of file RFFlowStat.h.

m_interval

int m_interval

private

Definition at line 50 of file RFFlowStat.h.

m_nevtint

int m_nevtint

private

Definition at line 49 of file RFFlowStat.h.

m_rbuf

RingBuffer* m_rbuf

private

Definition at line 47 of file RFFlowStat.h.

m_rfshm

RFSharedMem* m_rfshm

private

Definition at line 45 of file RFFlowStat.h.

m_t0

struct timeval m_t0

private

Definition at line 51 of file RFFlowStat.h.

---

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

• daq/rfarm/manager/include/RFFlowStat.h
• daq/rfarm/manager/src/RFFlowStat.cc