clb_replay.cpp

Go to the documentation of this file.

/**
 
  Program name: CLBReplay
 
  Description:
    This program provide a way to send back to one of the DAQ tools
    the data contained in DQ or CLBSK dump data, via UDP.
    The program must run on the same computer where the DAQ tool is running.
 
    Use
     $ CLBReplay -h
    for a detailed help.
 
  E-mail: carmelo.pellegrino@bo.infn.it
  Date:   9 April 2015
 
  \author  Carmelo Pellegrino
*/
 
#include <iostream>
#include <boost/program_options.hpp>
#include <boost/asio.hpp>
#include <fstream>
#include <string>
 
 
namespace po = boost::program_options;
 
int main(int argc, char* argv[])
{
  std::string filename;
  unsigned int port = 0;
  unsigned int sleep_time;
 
  po::options_description desc("Options");
  desc.add_options()
      ("help,h",     "Print this help and exit.")
      ("dumpfile,d",
          po::value<std::string>(&filename)->required(),
          "Set the name of the data file to send back to DQ or CLBSwissKnife.")
      ("port,p",
          po::value<unsigned int>(&port)->required(),
          "Set the UDP port to send the data through")
      ("sleep,s",po::value<unsigned int>(&sleep_time)->default_value(1000),"sleep time between sending data packets (in microseconds)");
 
  try
  {
    po::variables_map vm;
    po::store(
        po::command_line_parser(argc, argv).options(desc).run(),
        vm);
 
    if (vm.count("help"))
    {
      std::cout << desc << std::endl;
      return EXIT_SUCCESS;
    }
 
    po::notify(vm);
  }
  catch (const po::error& e)
  {
    std::cerr << "CLBReplay: Error: " << e.what() << '\n'
              << desc << std::endl;
    return EXIT_FAILURE;
  }
  catch (const std::runtime_error& e)
  {
    std::cerr << "CLBReplay: Error: " << e.what() << '\n'
              << desc << std::endl;
    return EXIT_FAILURE;
  }
 
  std::ifstream input_file(filename.c_str());
  boost::asio::ip::udp::udp::endpoint endpoint(
      boost::asio::ip::address::from_string("127.0.0.1"),
      port);
 
  boost::asio::io_service service;
  boost::asio::ip::udp::socket sock(service, boost::asio::ip::udp::udp::v4());
 
  char buffer[10000];
 
  while (input_file && input_file.peek() != EOF)
  {
    unsigned int datagram_size = 0;
    input_file.read((char*) &datagram_size, sizeof(datagram_size));
 
    input_file.read(buffer, datagram_size);
 
    sock.send_to(boost::asio::buffer(buffer, datagram_size), endpoint);
    // wait xx ms to give to the DAQ tool the time to complete the read-out
    usleep(sleep_time);
  }
 
  std::cout << "File finished\n";
 
  return EXIT_SUCCESS;
}