JDAQTags.hh

Go to the documentation of this file.

#ifndef __JDAQTAGS__
#define __JDAQTAGS__

#include <string>

#include "km3net-dataformat/online/JDAQDataTypes.hh"

#include "JNet/JTag.hh"
#include "JLang/JType.hh"
#include "JMath/JConstants.hh"


/**
 * \file
 *
 * Fixed parameters and ControlHost tags for %KM3NeT DAQ.
 * \author mdejong
 */


namespace KM3NETDAQ {

  using JMATH::KILOBYTE;
  using JMATH::MEGABYTE;
  using JMATH::GIGABYTE;


  // socket buffer size

  static const int DFILTER_DQUEUE_BUFFER_SIZE   =   1 * MEGABYTE;   //!< socket JDataFilter.cc  <-  DataQueue.cc
  static const int DFILTER_RECEIVE_BUFFER_SIZE  =  16 * MEGABYTE;   //!< socket JDataFilter.cc  <-  JLigier.cc
  static const int DFILTER_SEND_BUFFER_SIZE     =  16 * MEGABYTE;   //!< socket JDataFilter.cc  ->  JDataWriter.cc
  static const int DWRITER_RECEIVE_BUFFER_SIZE  =  16 * MEGABYTE;   //!< socket JDataWriter.cc  <-  JDataFilter.cc


  // run control client name
  
  static const std::string RUN_CONTROL_CLIENT   =  std::string("DAQ"); 
  
  // process names

  static const std::string JDATAQUEUE           =  std::string("DataQueue");
  static const std::string JDATAFILTER          =  std::string("JDataFilter");
  static const std::string JACOUSTICDATAFILTER  =  std::string("AcousticDataFilter");
  static const std::string JDATAWRITER          =  std::string("JDataWriter");
  static const std::string JUNIQUE_ID           =  std::string("uniqueID");

  // token delimiters
  
  static const char        WILD_CARD            =  '%';
  static const char        EVENTNAME_DELIMETER  =  ':';
  static const std::string TOKEN_DELIMETER      =  std::string("#");
  static const std::string CLIENTNAME_DELIMETER =  std::string("/");
  static const std::string FILENAME_PREFIX      =  std::string("%<");
  static const std::string FILENAME_POSTFIX     =  std::string(">%");
  
  // tags for control messages
  
  static const JNET::JTag RC_STRT               =  JNET::JTag("RC_STRT");
  static const JNET::JTag RC_CMD                =  JNET::JTag("RC_CMD");
  static const JNET::JTag RC_REPLY              =  JNET::JTag("RC_REPLY");
  static const JNET::JTag RC_FAIL               =  JNET::JTag("RC_FAIL");
  static const JNET::JTag RC_DQSIMULATOR        =  JNET::JTag("RC_DQSIM");
  static const JNET::JTag RC_EVTGENERATOR       =  JNET::JTag("RC_EVT");
  static const JNET::JTag RC_DWRITER            =  JNET::JTag("RC_DWRT");  /*!< JTag for JDataWriter */ 
  static const JNET::JTag RC_LOG                =  JNET::JTag("RC_LOG");   /*!< JTag for Logger */
  static const JNET::JTag RC_DFILTER            =  JNET::JTag("RC_DFLTR"); /*!< JTag for JDataFilter */
  static const JNET::JTag RC_DQUEUE             =  JNET::JTag("RC_DQUE");  /*!< JTag for combined opto-acoustic DataQueue */
  static const JNET::JTag RC_DQUEUE_ACS         =  JNET::JTag("RC_DQUEA"); /*!< JTag for acoustic-only DataQueue */
  static const JNET::JTag RC_DQUEUE_OPT         =  JNET::JTag("RC_DQUEO"); /*!< JTag for optical-only  DataQueue */
  static const JNET::JTag RC_MONITORING_ROUTER  =  JNET::JTag("RC_MROUT"); /*!< JTag for Monitoring Router */
  static const JNET::JTag RC_AFILTER            =  JNET::JTag("RC_AFLTR");
  static const JNET::JTag RC_ALERT              =  JNET::JTag("RC_ALRT");  /*!< JTag for JDataFilter alert */

  // tags for DAQ data
  
  static const JNET::JTag IO_TIMESLICE          =  JNET::JTag("IO_TSL");
  static const JNET::JTag IO_TIMESLICE_L0       =  JNET::JTag("IO_TSL0");
  static const JNET::JTag IO_TIMESLICE_L1       =  JNET::JTag("IO_TSL1");
  static const JNET::JTag IO_TIMESLICE_L2       =  JNET::JTag("IO_TSL2");
  static const JNET::JTag IO_TIMESLICE_SN       =  JNET::JTag("IO_TSSN");
  static const JNET::JTag IO_EVENT              =  JNET::JTag("IO_EVT");
  static const JNET::JTag IO_SUMMARY            =  JNET::JTag("IO_SUM");
  static const JNET::JTag IO_TRIGGER_PARAMETERS =  JNET::JTag("TRG_PARS");
  static const JNET::JTag IO_MONITORING_DATA    =  JNET::JTag("IO_MONIT");
}  
  
inline JNET::JTag getTag(JLANG::JType<KM3NETDAQ::JDAQTimeslice>)    { return KM3NETDAQ::IO_TIMESLICE; }
inline JNET::JTag getTag(JLANG::JType<KM3NETDAQ::JDAQTimesliceL0>)  { return KM3NETDAQ::IO_TIMESLICE_L0; }
inline JNET::JTag getTag(JLANG::JType<KM3NETDAQ::JDAQTimesliceL1>)  { return KM3NETDAQ::IO_TIMESLICE_L1; }
inline JNET::JTag getTag(JLANG::JType<KM3NETDAQ::JDAQTimesliceL2>)  { return KM3NETDAQ::IO_TIMESLICE_L2; }
inline JNET::JTag getTag(JLANG::JType<KM3NETDAQ::JDAQTimesliceSN>)  { return KM3NETDAQ::IO_TIMESLICE_SN; }
inline JNET::JTag getTag(JLANG::JType<KM3NETDAQ::JDAQEvent>)        { return KM3NETDAQ::IO_EVENT; }
inline JNET::JTag getTag(JLANG::JType<KM3NETDAQ::JDAQSummaryslice>) { return KM3NETDAQ::IO_SUMMARY; }

#endif