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

#include <DesSerCOPPER.h>

Inheritance diagram for DesSerCOPPER:

Collaboration diagram for DesSerCOPPER:

[legend]

Public Member Functions
	DesSerCOPPER (std::string host_recv, int port_recv, const std::string &host_send, int port_send, int shmflag, const std::string &nodename, int nodeid, int finesse_bitflag)
	Constructor / Destructor.

void	DataAcquisition () override
	Module functions to be called from event process.

int *	readOneEventFromCOPPERFIFO (const int entry, int delete_flag, int m_size_word)
	Read one event from COPPER.

void	openCOPPER ()
	open COPPER

void	initializeCOPPER ()
	Module functions to be called from main process.

int	readFD (int fd, char *buf, int data_size_byte, int delete_flag)
	receive data

void	initialize (bool close_listen=true)

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	m_cpr_fd
	file descripter for COPPER

int	m_use_slot
	bit flag of FINESSE slots to use

int	m_finesse_bit_flag
	bit flag of FINESSE slots to use

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 27 of file DesSerCOPPER.h.

Member Data Documentation

◆ m_hostname_from

std::vector<std::string> m_hostname_from

protectedinherited

Reciever basf2 Socket.

hostname of upstream Data Sources

Definition at line 243 of file DesSer.h.

◆ m_num_connections

int m_num_connections

protectedinherited

check data contents

of connections

Definition at line 237 of file DesSer.h.

◆ m_num_usedbuf

int m_num_usedbuf

inherited

of already used buffers

Definition at line 132 of file DesSer.h.

◆ m_pre_rawcpr

PreRawCOPPERFormat_v2 m_pre_rawcpr

inherited

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

inherited

of events in a run

Definition at line 61 of file DesSer.h.

◆ monitor_numeve

int monitor_numeve

inherited

buffer for shared memory

Definition at line 178 of file DesSer.h.

◆ p_method

std::string p_method

protectedinherited

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/DesSerCOPPER.h
daq/rawdata/src/DesSerCOPPER.cc

Public Member Functions

Public Attributes

Protected Types

Protected Attributes

Detailed Description

Member Data Documentation

◆ m_hostname_from

◆ m_num_connections

of connections

◆ m_num_usedbuf

of already used buffers

◆ m_pre_rawcpr

◆ max_nevt

of events in a run

◆ monitor_numeve

◆ p_method