DesSer Class Reference

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

#include <DesSer.h>

Inheritance 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
int	m_start_flag
	start flag
CprErrorMessage	print_err
	wrapper for B2LOG system
PreRawCOPPERFormat_v2	m_pre_rawcpr
	report status to SLC
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
std::vector< std::string >	m_hostname_from
	Reciever basf2 Socket.
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.
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 Enumeration Documentation

anonymous enum

anonymous enum

protected

Definition at line 269 of file DesSer.h.

         {
      COPPER = 1,
      ROPC = 2
    };

Constructor & Destructor Documentation

DesSer()

DesSer

(

)

Constructor / Destructor.

Definition at line 30 of file DesSer.cc.

{
 
  m_num_connections = 1;
 
  m_exprunsubrun_no = 0; // will obtain info from data
 
  m_prev_exprunsubrun_no = 0xFFFFFFFF;
 
#ifdef NONSTOP
  m_run_pause = 0;
 
  m_run_error = 0;
#endif
 
  //  B2INFO("DeSerializerPrePC: Constructor done.");
  printf("[DEBUG] DesSer: Constructor done.\n"); fflush(stdout);
}

~DesSer()

~DesSer ( )

virtual

Definition at line 51 of file DesSer.cc.

{
 
}

Member Function Documentation

Accept()

void Accept

(

bool

close_listen = true

)

Definition at line 364 of file DesSer.cc.

{
  //
  // Connect to cprtb01
  //
  struct hostent* host;
  host = gethostbyname(m_hostname_local.c_str());
  if (host == NULL) {
    char temp_buf[500];
    sprintf(temp_buf, "[FATAL] hostname(%s) cannot be resolved(%s). Check /etc/hosts. Exiting...\n",
            m_hostname_local.c_str(), strerror(errno));
    print_err.PrintError(temp_buf, __FILE__, __PRETTY_FUNCTION__, __LINE__);
    exit(1);
  }
 
  //
  // Bind and listen
  //
  int fd_listen;
  struct sockaddr_in sock_listen;
  sock_listen.sin_family = AF_INET;
  sock_listen.sin_addr.s_addr = *(unsigned int*)host->h_addr_list[0];
 
  socklen_t addrlen = sizeof(sock_listen);
  sock_listen.sin_port = htons(m_port_to);
  fd_listen = socket(PF_INET, SOCK_STREAM, 0);
 
  int flags = 1;
  int ret = setsockopt(fd_listen, SOL_SOCKET, SO_REUSEADDR, &flags, (socklen_t)sizeof(flags));
  if (ret < 0) {
    perror("Failed to set REUSEADDR");
  }
 
  if (bind(fd_listen, (struct sockaddr*)&sock_listen, sizeof(struct sockaddr)) < 0) {
    printf("[FATAL] Failed to bind. Maybe other programs have already occupied this port(%d). Exiting...\n",
           m_port_to); fflush(stdout);
    // Check the process occupying the port 30000.
    FILE* fp;
    char buf[256];
    char cmdline[500];
    sprintf(cmdline, "/usr/sbin/ss -ap | grep %d", m_port_to);
    if ((fp = popen(cmdline, "r")) == NULL) {
      printf("[WARNING] Failed to run %s\n", cmdline);
    }
    while (fgets(buf, 256, fp) != NULL) {
      printf("[ERROR] Failed to bind. output of ss(port %d) : %s\n", m_port_to, buf); fflush(stdout);
    }
    // Error message
    fclose(fp);
    char temp_char[500];
    sprintf(temp_char, "[FATAL] Failed to bind.(%s) Maybe other programs have already occupied this port(%d). Exiting...",
            strerror(errno), m_port_to);
    print_err.PrintError(temp_char, __FILE__, __PRETTY_FUNCTION__, __LINE__);
    exit(1);
  }
 
  int val1 = 0;
  setsockopt(fd_listen, IPPROTO_TCP, TCP_NODELAY, &val1, (socklen_t)sizeof(val1));
  int backlog = 1;
  if (listen(fd_listen, backlog) < 0) {
    char err_buf[500];
    sprintf(err_buf, "Failed in listen(%s). Exting...", strerror(errno));
    print_err.PrintError(err_buf, __FILE__, __PRETTY_FUNCTION__, __LINE__);
    exit(-1);
  }
 
  //
  // Accept
  //
  int fd_accept;
  struct sockaddr_in sock_accept;
  printf("[DEBUG] Accepting... : port %d server %s\n", m_port_to, m_hostname_local.c_str());
  fflush(stdout);
 
  if ((fd_accept = accept(fd_listen, (struct sockaddr*) & (sock_accept), &addrlen)) == 0) {
    char err_buf[500];
    sprintf(err_buf, "[FATAL] Failed to accept(%s). Exiting...", strerror(errno));
    print_err.PrintError(err_buf, __FILE__, __PRETTY_FUNCTION__, __LINE__);
    exit(-1);
  } else {
    //    B2INFO("Done.");
    printf("[DEBUG] Done.\n"); fflush(stdout);
 
    //    set timepout option
    struct timeval timeout;
    timeout.tv_sec = 1;
    timeout.tv_usec = 0;
    ret = setsockopt(fd_accept, SOL_SOCKET, SO_SNDTIMEO, &timeout, (socklen_t)sizeof(timeout));
    if (ret < 0) {
      char temp_char[100] = "[FATAL] Failed to set TIMEOUT. Exiting...";
      print_err.PrintError(temp_char, __FILE__, __PRETTY_FUNCTION__, __LINE__);
      exit(-1);
    }
  }
 
  if (close_listen) {
    close(fd_listen);
  }
 
  //   int flag = 1;
  //   ret = setsockopt(fd_accept, IPPROTO_TCP, TCP_NODELAY, (char*)&flag, sizeof(flag) );
  m_socket_send = fd_accept;
 
  if (m_status.isAvailable()) {
    m_status.setOutputPort(ntohs(sock_listen.sin_port));
    m_status.setOutputAddress(sock_listen.sin_addr.s_addr);
    //    B2INFO("Accepted " << (int)ntohs(sock_listen.sin_port) << " " << (int)sock_listen.sin_addr.s_addr);
    printf("Accepted. port %d address %d\n", (int)ntohs(sock_listen.sin_port), (int)sock_listen.sin_addr.s_addr); fflush(stdout);
  }
 
  return;
 
}

