DesSer Class Reference

A class definition of an input module for Sequential ROOT I/O. More...

#include <DesSer.h>

Inheritance diagram for DesSer:

Collaboration diagram for DesSer:

Public Member Functions
	DesSer ()
	Constructor / Destructor.
void	initialize (bool close_listen=true)
virtual void	DataAcquisition ()=0
	Module functions to be called from event process.
void	printData (int *buf, int nwords)
	dump error data
int *	getPreAllocBuf ()
	Getbuffer.
int *	getNewBuffer (int nwords, int *delete_flag)
	Getbuffer.
double	getTimeSec ()
	store time info.
void	recordTime (int event, double *array)
	store time info.
unsigned int	calcSimpleChecksum (int *buf, int nwords)
	calculate checksum
unsigned int	calcXORChecksum (int *buf, int nwords)
	calculate checksum
void	clearNumUsedBuf ()
void	RateMonitor (unsigned int nevt)
	monitor rate
void	shmOpen (char *path_cfg, char *path_sta)
	open shared memory
int *	shmGet (int fd, int size_words)
	Get shared memory.
void	initializeNode ()
	Module functions to be called from main process.
void	beginRun ()
	Module functions to be called from event process.
void	endRun ()
void	terminate ()
int	sendByWriteV (RawDataBlockFormat *rawdblk)
void	Accept (bool close_listen=true)
void	fillSendHeaderTrailer (SendHeader *hdr, SendTrailer *trl, RawDataBlockFormat *rawdblk)
int	Send (int socket, char *buf, int size_bytes)
	send buffer

Public Attributes
int	max_nevt
double	max_seconds
	time to stop a run
int	m_compressionLevel
	Compression Level.
int	n_basf2evt
	No. of sent events.
int	m_prev_nevt
	No. of prev sent events.
std::string	m_dump_fname
	dump filename
FILE *	m_fp_dump
	dump file descripter
int *	m_buffer
	buffer
int *	m_bufary [NUM_PREALLOC_BUF]
	buffer
timeval	m_t0
double	m_recvd_totbytes
double	m_recvd_prev_totbytes
double	m_sent_totbytes
double	m_sent_prev_totbytes
int	m_ncycle
double	cur_time
	for time monitoring
double	m_start_time
double	m_prev_time
int	prev_event
int	m_num_usedbuf
std::string	m_nodename
	Node Name for SLC.
int	m_nodeid
	Node ID for SLC.
RunInfoBuffer	m_status
	Run info buffer.
unsigned int	m_exprunsubrun_no
	run no.
unsigned int	m_prev_exprunsubrun_no
	run no.
int	m_exp_no
	exp no.
int	m_data_type
	data type
int	m_trunc_mask
	trunc mask
int	m_shmflag
	Use shared memory.
int	m_shmfd_cfg
	file descripter for shm
int	m_shmfd_sta
	file descripter for shm
int	monitor_numeve
	buffer for shared memory More...
int	m_start_flag
	start flag
CprErrorMessage	print_err
	wrapper for B2LOG system
PreRawCOPPERFormat_v2	m_pre_rawcpr
	report status to SLC More...
int *	m_cfg_buf
	buffer for shared memory
int *	m_cfg_sta
	buffer for shared memory
int	m_run_pause
	flag to show that run-controller pauses a run
int	m_run_error
	flag to show that there is some errors with which DAQ cannot continue.

Protected Types
enum	{   COPPER = 1 ,   ROPC = 2 }

Protected Attributes
int	m_num_connections
	check data contents More...
std::vector< std::string >	m_hostname_from
	Reciever basf2 Socket. More...
std::vector< int >	m_port_from
	port # to connect data sources
std::vector< int >	m_socket_recv
int	event_diff
unsigned int	m_prev_copper_ctr
unsigned int	m_prev_evenum
int	m_socket_send
	Reciever Socket.
std::string	m_hostname_local
	Destination Host.
int	m_port_to
	Destination port.
std::string	p_method
	EvtSocket. More...
int	p_method_val
RawHeader_v2	tmp_header
	which format is used

Detailed Description

A class definition of an input module for Sequential ROOT I/O.

Definition at line 41 of file DesSer.h.

Member Data Documentation

m_hostname_from

std::vector<std::string> m_hostname_from

protected

Reciever basf2 Socket.

hostname of upstream Data Sources

Definition at line 243 of file DesSer.h.

m_num_connections

int m_num_connections

protected

check data contents

of connections

Definition at line 237 of file DesSer.h.

m_num_usedbuf

int m_num_usedbuf

of already used buffers

Definition at line 132 of file DesSer.h.

m_pre_rawcpr

PreRawCOPPERFormat_v2 m_pre_rawcpr

report status to SLC

Use ver.2 for the moment(ver.4 -> PCI40)

Definition at line 191 of file DesSer.h.

max_nevt

int max_nevt

of events in a run

Definition at line 61 of file DesSer.h.

monitor_numeve

int monitor_numeve

buffer for shared memory

buffer for shared memory

Definition at line 178 of file DesSer.h.

p_method

std::string p_method

protected

EvtSocket.

How to handle data

Definition at line 284 of file DesSer.h.

---

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

• daq/rawdata/include/DesSer.h
• daq/rawdata/src/DesSer.cc