#include <poll.h>
#include <sys/time.h>
#include <sys/epoll.h>
#include <netinet/tcp.h>
#include <cstring>
#include <cstdarg>
#include <list>
#include <queue>
#include <boost/algorithm/string/join.hpp>
#include "../externals/Queue.h"
#include "MessageImp.h"
#include "EventBuilder.h"
#include "HeadersFAD.h"

Include dependency graph for EventBuilder.cc:

Classes
struct	READ_STRUCT

Namespaces
	Memory

Macros
#define	MIN_LEN 32

#define	MAX_LEN 81920

Functions
bool	runOpen (const EVT_CTRL2 &evt)

bool	runWrite (const EVT_CTRL2 &evt)

void	runClose (const EVT_CTRL2 &run)

void	applyCalib (const EVT_CTRL2 &evt, const size_t &size)

void	factOut (int severity, const char *message)

void	factReportIncomplete (uint64_t rep)

void	gotNewRun (RUN_CTRL2 &run)

void	runFinished ()

void	factStat (const GUI_STAT &gj)

bool	eventCheck (const EVT_CTRL2 &evt)

void	debugHead (void *buf)

void *	Memory::malloc ()

void	Memory::free (void *mem)

void	factPrintf (int severity, const char *fmt,...)

bool	checkRoiConsistency (const READ_STRUCT &rd, uint16_t roi[])

shared_ptr< EVT_CTRL2 >	mBufEvt (const READ_STRUCT &rd, shared_ptr< RUN_CTRL2 > &actrun)

void	copyData (const READ_STRUCT &rBuf, EVT_CTRL2 *evt)

uint64_t	reportIncomplete (const shared_ptr< EVT_CTRL2 > &evt, const char *txt)

bool	proc1 (const shared_ptr< EVT_CTRL2 > &)

bool	writeEvt (const shared_ptr< EVT_CTRL2 > &evt)

bool	procEvt (const shared_ptr< EVT_CTRL2 > &evt)

void	CloseRunFile ()

bool	mainloop (READ_STRUCT *rd)

void	StartEvtBuild ()

Variables
int	g_reset

size_t	g_maxMem

uint16_t	g_evtTimeout

FACT_SOCK	g_port [NBOARDS]

uint	gi_NumConnect [NBOARDS]

GUI_STAT	gj

uint64_t	Memory::inuse = 0

uint64_t	Memory::allocated = 0

uint64_t	Memory::max_inuse = 0

std::mutex	Memory::mtx

std::forward_list< void * >	Memory::memory

list< shared_ptr< EVT_CTRL2 > >	evtCtrl

Queue< shared_ptr< EVT_CTRL2 > >	processingQueue1 (bind(&proc1, placeholders::_1))

Queue< shared_ptr< EVT_CTRL2 > >	secondaryQueue (bind(&writeEvt, placeholders::_1))

Queue< shared_ptr< EVT_CTRL2 > >	primaryQueue (bind(&procEvt, placeholders::_1))

shared_ptr< RUN_CTRL2 >	actrun

Classes

Namespaces

Macros

Functions

Variables