dlardaq Namespace Reference

Classes
class	EventDecoder
struct	evheader_t
struct	footer_t
class	formatexception
class	HuffDataCompressor
class	LogStream
struct	runheader_t
struct	trigger_t

Typedefs
typedef char	BYTE
typedef uint16_t	adc16_t
typedef struct dlardaq::trigger_t	trigger_t
typedef struct dlardaq::runheader_t	runheader_t
typedef struct dlardaq::evheader_t	evheader_t
typedef struct dlardaq::footer_t	footer_t

Functions
void	pack16into12 (const void *in, void *out, size_t n)
void	unpack12into16 (const void *in, void *out, size_t n)
void	write12 (const char *fname, std::vector< adc16_t > &adc)
void	read12 (const char *fname, std::vector< adc16_t > &adc)
template<typename T >
T	ConvertToValue (const void *in)
ssize_t	decode_runhead (const char *buf, runheader_t &rh)
ssize_t	decode_evehead (const char *buf, evheader_t &eh)
ssize_t	decode_filefoot (const char *buf, footer_t &rf)
static LogStream	msg_info (std::cout, _strinfo)
static LogStream	msg_warn (std::cout, _strwarn)
static LogStream	msg_err (std::cerr, _strerror)

Variables
static formatexception	fex
static const size_t	RunHeadSz = 5
static const size_t	EveHeadSz = 35
static const size_t	FileFootSz = 4
static const short	BitsADC = 12
static std::string	_strinfo = "[ \033[22;32mINFO\033[0m ] "
static std::string	_strwarn = "[ \033[01;35mWARN\033[0m ] "
static std::string	_strerror = "[ \033[22;31mERROR\033[0m ] "

Typedef Documentation

typedef uint16_t dlardaq::adc16_t

Definition at line 40 of file dlardaq.h.

typedef char dlardaq::BYTE

Definition at line 39 of file dlardaq.h.

typedef struct dlardaq::evheader_t dlardaq::evheader_t

typedef struct dlardaq::footer_t dlardaq::footer_t

typedef struct dlardaq::runheader_t dlardaq::runheader_t

typedef struct dlardaq::trigger_t dlardaq::trigger_t

Function Documentation

template<typename T >

T dlardaq::ConvertToValue

(

const void *

in

)

Definition at line 110 of file dlardaq.h.

    {
      const T *ptr = static_cast<const T*>(in);
      return *ptr;
    }

ssize_t dlardaq::decode_evehead	(	const char *	buf,
		dlardaq::evheader_t &	eh
	)

Definition at line 174 of file dlardaq_service.cc.

{
  ssize_t rval = EveHeadSz;
  memset(&eh, 0, sizeof(eh));

  try
    {
      // check for delimiting words
      BYTE k0 = buf[0];
      BYTE k1 = buf[1];
      if( !( ((k0 & 0xFF) == EVSKEY) && ((k1 & 0xFF) == EVSKEY) ) )
        {
          msg_err<<"Event delimiting word could not be detected "<<endl;
          throw fex;
        }
      rval = 2;
      // this is actually written in host byte order
      eh.trig_info = ConvertToValue<trigger_t>(buf+rval);
      rval += sizeof(eh.trig_info);
      
      // data quality flags
      eh.dq_flag = (uint8_t)buf[rval++];
      
      // event number 4 bytes
      eh.ev_num   = (((uint32_t)buf[rval++] << 24) & 0xFF000000);
      eh.ev_num  += (((uint32_t)buf[rval++] << 16) & 0xFF0000);
      eh.ev_num  += (((uint32_t)buf[rval++] << 8) & 0xFF00);
      eh.ev_num  += ( (uint32_t)buf[rval++] & 0xFF);


      // event number 4 bytes
      eh.ev_size   = (((uint32_t)buf[rval++] << 24) & 0xFF000000);
      eh.ev_size  += (((uint32_t)buf[rval++] << 16) & 0xFF0000);
      eh.ev_size  += (((uint32_t)buf[rval++] << 8) & 0xFF00);
      eh.ev_size  += ( (uint32_t)buf[rval++] & 0xFF);
    }
  catch(exception &e)
    {
      msg_err<<"Decode event header exception "<<e.what()<<endl;
      rval = -1;
    }

  return rval;
}

ssize_t dlardaq::decode_filefoot	(	const char *	buf,
		dlardaq::footer_t &	rf
	)

Definition at line 221 of file dlardaq_service.cc.

{
  ssize_t rval = FileFootSz;
  memset(&rf, 0, sizeof(rf));

  try
    {
      // check for delimiting words
      if( !( ((buf[0]&0xFF) == ENDKEY) && ((buf[1]&0xFF) == ENDKEY) ) )
        {
          msg_err<<"Delimiting word in footer could not be detected "<<endl;
          throw fex;
        }
      rf.num_events = (((uint16_t)buf[2] << 8) & 0xff00) + (buf[3] & 0xff);
    }
  catch(exception &e)
    {
      msg_err<<"Decode footer info exception "<<e.what()<<endl;
      rval = -1;
    }

  return rval;
}

ssize_t dlardaq::decode_runhead	(	const char *	buf,
		dlardaq::runheader_t &	rh
	)

Definition at line 146 of file dlardaq_service.cc.

