JRegurgitate.cc

Go to the documentation of this file.

#include <string>
#include <iostream>
#include <iomanip>

#include "JDAQ/JDAQTimesliceIO.hh"
#include "JDAQ/JDAQEventIO.hh"
#include "JDAQ/JDAQSummarysliceIO.hh"

#include "JSupport/JMultipleFileScanner.hh"
#include "JSupport/JSupport.hh"

#include "JROOT/JROOTClassSelector.hh"
#include "JLang/JPipe.hh"
#include "JLang/JValve.hh"

#include "JDAQ/JDAQTags.hh"
#include "JNet/JControlHostObjectOutput.hh"

#include "Jeep/JTimekeeper.hh"
#include "Jeep/JParser.hh"
#include "Jeep/JMessage.hh"


namespace {

  using namespace JPP;

  /**
   * Auxiliary class to control object throughput.
   */
  struct JRegulator_t :
    public JRegulator,
    public JTimekeeper
  {
    /**
     * Constructor.
     *
     * \param  rate_Hz       rate [Hz]
     * \param  time_s        time [s]
     */
    JRegulator_t(const double rate_Hz,
                 const double time_s)
    {
      setInterval((long long int) (1.0e6 / rate_Hz));

      t1 = getLocalTime()  +  (localtime_t) (1.0e6 * time_s);
    }


    /**
     * Accept.
     *
     * \return            true
     */
    virtual bool accept() const
    {
      if ((bool) (*this)) {
      
        this->wait();
        
        return true;
      }

      return false;
    }

    
    /**
     * Type conversion operator.
     *
     * \return            true if within time; else false
     */
    inline operator bool() const
    {
      return getLocalTime() < t1;
    }
    

  protected:
    localtime_t t1;
  };
}


/**
 * \file
 * Auxiliary program to send objects to JLigier.cc server.
 * The option <tt>-H <hostname>[:port]</tt> correponds to the hostname and the port of the server, respectively.
 * \author mdejong
 */
int main(int argc, const char *argv[])
{
  using namespace std;
  using namespace JPP;

  typedef JDAQTypes_t  typelist;

  JMultipleFileScanner<typelist> inputFile;
  string             hostname;
  JROOTClassSelector selector;
  double             rate_Hz;
  double             time_s;
  int                debug;

  try {

    JParser<> zap("Auxiliary program to send objects to JLigier server.");

    zap['f'] = make_field(inputFile);
    zap['H'] = make_field(hostname)     = "localhost";
    zap['C'] = make_field(selector)     = getROOTClassSelection<typelist>();
    zap['R'] = make_field(rate_Hz);
    zap['T'] = make_field(time_s);
    zap['d'] = make_field(debug)        = 1;

    zap['C'] = JPARSER::not_initialised();

    zap(argc, argv);
  }
  catch(const exception &error) {
    FATAL(error.what() << endl);
  }


  JControlHostObjectOutput<typelist> out(hostname);

  for (JRegulator_t regulator(rate_Hz, time_s); regulator; inputFile.rewind()) {
    inputFile | JValve<typelist>(selector) | regulator | out;
  }
}