calcXORChecksum()

unsigned int calcXORChecksum	(	int *	buf,
		int	nwords
	)

calculate checksum

Definition at line 495 of file DesSer.cc.

{
  unsigned int checksum = 0;
  for (int i = 0; i < nwords; i++) {
    checksum = checksum ^ buf[ i ];
  }
  return checksum;
}

clearNumUsedBuf()

void clearNumUsedBuf ( )

inline

Definition at line 121 of file DesSer.h.

    {
      m_num_usedbuf = 0;
      return ;
    }

DataAcquisition()

virtual void DataAcquisition ( )

pure virtual

Module functions to be called from event process.

Implemented in DesSerCOPPER, and DesSerPrePC.

fillSendHeaderTrailer()

void fillSendHeaderTrailer	(	SendHeader *	hdr,
		SendTrailer *	trl,
		RawDataBlockFormat *	rawdblk
	)

Definition at line 171 of file DesSer.cc.

{
 
  int total_send_nwords =
    hdr->GetHdrNwords() +
    rawdblk->TotalBufNwords() +
    //    rawhdr.GetNwords() +
    trl->GetTrlNwords();
 
  hdr->SetNwords(total_send_nwords);
  hdr->SetNumEventsinPacket(rawdblk->GetNumEvents());
  hdr->SetNumNodesinPacket(rawdblk->GetNumNodes());
 
  //
  // For bug check
  //
  if (rawdblk->GetNumEntries() == 1) {
    if (total_send_nwords != (rawdblk->GetBuffer(0))[ 0 ] + 8) {
      char err_buf[500];
      sprintf(err_buf, "Length error. total length %d rawdblk length %d. Exting...\n",
              total_send_nwords, (rawdblk->GetBuffer(0))[ 0 ]);
      printData(rawdblk->GetBuffer(0), rawdblk->TotalBufNwords());
      print_err.PrintError(err_buf, __FILE__, __PRETTY_FUNCTION__, __LINE__);
      sleep(1234567);
      exit(-1);
    }
  }
 
 
  for (int i = 0; i < rawdblk->GetNumEntries(); i++) {
 
    //copy event # from a tonp COPPER block
    if (!(rawdblk->CheckFTSWID(i)) && !(rawdblk->CheckTLUID(i))) {
      tmp_header.SetBuffer(rawdblk->GetBuffer(i));
      hdr->SetEventNumber(tmp_header.GetEveNo());
      hdr->SetNodeID(tmp_header.GetNodeID());
      hdr->SetExpRunWord(tmp_header.GetExpRunSubrun());
      break;
    }
 
    //Error if you cannot find any COPPER block
    if (i == (rawdblk->GetNumEntries() - 1)) {
      printf("[DEBUG] i= %d : num entries %d : Tot words %d\n", i, rawdblk->GetNumEntries(), rawdblk->TotalBufNwords());
      printData(rawdblk->GetBuffer(0), rawdblk->TotalBufNwords());
 
      char err_buf[500] = "[FATAL] CORRUPTED DATA: No COPPER blocks in RawDataBlock. Exiting...";
      print_err.PrintError(err_buf, __FILE__, __PRETTY_FUNCTION__, __LINE__);
      sleep(1234567);
      exit(-1);
    }
  }
  return;
}