{
  ssize_t rval = RunHeadSz;
  memset(&rh, 0, sizeof(rh));
  // in general we will get undefined behaviour if buf < required bytes
  // the try - catch block will not help, but does not hurt either
  try
    {
      // decode run number
      rh.run_num   = (((uint32_t)buf[0] << 24) & 0xFF000000);
      rh.run_num  += (((uint32_t)buf[1] << 16) & 0xFF0000);
      rh.run_num  += (((uint32_t)buf[2] << 8) & 0xFF00);
      rh.run_num  += ( (uint32_t)buf[3] & 0xFF);
      
      rh.run_flags = (uint8_t)buf[4];
    }
  catch(std::exception &e)
    {
      msg_err<<"Decode runheader exception "<<e.what()<<endl;
      rval = -1;
    }
  
  return rval;
}

static LogStream dlardaq::msg_err ( std::cerr  , _strerror    )

static

static LogStream dlardaq::msg_info ( std::cout  , _strinfo    )

static

static LogStream dlardaq::msg_warn ( std::cout  , _strwarn    )

static

void dlardaq::pack16into12	(	const void *	in,
		void *	out,
		size_t	n
	)

Definition at line 30 of file dlardaq_service.cc.

{
  const adc16_t* in16 = static_cast<const adc16_t*>(in);
  BYTE* out8 = static_cast<BYTE*>(out);
  BYTE* stop = out8 + n8bit;
  
  while(out8!=stop)
    {
      // we pack 2x12 bit values into 3x8bit
      adc16_t v1 = *in16++;
      adc16_t v2 = *in16++;
      
      *out8++ = ( v1 >> 4 ) & 0xff;
      *out8++ = ( (v1 & 0xf) << 4 ) + ( ( v2 >> 8) & 0xf );
      *out8++ = v2 & 0xff;
    }
}

void dlardaq::read12	(	const char *	fname,
		std::vector< adc16_t > &	adc
	)

Definition at line 105 of file dlardaq_service.cc.

{
  //std::ifstream fin(fname, ios::in | ios::binary | ios::ate);
  std::ifstream fin(fname, ios::in | ios::binary);

  // get number of bytes
  //size_t bufsize = fin.tellg();
  //fin.seekg(0, ios::beg);
  
  // more presise ???
  fin.ignore( std::numeric_limits<std::streamsize>::max() );
  size_t bufsize = fin.gcount();
  fin.clear();  
  fin.seekg( 0, std::ios_base::beg );

  size_t npad = 0;
  while( (bufsize+npad) % 3 ) 
    {
      msg_warn<<"The input vector size is not divisible by 3. Appending zeros"<<endl;
      npad++;
    }

  // allocate memory for file content
  char* buffer = new char[bufsize + npad];
  for(size_t i=bufsize;i<bufsize+npad;i++)
    buffer[i] = '\0';

  // read content of the file
  fin.read(buffer, bufsize);
  fin.close();

  adc.clear();
  adc.resize( (bufsize + npad)/3*2, 0 );
  unpack12into16( buffer, &adc[0], bufsize + npad );

  delete [] buffer;
}

void dlardaq::unpack12into16	(	const void *	in,
		void *	out,
		size_t	n
	)

Definition at line 52 of file dlardaq_service.cc.

{
  const BYTE* in8  = static_cast<const BYTE*>(in);
  const BYTE* stop = in8 + n8bit;

  adc16_t* out16 = static_cast<adc16_t*>(out);

  while(in8!=stop)
    {
      BYTE v1 = *in8++;
      BYTE v2 = *in8++;
      BYTE v3 = *in8++;

      *out16++ = ((v1 << 4) + ((v2 >> 4) & 0xf)) & 0xfff;
      *out16++ = (((v2 & 0xf) << 8 ) + (v3 & 0xff)) & 0xfff;
    }
}

void dlardaq::write12	(	const char *	fname,
		std::vector< adc16_t > &	adc
	)

Definition at line 74 of file dlardaq_service.cc.

{
  size_t vecsize = adc.size();
  if(vecsize % 2)
    {
      msg_warn<<"The input vector size is not even. Appending zeros"<<endl;
      adc.push_back( 0 ); // careful, 0 added returns by reference !!!
      vecsize++;
    }

  // size of the 8 bit buffer
  size_t bufsize = vecsize/2*3;

  // new buffer
  char *buffer = new char[bufsize];

  // fill it
  pack16into12(&adc[0], buffer, bufsize);
  
  // write it to file
  ofstream fout(fname, ios::out | ios::binary);
  fout.write(buffer, bufsize);
  fout.close();
  
  delete [] buffer;
}

Variable Documentation

std::string dlardaq::_strerror = "[ \033[22;31mERROR\033[0m ] "

static

Definition at line 23 of file LogMsg.h.

std::string dlardaq::_strinfo = "[ \033[22;32mINFO\033[0m ] "

static

Definition at line 21 of file LogMsg.h.

std::string dlardaq::_strwarn = "[ \033[01;35mWARN\033[0m ] "

static

Definition at line 22 of file LogMsg.h.

const short dlardaq::BitsADC = 12

static

Definition at line 63 of file dlardaq.h.

const size_t dlardaq::EveHeadSz = 35

static

Definition at line 58 of file dlardaq.h.

formatexception dlardaq::fex

static

Definition at line 52 of file dlardaq.h.

const size_t dlardaq::FileFootSz = 4

static

Definition at line 60 of file dlardaq.h.

const size_t dlardaq::RunHeadSz = 5

static

Definition at line 56 of file dlardaq.h.