global_system_config.cc

Go to the documentation of this file.

/*
 * Copyright (c) 2013 Juniper Networks, Inc. All rights reserved.
 */

#include <cmn/agent.h>
#include <init/agent_param.h>
#include <bind/bind_resolver.h>
#include <vnc_cfg_types.h>
#include <oper_db.h>
#include <controller/controller_init.h>
#include <forwarding_class.h>
#include <global_system_config.h>
#include <config_manager.h>
#include <cfg/cfg_init.h>
#include "oper/bgp_as_service.h"

#define DEFAULT_XMPP_HOLD_TIME 90

void BGPaaServiceParameters::Reset() {
    port_start = 0;
    port_end = 0;
}

void GracefulRestartParameters::Reset() {
    enable_ = true;
    end_of_rib_time_ = 0;
    long_lived_restart_time_ = 0;
    xmpp_helper_enable_ = true;
    config_seen_ = false;
}

void FastConvergenceParameters::Reset() {
    enable = false;
    xmpp_hold_time = DEFAULT_XMPP_HOLD_TIME;
}

void GracefulRestartParameters::Update(autogen::GlobalSystemConfig *cfg) {
    bool changed = false;

    config_seen_ = true;
    if (enable_ != cfg->graceful_restart_parameters().enable) {
        enable_ = cfg->graceful_restart_parameters().enable;
        changed = true;
    }

    if (xmpp_helper_enable_ !=
        cfg->graceful_restart_parameters().xmpp_helper_enable) {
        xmpp_helper_enable_ =
            cfg->graceful_restart_parameters().xmpp_helper_enable;
        changed = true;
    }

    if (end_of_rib_time_ !=
        (uint32_t)cfg->graceful_restart_parameters().end_of_rib_timeout) {
        end_of_rib_time_ =
            (uint32_t)cfg->graceful_restart_parameters().end_of_rib_timeout;
        changed = true;
    }

    if (long_lived_restart_time_ !=
        (uint32_t)cfg->graceful_restart_parameters().long_lived_restart_time) {
        long_lived_restart_time_ =
            (uint32_t)cfg->graceful_restart_parameters().long_lived_restart_time;
        changed = true;
    }

    if (changed) {
        Notify();
    }
}

void GracefulRestartParameters::Notify() {
    for (GracefulRestartParameters::CallbackList::iterator it =
         callbacks_.begin(); it != callbacks_.end(); it++) {
        (*it)();
    }
}

void GracefulRestartParameters::Register(GracefulRestartParameters::Callback cb)
{
    callbacks_.push_back(cb);
}

GlobalSystemConfig::GlobalSystemConfig(Agent *agent) : OperIFMapTable(agent) {
    Reset();
}

GlobalSystemConfig::~GlobalSystemConfig() {
}

void GlobalSystemConfig::ConfigDelete(IFMapNode *node) {
    if (node->IsDeleted()) {
        Reset();
    }
}

void GlobalSystemConfig::Reset() {
    bgpaas_parameters_.Reset();
    gres_parameters_.Reset();
    fc_params_.Reset();
    cfg_igmp_enable_ = false;
}

void GlobalSystemConfig::ConfigAddChange(IFMapNode *node) {
    autogen::GlobalSystemConfig *cfg =
        dynamic_cast<autogen::GlobalSystemConfig *>(node->GetObject());

    if (!cfg) {
        Reset();
        return;
    }

    //Populate BGP-aas params
    if ((bgpaas_parameters_.port_start !=
                    cfg->bgpaas_parameters().port_start) ||
        (bgpaas_parameters_.port_end !=
                    cfg->bgpaas_parameters().port_end)) {
        bgpaas_parameters_.port_start = cfg->bgpaas_parameters().port_start;
        bgpaas_parameters_.port_end = cfg->bgpaas_parameters().port_end;
        // update BgpaaS session info
        agent()->oper_db()->bgp_as_a_service()->
                                UpdateBgpAsAServiceSessionInfo();
    }

    //Populate fast convergence params
    if ((fc_params_.enable !=
                    cfg->fast_convergence_parameters().enable) ||
        (fc_params_.xmpp_hold_time !=
                    cfg->fast_convergence_parameters().xmpp_hold_time)) {
        fc_params_.enable = cfg->fast_convergence_parameters().enable;
        fc_params_.xmpp_hold_time =
                    cfg->fast_convergence_parameters().xmpp_hold_time;
        // if fc_enabled is not set, use default hold time
        if (!fc_params_.enable)
            fc_params_.xmpp_hold_time = DEFAULT_XMPP_HOLD_TIME;
        // update hold time in existing xmpp sessions
        agent()->controller()->XmppServerUpdate(fc_params_.xmpp_hold_time);
    }

    if (cfg_igmp_enable_ != cfg->igmp_enable()) {

        cfg_igmp_enable_ = cfg->igmp_enable();

        agent()->cfg()->cfg_vm_interface_table()->NotifyAllEntries();
    }

    //Populate gres params
    gres_parameters_.Update(cfg);
}

void GlobalSystemConfig::ConfigManagerEnqueue(IFMapNode *node) {
    agent()->config_manager()->AddGlobalSystemConfigNode(node);
}

GracefulRestartParameters &GlobalSystemConfig::gres_parameters() {
    return gres_parameters_;
}

bool GlobalSystemConfig::cfg_igmp_enable() const {
    return cfg_igmp_enable_;
}

void GlobalSystemConfig::FillSandeshInfo(GlobalSystemConfigResp *resp)
{
  BGPaaSSandeshData bgp_params;
  bgp_params.set_port_start(bgpaas_parameters_.port_start);
  bgp_params.set_end_port(bgpaas_parameters_.port_end);
  GracefulRestartSandeshData graceful_restart;
  graceful_restart.set_enable(gres_parameters_.enable());
  graceful_restart.set_end_of_rib_time(gres_parameters_.end_of_rib_time());
  graceful_restart.set_xmpp_helper_enable(gres_parameters_.xmpp_helper_enable());
  graceful_restart.set_config_seen(gres_parameters_.config_seen());
  IgmpSandeshData igmp_params;
  igmp_params.set_cfg_igmp_enable(cfg_igmp_enable());
  resp->set_bgp_parameters(bgp_params);
  resp->set_llgr_parameters(graceful_restart);
  resp->set_igmp_parameters(igmp_params);
}

void GlobalSystemConfigReq::HandleRequest() const {
    GlobalSystemConfigResp *resp = new GlobalSystemConfigResp();
    Agent *agent = Agent::GetInstance();
    GlobalSystemConfig  *global_sys_config = agent->oper_db()->global_system_config();
    if (!global_sys_config) {
        resp->set_more(false);
        resp->Response();
        return;
    }
    resp->set_context(context());
    global_sys_config->FillSandeshInfo(resp);
    resp->set_more(false);
    resp->Response();
    return;
}