getNewBuffer()

int * getNewBuffer	(	int	nwords,
		int *	delete_flag
	)

Getbuffer.

Definition at line 77 of file DesSer.cc.

{
 
  int* temp_buf = NULL;
  // Prepare buffer
  if (nwords >  BUF_SIZE_WORD) {
    *delete_flag = 1;
    temp_buf = new int[ nwords ];
  } else {
    if ((temp_buf = getPreAllocBuf()) == 0x0) {
      char err_buf[500];
      sprintf(err_buf, "Null pointer from GetPreALlocBuf(). Exting...\n");
      print_err.PrintError(err_buf, __FILE__, __PRETTY_FUNCTION__, __LINE__);
      sleep(1234567);
      exit(1);
    } else {
      *delete_flag = 0;
    }
  }
 
  return temp_buf;
 
}

getPreAllocBuf()

int * getPreAllocBuf

(

)

Getbuffer.

Definition at line 57 of file DesSer.cc.

{
  int* tempbuf = 0;
  if (m_num_usedbuf < NUM_PREALLOC_BUF) {
    tempbuf = m_bufary[ m_num_usedbuf  ];
    m_num_usedbuf++;
  } else {
    char err_buf[500];
    sprintf(err_buf,
            "No pre-allocated buffers are left. %d > %d. Not enough buffers are allocated or "
            "memory leak or forget to call ClearNumUsedBuf every event loop. Exting...",
            m_num_usedbuf, NUM_PREALLOC_BUF);
    print_err.PrintError(err_buf, __FILE__, __PRETTY_FUNCTION__, __LINE__);
    sleep(1234567);
    exit(1);
  }
  return tempbuf;
}

getTimeSec()

double getTimeSec

(

)

store time info.

Definition at line 478 of file DesSer.cc.

{
  struct timeval t;
  gettimeofday(&t, NULL);
  return (t.tv_sec + t.tv_usec * 1.e-6);
}

initialize()

void initialize

(

bool

close_listen = true

)

Definition at line 101 of file DesSer.cc.

{
  printf("[DEBUG] DesSer: initialize() started.\n"); fflush(stdout);
  signal(SIGPIPE, SIG_IGN);
 
  //
  // initialize Rx part from DeSerializer**.cc
  //
 
  // allocate buffer
  for (int i = 0 ; i < NUM_PREALLOC_BUF; i++) {
    m_bufary[i] = new int[ BUF_SIZE_WORD ];
  }
  m_buffer = new int[ BUF_SIZE_WORD ];
 
  // initialize buffer
  for (int i = 0 ; i < NUM_PREALLOC_BUF; i++) {
    memset(m_bufary[i], 0,  BUF_SIZE_WORD * sizeof(int));
  }
 
  // Open message handler
  clearNumUsedBuf();
  // Shared memory
  if (m_shmflag > 0) {
    if (m_nodename.size() == 0 || m_nodeid < 0) {
      m_shmflag = 0;
    } else {
      m_status.open(m_nodename, m_nodeid);
      m_status.reportReady();
    }
  }
 
  event_diff = 0;
 
  m_prev_copper_ctr = 0xFFFFFFFF;
  m_prev_evenum = 0xFFFFFFFF;
 
 
  //
  // initialize Rx part from DeSerializer**.cc
  //
  m_start_flag = 0;
  n_basf2evt = -1;
  m_compressionLevel = 0;
 
#ifdef DUMMY
  m_buffer = new int[ BUF_SIZE_WORD ];
#endif
  Accept(close_listen);
#ifdef NONSTOP
  openRunPauseNshm();
#endif
 
 
  // For monitor
  if (m_status.isAvailable()) {
    m_status.setOutputNBytes(0);
    m_status.setOutputCount(0);
  }
  //  B2INFO("DesSer: initialize() was done.");
  printf("[DEBUG] DesSer: initialize() was done.\n"); fflush(stdout);
 
}

