driver/host_info.cc

// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License, version 2.0
// (GPLv2), as published by the Free Software Foundation, with the
// following additional permissions:
//
// This program is distributed with certain software that is licensed
// under separate terms, as designated in a particular file or component
// or in the license documentation. Without limiting your rights under
// the GPLv2, the authors of this program hereby grant you an additional
// permission to link the program and your derivative works with the
// separately licensed software that they have included with the program.
//
// Without limiting the foregoing grant of rights under the GPLv2 and
// additional permission as to separately licensed software, this
// program is also subject to the Universal FOSS Exception, version 1.0,
// a copy of which can be found along with its FAQ at
// http://oss.oracle.com/licenses/universal-foss-exception.
//
// This program 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 General Public License, version 2.0, for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program. If not, see 
// http://www.gnu.org/licenses/gpl-2.0.html.

#include "host_info.h"

#include "rds_utils.h"

// TODO
// the entire HOST_INFO needs to be reviewed based on needed interfaces and other objects like CLUSTER_TOPOLOGY_INFO
// most/all of the HOST_INFO potentially could be internal to CLUSTER_TOPOLOGY_INFO and specfic information may be accessed
// through CLUSTER_TOPOLOGY_INFO
// Move the implementation to it's own file

HOST_INFO::HOST_INFO() : HOST_INFO("", NO_PORT) {}

HOST_INFO::HOST_INFO(std::string host, int port)
    : HOST_INFO(host, port, UP, false) {}

// would need some checks for nulls
HOST_INFO::HOST_INFO(const char* host, int port)
    : HOST_INFO(host, port, UP, false) {}

HOST_INFO::HOST_INFO(std::string host, int port, HOST_STATE state, bool is_writer)
    : host{host}, host_id{RDS_UTILS::get_rds_instance_id(host)}, port{port}, host_state{state}, is_writer{is_writer} {}

// would need some checks for nulls
HOST_INFO::HOST_INFO(const char* host, int port, HOST_STATE state, bool is_writer)
    : host{host}, host_id{RDS_UTILS::get_rds_instance_id(host)}, port{port}, host_state{state}, is_writer{is_writer} {}

HOST_INFO::~HOST_INFO() {}

/**
 * @return the host endpoint
 */
std::string HOST_INFO::get_host() {
    return host;
}

/**
 * @return the host name
 */
std::string HOST_INFO::get_host_id() { return host_id; }

/**
 * @return the port
 */
int HOST_INFO::get_port() {
    return port;
}

/**
 * @return the host:port representation of this host
 */
std::string HOST_INFO::get_host_port_pair() {
    return get_host() + HOST_PORT_SEPARATOR + std::to_string(get_port());
}


bool HOST_INFO::equal_host_port_pair(HOST_INFO& hi) {
    return get_host_port_pair() == hi.get_host_port_pair();
}

HOST_STATE HOST_INFO::get_host_state() {
    return host_state;
}

void HOST_INFO::set_host_state(HOST_STATE state) {
    host_state = state;
}

bool HOST_INFO::is_host_up() {
    return host_state == UP;
}

bool HOST_INFO::is_host_down() {
    return host_state == DOWN;
}

bool HOST_INFO::is_host_writer() {
    return is_writer;
}
void HOST_INFO::mark_as_writer(bool writer) {
    is_writer = writer;
}

// Check if two host info have same instance name
bool HOST_INFO::is_host_same(std::shared_ptr<HOST_INFO> h1, std::shared_ptr<HOST_INFO> h2) {
    return h1->instance_name == h2->instance_name;
}