linux_vxlan_agent_init.cc

Go to the documentation of this file.

/*
 * Copyright (c) 2013 Juniper Networks, Inc. All rights reserved.
 */
#include <cmn/agent_cmn.h>

#include <ksync/ksync_index.h>
#include <ksync/ksync_entry.h>
#include <ksync/ksync_object.h>

#include <vnc_cfg_types.h>
#include <bgp_schema_types.h>
#include <agent_types.h>

#include <init/agent_param.h>
#include <cmn/agent_db.h>

#include <oper/operdb_init.h>
#include <oper/peer.h>
#include <oper/vrf.h>
#include <oper/interface_common.h>
#include <oper/nexthop.h>
#include <oper/multicast.h>
#include <oper/vn.h>
#include <oper/mirror_table.h>
#include <oper/vxlan.h>
#include <oper/mpls.h>
#include <oper/route_common.h>
#include <oper/bridge_route.h>

#include <cfg/cfg_init.h>
#include <controller/controller_init.h>
#include <uve/agent_uve.h>

#include <vxlan_agent/ksync_vxlan.h>
#include <vxlan_agent/ksync_vxlan_bridge.h>
#include <vxlan_agent/ksync_vxlan_route.h>
#include <vxlan_agent/ksync_vxlan_port.h>

#include "linux_vxlan.h"
#include "linux_bridge.h"
#include "linux_port.h"
#include "linux_fdb.h"

#include "linux_vxlan_agent_init.h"

LinuxVxlanAgentInit::LinuxVxlanAgentInit()
    : ksync_vxlan_(nullptr) {
}

LinuxVxlanAgentInit::~LinuxVxlanAgentInit() {
    ksync_vxlan_.reset(nullptr);
    uve_.reset(nullptr);
}

void LinuxVxlanAgentInit::ProcessOptions
    (const std::string &config_file, const std::string &program_name) {
    AgentInit::ProcessOptions(config_file, program_name);
}

int LinuxVxlanAgentInit::Start() {
    return AgentInit::Start();
}

/****************************************************************************
 * Initialization routines
****************************************************************************/
void LinuxVxlanAgentInit::FactoryInit() {
}

void LinuxVxlanAgentInit::CreateModules() {
    ksync_vxlan_.reset(new KSyncLinuxVxlan(agent()));
    uve_.reset(new AgentUve(agent(), AgentUveBase::kBandwidthInterval,
                            AgentUveBase::kDefaultInterval,
                            AgentUveBase::kIncrementalInterval));
    agent()->set_uve(uve_.get());
}

void LinuxVxlanAgentInit::RegisterDBClients() {
    ksync_vxlan_->RegisterDBClients(agent()->db());
    uve_->RegisterDBClients();
}

void LinuxVxlanAgentInit::InitModules() {
    ksync_vxlan_->Init();
    uve_->Init();
}

void LinuxVxlanAgentInit::ConnectToController() {
    agent()->controller()->Connect();
}

/****************************************************************************
 * Shutdown routines
 ****************************************************************************/
void LinuxVxlanAgentInit::KSyncShutdown() {
    ksync_vxlan_->Shutdown();
}

void LinuxVxlanAgentInit::UveShutdown() {
    uve_->Shutdown();
}

void LinuxVxlanAgentInit::WaitForIdle() {
    sleep(5);
}