source: src/JobMarket/ServerOptions.cpp@ 404d2b

/*
 * Project: JobMarket
 * Description: asynchronous Server/Controller/Client-approach to parallel computing, based on boost::asio
 * Copyright (C)  2012 Frederik Heber. All rights reserved.
 * 
 */

/*
 * ServerOptions.cpp
 *
 *  Created on: 01.06.2012
 *      Author: heber
 */

// include config.h
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include "CodePatterns/MemDebug.hpp"

#include "JobMarket/ServerOptions.hpp"

#include "CodePatterns/Log.hpp"

int ServerOptions::parseWorkerPort(boost::program_options::variables_map &vm)
{
  if (vm.count("workerport")) {
    try {
      workerport = vm["workerport"].as< unsigned short >();
    } catch (boost::bad_lexical_cast) {
      ELOG(1, "Could not read " << workerport << " as digits.");
      return 255;
    }
    LOG(1, "INFO: Using " << workerport << " as listen port for worker.");
  } else {
    ELOG(1, "Requiring listen port for worker.");
    return 255;
  }
  return 0;
}

int ServerOptions::parseControllerPort(boost::program_options::variables_map &vm)
{
  if (vm.count("controllerport")) {
    try {
      controllerport = vm["controllerport"].as< unsigned short >();
    } catch (boost::bad_lexical_cast) {
      ELOG(1, "Could not read " << controllerport << " as digits.");
      return 255;
    }
    LOG(1, "INFO: Using " << controllerport << " as listen port for controller.");
  } else {
    ELOG(1, "Requiring listen port for controller.");
    return 255;
  }
  return 0;
}

int ServerOptions::parseTimeout(boost::program_options::variables_map &vm)
{
  if (vm.count("timeout")) {
    try {
      timeout = vm["timeout"].as< size_t >();
    } catch (boost::bad_lexical_cast) {
      ELOG(1, "Could not read " << timeout << " as digits.");
      return 255;
    }
  } else {
    timeout = 30;
  }
  LOG(1, "INFO: Using " << timeout << " as timeout.");
  return 0;
}