clb_replay.cpp File Reference

#include <iostream>
#include <boost/program_options.hpp>
#include <boost/asio.hpp>
#include <fstream>
#include <string>

Go to the source code of this file.

Functions
int	main (int argc, char *argv[])
	Program name: CLBReplay.

Function Documentation

main()

int main	(	int	argc,
		char *	argv[] )

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: carme.nosp@m.lo.p.nosp@m.elleg.nosp@m.rino.nosp@m.@bo.i.nosp@m.nfn..nosp@m.it Date: 9 April 2015

Author

Carmelo Pellegrino

Definition at line 29 of file clb_replay.cpp.

{
  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;
}