Config.cc

Go to the documentation of this file.

#include "Common/Compat.h"
#include "Common/InetAddr.h"
#include "Config.h"

#include <algorithm>
#include <iostream>
#include <vector>

#include <strings.h>

namespace Hypertable { namespace Config {

void init_hyperspace_client_options() {
  cmdline_desc().add_options()
    ("hyperspace", str(),
        "hyperspace master server to connect to in <host:port> format")
    ("hyperspace-timeout", i32()->default_value(30000),
        "Timeout in milliseconds for hyperspace connection")
    ("keepalive", i32()->default_value(10000),
        "Interval in milliseconds of keepalive message from Hyperspace client")
    ("lease-interval", i32()->default_value(60000),
        "Hyperspace master lease interval in milliseconds")
    ("grace-period", i32()->default_value(60000),
        "Grace period in milliseconds before 'jeopardy' for hyperspace client")
    ;
  alias("hyperspace-timeout", "Hyperspace.Timeout");
  alias("keepalive", "Hyperspace.KeepAlive.Interval");
  alias("lease-interval", "Hyperspace.Lease.Interval");
  alias("grace-period", "Hyperspace.GracePeriod");
  // hidden aliases
  alias("hs-host", "Hyperspace.Replica.Host");
  alias("hs-port", "Hyperspace.Replica.Port");
}

void init_hyperspace_client() {
  // prepare hidden aliases to be synced
  if (properties->has("hyperspace")) {
    Endpoint e = InetAddr::parse_endpoint(get_str("hyperspace"));
    bool defaulted = properties->defaulted("hyperspace");
    Strings hosts;
    if (properties->has("Hyperspace.Replica.Host"))
      hosts = properties->get_strs("Hyperspace.Replica.Host");

    size_t i;
    for (i=0; i<hosts.size(); i++) {
#if defined(__WIN32__) || defined(_WIN32) || defined(WIN32) || defined(__WINDOWS_386__)
      if (stricmp(hosts[i].c_str(), e.host.c_str()) == 0)
        break;
#else
      if (strcasecmp(hosts[i].c_str(), e.host.c_str()) == 0)
        break;
#endif
    }
    // if not found ...
    if (i == hosts.size()) {
      hosts.insert(hosts.begin(), e.host);
      properties->set("hs-host", hosts, defaulted);
    }
    properties->set("hs-port", e.port, !e.port || defaulted);
  }
}

void init_hyperspace_command_shell_options() {
  CommandShell::add_options(cmdline_desc());
}

void init_hyperspace_master_options() {
  cmdline_desc().add_options()
    ("port", i16(),
        "Hyperspace master listening port")
    ("dir", str()->default_value("hyperspace"),
        "Hyperspace root directory name")
    ("keepalive", i32()->default_value(10000),
        "Interval in milliseconds of keepalive message from Hyperspace client")
    ("lease-interval", i32()->default_value(20000),
        "Hyperspace master lease interval in milliseconds")
    ;
  alias("reactors", "Hyperspace.Replica.Reactors");
  alias("workers", "Hyperspace.Replica.Workers");
  alias("port", "Hyperspace.Replica.Port");
  alias("dir", "Hyperspace.Replica.Dir");
  alias("keepalive", "Hyperspace.KeepAlive.Interval");
  alias("lease-interval", "Hyperspace.Lease.Interval");
}

}} // namespace Hypertable::Config