printData()

void printData	(	int *	buf,
		int	nwords
	)

dump error data

Definition at line 505 of file DesSer.cc.

{
  printf("[DEBUG]");
  for (int i = 0; i < nwords; i++) {
    printf("%.8x ", buf[ i ]);
    if (i % 10 == 9) printf("\n[DEBUG]");
  }
  printf("\n[DEBUG]");
  printf("\n");
  return;
}

recordTime()

void recordTime	(	int	event,
		double *	array
	)

store time info.

Definition at line 486 of file DesSer.cc.

{
  if (event >= 50000 && event < 50500) {
    array[ event - 50000 ] = getTimeSec() - m_start_time;
  }
  return;
}

Send()

int Send	(	int	socket,
		char *	buf,
		int	size_bytes
	)

send buffer

Definition at line 328 of file DesSer.cc.

{
  int sent_bytes = 0;
  while (true) {
    int ret = 0;
    if ((ret = send(socket,
                    buf + sent_bytes, size_bytes - sent_bytes,  MSG_NOSIGNAL)) < 0) {
      if (errno == EINTR) {
        continue;
      } else if (errno == EAGAIN || errno == EWOULDBLOCK) {
#ifdef NONSTOP
        string err_str;
        callCheckRunPause(err_str);
#endif
        continue;
      } else {
        char err_buf[500];
        sprintf(err_buf, "[WARNING] SEND ERROR.(%s)", strerror(errno));
#ifdef NONSTOP
        m_run_error = 1;
        //        B2ERROR(err_buf);
        printf("%s\n", err_buf); fflush(stdout);
        string err_str = "RUN_ERROR";
        throw (err_str);  // To exit this module, go to DeSerializer** and wait for run-resume.
#else
        print_err.PrintError(err_buf, __FILE__, __PRETTY_FUNCTION__, __LINE__);
        exit(1);
#endif
      }
    }
    sent_bytes += ret;
    if (sent_bytes == size_bytes) break;
  }
  return sent_bytes;
}

sendByWriteV()

int sendByWriteV

(

RawDataBlockFormat *

rawdblk

)

Definition at line 227 of file DesSer.cc.

