JDAQSummaryslice.hh

Go to the documentation of this file.

#ifndef __JDAQSUMMARYSLICE__
#define __JDAQSUMMARYSLICE__

#include <ostream>
#include <iomanip>
#include <vector>

#include "JDAQ/JDAQRoot.hh"
#include "JDAQ/JDAQPreamble.hh"
#include "JDAQ/JDAQSummaryFrame.hh"
#include "JDAQ/JDAQSummarysliceHeader.hh"
#include "JDAQ/JDAQTimeslice.hh"
#include "JDAQ/JDAQClock.hh"
#include "JIO/JSerialisable.hh"
#include "JIO/JSTDIO.hh"


/**
 * \author mdejong
 */

namespace KM3NETDAQ {

  using JIO::JReader;
  using JIO::JWriter;


  /**
   * Data summary slice.
   */
  class JDAQSummaryslice :
    public JDAQPreamble,
    public JDAQSummarysliceHeader,
    public std::vector<JDAQSummaryFrame>
  {
  public:
    /**
     * Default constructor.
     */
    JDAQSummaryslice() :
      JDAQPreamble(JDAQType<JDAQSummaryslice>()),
      JDAQSummarysliceHeader(),
      std::vector<JDAQSummaryFrame>()
    {}


    /**
     * Constructor.
     *
     * \param  chronometer    DAQ chronometer
     */
    JDAQSummaryslice(const JDAQChronometer& chronometer) :
      JDAQPreamble(JDAQType<JDAQSummaryslice>()),
      JDAQSummarysliceHeader(chronometer),
      std::vector<JDAQSummaryFrame>()
    {}


    /**
     * Constructor.
     *
     * \param  timeslice      time slice
     */
    JDAQSummaryslice(const JDAQTimeslice& timeslice) :
      JDAQPreamble(JDAQType<JDAQSummaryslice>()),
      JDAQSummarysliceHeader(timeslice),
      std::vector<JDAQSummaryFrame>()
    {
      for (JDAQTimeslice::const_iterator i = timeslice.begin(); i != timeslice.end(); ++i) {
        this->push_back(JDAQSummaryFrame(*i));
      }
    }


    /**
     * Virtual destructor.
     */
    virtual ~JDAQSummaryslice()
    {}


    /**
     * Read DAQ summaryslice from input.
     *
     * \param  in             JReader
     * \param  summaryslice   JDAQSummaryslice
     * \return                JReader
     */
    friend inline JReader& operator>>(JReader& in, JDAQSummaryslice& summaryslice)
    {
      summaryslice.clear();

      in >> static_cast<JDAQPreamble&>                 (summaryslice);
      in >> static_cast<JDAQSummarysliceHeader&>       (summaryslice);
      in >> static_cast<std::vector<JDAQSummaryFrame>&>(summaryslice);

      return in;
    }


    /**
     * Write DAQ summaryslice to output.
     *
     * \param  out           JWriter
     * \param  summaryslice  JDAQSummaryslice
     * \return               JWriter
     */
    friend inline JWriter& operator<<(JWriter& out, const JDAQSummaryslice& summaryslice)
    {
      out << static_cast<const JDAQPreamble&>                 (summaryslice);
      out << static_cast<const JDAQSummarysliceHeader&>       (summaryslice);
      out << static_cast<const std::vector<JDAQSummaryFrame>&>(summaryslice);

      return out;
    }


    /**
     * Print DAQ summary.
     *
     * \param  out         output stream
     * \param  lpr         long print
     * \return             output stream
     */
    std::ostream& print(std::ostream& out, const bool lpr = false) const
    {
      using namespace std;

      out << this->ClassName() << endl;
      out << dynamic_cast<const JDAQPreamble&>   (*this) << endl;
      out << dynamic_cast<const JDAQChronometer&>(*this) << endl;
    
      for (JDAQSummaryslice::const_iterator module = this->begin(); module != this->end(); ++module) {

        out << ' ' << setw(5) <<        module->getModuleID();
        out << ' ' << setw(8) << hex << module->getStatus() << dec;
        out << ' ' << setw(2) <<        module->getUDPNumberOfReceivedPackets();
        out << ' ' << setw(2) <<        module->getUDPMaximalSequenceNumber();

        if (lpr) {
          for (int pmt = 0; pmt != NUMBER_OF_PMTS; ++pmt) {
            out << ' ' << fixed << showpoint << setw(4) << setprecision(1) << module->getRate(pmt) * 1.0e-3;
          }
        }

        out << endl;
      }

      return out;
    }


    /**
     * Get size of object.
     *
     * \return               number of bytes
     */
    virtual int getSize() const
    { 
      int len = 0;

      len += JDAQPreamble          ::sizeOf();
      len += JDAQSummarysliceHeader::sizeOf();

      len += sizeof(int);
      len += this->size() * JDAQSummaryFrame::sizeOf();

      return len;
    }

    
    /**
     * Action method at file open.
     *
     * \param  version   version
     */
    static void actionAtFileOpen(int version)
    {
      JDAQSummaryFrame::ROOT_IO_VERSION = version;
    }
    
    ClassDef(JDAQSummaryslice,6);
  };


  /**
   * Print DAQ summary.
   *
   * \param  out         output stream
   * \param  summary     summary
   * \return             output stream
   */
  inline std::ostream& operator<<(std::ostream& out, const KM3NETDAQ::JDAQSummaryslice& summary)
  {
    return summary.print(out, getDAQLongprint());
  }


  /**
   * Equal operator for DAQ summary slices.
   *
   * \param  first     summary slice
   * \param  second    summary slice
   * \result           true if first summary slice equal to second; else false
   */
  inline bool operator==(const JDAQSummaryslice& first,
                         const JDAQSummaryslice& second)
  {
    return (first.getDAQSummarysliceHeader()                         == second.getDAQSummarysliceHeader()                         &&
            static_cast<const std::vector<JDAQSummaryFrame>&>(first) == static_cast<const std::vector<JDAQSummaryFrame>&>(second));
  }


  /**
   * Not-equal operator for DAQ summary slices.
   *
   * \param  first     summary slice
   * \param  second    summary slice
   * \result           true if first summary slice not equal to second; else false
   */
  inline bool operator!=(const JDAQSummaryslice& first,
                         const JDAQSummaryslice& second)
  {
    return !(first == second);
  }
}

#endif