fix_to_link_main_impl.hpp

Go to the documentation of this file.

/******************************************************************************
** Copyright © 2017 by J.M.McGuiness, isimud@hussar.me.uk
**
** This library is free software; you can redistribute it and/or
** modify it under the terms of the GNU Lesser General Public
** License as published by the Free Software Foundation; either
** version 2.1 of the License, or (at your option) any later version.
**
** This library is distributed in the hope that it will be useful,
** but WITHOUT ANY WARRANTY; without even the implied warranty of
** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
** Lesser General Public License for more details.
**
** You should have received a copy of the GNU Lesser General Public
** License along with this library; if not, write to the Free Software
** Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
 
namespace isimud { namespace ISIMUD_VER_NAMESPACE { namespace exchanges {
 
template<class Link, class Operation>
inline int
fix_to_link::main(int argc, char const * const *argv, boost::program_options::options_description &&all, Operation &&op) noexcept(true) {
   using namespace libjmmcg;
   using link_t=Link;
   using thread_traits=typename link_t::thread_traits;
 
   try {
      boost::program_options::variables_map vm;
      boost::program_options::store(boost::program_options::parse_command_line(argc, argv, all), vm);
      if (vm.count("help")) {
         std::cout<<all<<std::endl;
         return exit_codes::exit_print_help;
      }
      if (vm.count("version")) {
         std::cout<<LIBJMMCG_DETAILED_VERSION_INFO " Built with FIX: " ISIMUD_FIX_EXCHANGE_VERSION ", MICs generated on: '" ISIMUD_ISO_10383_MIC_XML_GENERATED_DATE "', currency-codes created on: '" ISIMUD_ISO_4217_CURRENCY_CODES_XML_GENERATED_DATE "' and country-codes generated on: '" ISIMUD_ISO_3166_COUNTRY_CODES_XML_GENERATED_DATE "'" << std::endl;
         return exit_codes::exit_print_version;
      }
      boost::program_options::notify(vm);
 
      thread_traits::set_backtrace_on_signal();
      auto const ctor_args=op(vm);
      const std::size_t num_timestamps=vm["num_timings"].as<std::size_t>();
      latency_timestamps timestamps(num_timestamps);
      {
         link_t link(
            std::get<0>(ctor_args),
            std::get<1>(ctor_args),
            socket::socket_priority::high,
            socket::socket_priority::low,
            std::get<2>(ctor_args),
            timestamps,
            "link" LIBJMMCG_ENQUOTE(__LINE__)
         );
         std::clog<<link<<std::endl;
         thread_traits::set_kernel_affinity(
            thread_traits::get_current_thread(),
            typename thread_traits::api_params_type::processor_mask_type(common::thread_traits::main_thread.core)
         );
         thread_traits::set_kernel_priority(
            thread_traits::get_current_thread(),
            common::thread_traits::main_thread.priority
         );
         while (!link.signal_status()) {
            thread_traits::sleep(0);
         }
         std::clog<<link<<std::endl;
      }
      timestamps.write_to_csv_file(std::clog, argv[0]);
      return exit_codes::exit_success;
   } catch (std::exception const &ex) {
      std::cerr<<"STL-derived exception. Details: "<<boost::diagnostic_information(ex)<<std::endl;
      return exit_codes::exit_stl_exception;
   } catch (...) {
      std::cerr<<"Unknown exception."<<std::endl;
      return exit_codes::exit_unknown_exception;
   }
   return exit_codes::exit_unknown_failure;
}
 
} } }