{
  SendHeader send_header;
  SendTrailer send_trailer;
  fillSendHeaderTrailer(&send_header, &send_trailer, rawdblk);
 
  enum {
    NUM_BUFFER = 3
  };
  struct iovec iov[ NUM_BUFFER ];
 
  // check Body data size
  int rawcopper_nwords = rawdblk->TotalBufNwords();
 
  //Fill iov info.
  iov[0].iov_base = (char*)send_header.GetBuffer();
  iov[0].iov_len = sizeof(int) * send_header.GetHdrNwords();
 
  iov[1].iov_base = (char*)rawdblk->GetWholeBuffer();
  iov[1].iov_len = sizeof(int) * rawcopper_nwords;
 
  iov[2].iov_base = (char*)send_trailer.GetBuffer();
  iov[2].iov_len = sizeof(int) * send_trailer.GetTrlNwords();
 
  // Send Multiple buffers
  int n = 0;
  while (true) {
    if ((n = writev(m_socket_send, iov, NUM_BUFFER)) < 0) {
      if (errno == EINTR) {
        continue;
      } else if (errno == EAGAIN || errno == EWOULDBLOCK) {
#ifdef NONSTOP
        string err_str;
        callCheckRunPause(err_str);
#endif
        continue;
      } else {
        char err_buf[500];
        sprintf(err_buf, "[WARNING] WRITEV error.(%s) : sent %d bytes, header %lu bytes body %lu trailer %lu\n",
                strerror(errno), n, iov[0].iov_len, iov[1].iov_len, iov[2].iov_len);
#ifdef NONSTOP
        m_run_error = 1;
        //        B2ERROR(err_buf);
        printf("%s\n", err_buf); fflush(stdout);
        string err_str = "RUN_ERROR";
        throw (err_str);  // To exit this module, go to DeSerializer** and wait for run-resume.
#else
        print_err.PrintError(err_buf, __FILE__, __PRETTY_FUNCTION__, __LINE__);
        exit(1);
#endif
      }
    }
    break;
  }
 
#ifdef DEBUG
  printf("[DEBUG] *******BODY**********\n");
  printf("[DEBUG] \n%.8d : ", 0);
  printData((int*)(iov[1].iov_base), iov[1].iov_len);
#endif
 
 
  int total_send_bytes = sizeof(int) * send_header.GetTotalNwords();
 
 
  //
  // Retry sending
  //
  if (n != total_send_bytes) {
    //    B2WARNING("Serializer: Sent byte(" << n << "bytes) is not same as the event size (" << total_send_bytes << "bytes). Retrying...");
    printf("[WARNING] Serializer: Sent byte( %d bytes) is not same as the event size ( %d bytes). Retrying...\n", n,
           total_send_bytes); // back to WARNING due to request from Konno-san on 2018/7/3
    fflush(stdout);
 
    double retry_start = getTimeSec();
    // Send Header
    if (n < (int)(iov[ 0 ].iov_len)) {
      n += Send(m_socket_send, (char*)iov[ 0 ].iov_base + n, iov[ 0 ].iov_len - n);
    }
 
    if (n < (int)(iov[ 0 ].iov_len + iov[ 1 ].iov_len)) {
      n += Send(m_socket_send, (char*)iov[ 1 ].iov_base + (n - iov[ 0 ].iov_len), iov[ 1 ].iov_len - (n - iov[ 0 ].iov_len));
    }
 
    if (n < (int)(iov[ 0 ].iov_len + iov[ 1 ].iov_len + iov[ 2 ].iov_len)) {
      n += Send(m_socket_send, (char*)iov[ 2 ].iov_base + (n - iov[ 0 ].iov_len - iov[ 1 ].iov_len),
                iov[ 2 ].iov_len - (n - iov[ 0 ].iov_len - iov[ 1 ].iov_len));
    }
    double retry_end = getTimeSec();
    //    B2WARNING("Resending ends. It takes " << retry_end - retry_start << "(s)");
    printf("[WARNING] Resending ends. It takes %lf (s)\n", retry_end - retry_start);
    fflush(stdout); // back to WARNING due to request from Konno-san on 2018/7/3
  }
  //   printf( "[DEBUG] n %d total %d\n", n, total_send_bytes);
  //  delete temp_buf;
 
  return total_send_bytes;
 
}

shmOpen()

void shmOpen	(	char *	path_cfg,
		char *	path_sta
	)

open shared memory

Definition at line 679 of file DesSer.cc.

{
  errno = 0;
  /*m_shmfd_cfg = shm_open( "/cpr_config2", O_CREAT | O_EXCL | O_RDWR, 0666);
  if (m_shmfd_cfg < 0) {
    if (errno != EEXIST) {
      perror("shm_open1");
      exit(1);
    }
  m_shmfd_cfg = shm_open(path_cfg, O_RDWR, 0666);
  if (m_shmfd_cfg < 0) {
    printf( "[DEBUG] %s\n", path_cfg);
    perror("[ERROR] shm_open2");
    exit(1);
  }
  */
  //}
  /*
  m_shmfd_sta = shm_open( "/cpr_status2", O_CREAT | O_EXCL | O_RDWR, 0666);
  if (m_shmfd_sta < 0) {
    if (errno != EEXIST) {
      perror("shm_open1");
      exit(1);
    }
  m_shmfd_sta = shm_open(path_sta , O_RDWR, 0666);
  if (m_shmfd_sta < 0) {
    printf( "[DEBUG] %s\n", path_sta);
    perror("[ERROR] shm_open2");
    exit(1);
  }
  //}
  int size = 4 * sizeof(int);
  ftruncate(m_shmfd_cfg, size);
  ftruncate(m_shmfd_sta, size);
    */
}

Member Data Documentation

cur_time

double cur_time

for time monitoring

Definition at line 102 of file DesSer.h.

event_diff

int event_diff

protected

Definition at line 256 of file DesSer.h.

m_bufary

int* m_bufary[NUM_PREALLOC_BUF]

buffer

Definition at line 85 of file DesSer.h.

m_buffer

int* m_buffer

buffer

Definition at line 82 of file DesSer.h.

m_cfg_buf

int* m_cfg_buf

buffer for shared memory

Definition at line 221 of file DesSer.h.

m_cfg_sta

int* m_cfg_sta

buffer for shared memory

Definition at line 224 of file DesSer.h.

m_compressionLevel

int m_compressionLevel

Compression Level.

Definition at line 67 of file DesSer.h.

m_data_type

int m_data_type

data type

Definition at line 153 of file DesSer.h.

m_dump_fname

std::string m_dump_fname

dump filename

Definition at line 76 of file DesSer.h.

m_exp_no

int m_exp_no

exp no.

Definition at line 150 of file DesSer.h.

m_exprunsubrun_no

unsigned int m_exprunsubrun_no

run no.

Definition at line 144 of file DesSer.h.

m_fp_dump

FILE* m_fp_dump

dump file descripter

Definition at line 79 of file DesSer.h.

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_hostname_local

std::string m_hostname_local

protected

Destination Host.

Definition at line 275 of file DesSer.h.

m_ncycle

int m_ncycle

Definition at line 100 of file DesSer.h.

m_nodeid

int m_nodeid

Node ID for SLC.

Definition at line 138 of file DesSer.h.

m_nodename

std::string m_nodename

Node Name for SLC.

Definition at line 135 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_port_from

std::vector<int> m_port_from

protected

port # to connect data sources

Definition at line 246 of file DesSer.h.

m_port_to

int m_port_to

protected

Destination port.

Definition at line 278 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.

m_prev_copper_ctr

unsigned int m_prev_copper_ctr

protected

Definition at line 258 of file DesSer.h.

m_prev_evenum

unsigned int m_prev_evenum

protected

Definition at line 260 of file DesSer.h.

m_prev_exprunsubrun_no

unsigned int m_prev_exprunsubrun_no

run no.

Definition at line 147 of file DesSer.h.

m_prev_nevt

int m_prev_nevt

No. of prev sent events.

Definition at line 73 of file DesSer.h.

m_prev_time

double m_prev_time

Definition at line 105 of file DesSer.h.

m_recvd_prev_totbytes

double m_recvd_prev_totbytes

Definition at line 97 of file DesSer.h.

m_recvd_totbytes

double m_recvd_totbytes

Definition at line 96 of file DesSer.h.

m_run_error

int m_run_error

flag to show that there is some errors with which DAQ cannot continue.

Definition at line 230 of file DesSer.h.

m_run_pause

int m_run_pause

flag to show that run-controller pauses a run

Definition at line 227 of file DesSer.h.

m_sent_prev_totbytes

double m_sent_prev_totbytes

Definition at line 99 of file DesSer.h.

m_sent_totbytes

double m_sent_totbytes

Definition at line 98 of file DesSer.h.

m_shmfd_cfg

int m_shmfd_cfg

file descripter for shm

Definition at line 168 of file DesSer.h.

m_shmfd_sta

int m_shmfd_sta

file descripter for shm

Definition at line 171 of file DesSer.h.

m_shmflag

int m_shmflag

Use shared memory.

Definition at line 159 of file DesSer.h.

m_socket_recv

std::vector<int> m_socket_recv

protected

Definition at line 248 of file DesSer.h.

m_socket_send

int m_socket_send

protected

Reciever Socket.

Definition at line 267 of file DesSer.h.

m_start_flag

int m_start_flag

start flag

Definition at line 181 of file DesSer.h.

m_start_time

double m_start_time

Definition at line 104 of file DesSer.h.

m_status

RunInfoBuffer m_status

Run info buffer.

Definition at line 141 of file DesSer.h.

m_t0

timeval m_t0

Definition at line 95 of file DesSer.h.

m_trunc_mask

int m_trunc_mask

trunc mask

Definition at line 156 of file DesSer.h.

max_nevt

int max_nevt

of events in a run

Definition at line 61 of file DesSer.h.

max_seconds

double max_seconds

time to stop a run

Definition at line 64 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.

n_basf2evt

int n_basf2evt

No. of sent events.

Definition at line 70 of file DesSer.h.

p_method

std::string p_method

protected

EvtSocket.

How to handle data

Definition at line 284 of file DesSer.h.

p_method_val

int p_method_val

protected

Definition at line 285 of file DesSer.h.

prev_event

int prev_event

Definition at line 106 of file DesSer.h.

print_err

CprErrorMessage print_err

wrapper for B2LOG system

Definition at line 184 of file DesSer.h.

tmp_header

RawHeader_v2 tmp_header

protected

which format is used

Definition at line 323 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