operdb_init.cc

Go to the documentation of this file.

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

#include <cmn/agent_factory.h>
#include <cmn/agent_cmn.h>
#include <init/agent_param.h>
#include <db/db.h>
#include <base/task_trigger.h>
#include <sandesh/sandesh_types.h>
#include <sandesh/sandesh_constants.h>
#include <sandesh/sandesh.h>
#include <sandesh/sandesh_trace.h>
#include <cfg/cfg_init.h>
#include <oper/route_common.h>
#include <oper/operdb_init.h>
#include <oper/metadata_ip.h>
#include <oper/interface_common.h>
#include <oper/health_check.h>
#include <oper/nexthop.h>
#include <oper/vrf.h>
#include <oper/mpls.h>
#include <oper/vm.h>
#include <oper/vn.h>
#include <oper/sg.h>
#include <oper/tag.h>
#include <oper/mirror_table.h>
#include <oper/vrf_assign.h>
#include <oper/vxlan.h>
#include <oper/multicast_policy.h>
#include <oper/multicast.h>
#include <oper/global_vrouter.h>
#include <oper/path_preference.h>
#include <oper/tsn_elector.h>
#include <oper/vxlan_routing_manager.h>
#include <filter/acl.h>
#include <filter/policy_set.h>
#include <oper/ifmap_dependency_manager.h>
#include <base/task_trigger.h>
#include <oper/instance_manager.h>
#include <oper/physical_device.h>
#include <oper/physical_device_vn.h>
#include <oper/config_manager.h>
#include <oper/agent_profile.h>
#include <oper/agent_sandesh.h>
#include <oper/vrouter.h>
#include <oper/bgp_as_service.h>
#include <oper/bgp_router.h>
#include <oper/agent_route_walker.h>
#include <nexthop_server/nexthop_manager.h>
#include <oper/forwarding_class.h>
#include <oper/qos_config.h>
#include <oper/qos_queue.h>
#include <oper/global_qos_config.h>
#include <oper/global_system_config.h>
#include <oper/bridge_domain.h>
#include <oper/agent_route_walker.h>
#include <oper/security_logging_object.h>
#include <oper/route_leak.h>
#include <oper/crypt_tunnel.h>
#include <oper/hbf.h>

using boost::assign::map_list_of;
using boost::assign::list_of;

SandeshTraceBufferPtr OperConfigTraceBuf(SandeshTraceBufferCreate("OperIfmap",
                                                                  1000));

template<typename T>
T *DBTableCreate(DB *db, Agent *agent, OperDB *oper,
                   const std::string &db_name) {
    DB::RegisterFactory(db_name, &T::CreateTable);
    T *table = static_cast<T *>(db->CreateTable(db_name));
    assert(table);
    table->set_agent(agent);
    return table;
}

void OperDB::CreateDBTables(DB *db) {
    DB::RegisterFactory("db.interface.0", &InterfaceTable::CreateTable);
    DB::RegisterFactory("db.nexthop.0", &NextHopTable::CreateTable);
    DB::RegisterFactory("db.crypttunnel.0",
                        boost::bind(&CryptTunnelTable::CreateTable,
                                    agent_, _1, _2));
    DB::RegisterFactory("uc.route.0",
                        &InetUnicastAgentRouteTable::CreateTable);
    DB::RegisterFactory("uc.route.3",
                        &InetUnicastAgentRouteTable::CreateTable);
    DB::RegisterFactory("mc.route.0",
                        &Inet4MulticastAgentRouteTable::CreateTable);
    DB::RegisterFactory("evpn.route.0", &EvpnAgentRouteTable::CreateTable);
    DB::RegisterFactory("l2.route.0", &BridgeAgentRouteTable::CreateTable);
    DB::RegisterFactory("uc.route6.0",
                        &InetUnicastAgentRouteTable::CreateTable);
    DB::RegisterFactory("db.vrf.0", &VrfTable::CreateTable);
    DB::RegisterFactory("db.vn.0", &VnTable::CreateTable);
    DB::RegisterFactory("db.vm.0", &VmTable::CreateTable);
    DB::RegisterFactory("db.sg.0", &SgTable::CreateTable);
    DB::RegisterFactory("db.tag.0", &TagTable::CreateTable);
    DB::RegisterFactory("db.mpls.0", &MplsTable::CreateTable);
    DB::RegisterFactory("db.acl.0", &AclTable::CreateTable);
    DB::RegisterFactory("db.mirror_table.0", &MirrorTable::CreateTable);
    DB::RegisterFactory("db.vrf_assign.0", &VrfAssignTable::CreateTable);
    DB::RegisterFactory("db.vxlan.0", &VxLanTable::CreateTable);
    DB::RegisterFactory("db.service-instance.0",
                        &ServiceInstanceTable::CreateTable);
    DB::RegisterFactory("db.physical_devices.0",
                        &PhysicalDeviceTable::CreateTable);
    DB::RegisterFactory("db.healthcheck.0",
                        boost::bind(&HealthCheckTable::CreateTable,
                                    agent_, _1, _2));
    DB::RegisterFactory("db.qos_queue.0",
                        boost::bind(&QosQueueTable::CreateTable,
                        agent_, _1, _2));
    DB::RegisterFactory("db.forwardingclass.0",
                        boost::bind(&ForwardingClassTable::CreateTable,
                        agent_, _1, _2));
    DB::RegisterFactory("db.qos_config.0",
                        boost::bind(&AgentQosConfigTable::CreateTable,
                        agent_, _1, _2));
    DB::RegisterFactory("db.bridge_domain.0",
                        boost::bind(&BridgeDomainTable::CreateTable,
                                    agent_, _1, _2));
    DB::RegisterFactory("db.security_logging_object.0",
                        boost::bind(&SecurityLoggingObjectTable::CreateTable,
                        agent_, _1, _2));
    DB::RegisterFactory("db.policy_set.0", &PolicySetTable::CreateTable);
    DB::RegisterFactory("db.multicast_policy.0",
                        &MulticastPolicyTable::CreateTable);

    InterfaceTable *intf_table;
    intf_table = static_cast<InterfaceTable *>(db->CreateTable("db.interface.0"));
    assert(intf_table);
    agent_->set_interface_table(intf_table);
    intf_table->Init(this);
    intf_table->set_agent(agent_);

    // Allocate Range to be used for MetaDataIPAllocator
    agent_->set_metadata_ip_allocator(
            new MetaDataIpAllocator(agent_, 1, max_linklocal_addresses - 1));
    agent_->set_metadata_ip6_allocator(
            new MetaDataIpAllocator(agent_, 1, max_linklocal_addresses - 1));

    HealthCheckTable *hc_table;
    hc_table =
        static_cast<HealthCheckTable *>(db->CreateTable("db.healthcheck.0"));
    assert(hc_table);
    agent_->set_health_check_table(hc_table);

    CryptTunnelTable *crypt_tunnel_table;
    crypt_tunnel_table = static_cast<CryptTunnelTable *>(db->CreateTable("db.crypttunnel.0"));
    assert(crypt_tunnel_table);
    agent_->set_crypt_tunnel_table(crypt_tunnel_table);

    NextHopTable *nh_table;
    nh_table = static_cast<NextHopTable *>(db->CreateTable("db.nexthop.0"));
    assert(nh_table);
    agent_->set_nexthop_table(nh_table);
    nh_table->set_agent(agent_);

    VrfTable *vrf_table;
    vrf_table = static_cast<VrfTable *>(db->CreateTable("db.vrf.0"));
    assert(vrf_table);
    agent_->set_vrf_table(vrf_table);
    vrf_table->set_agent(agent_);

    VmTable *vm_table;
    vm_table = static_cast<VmTable *>(db->CreateTable("db.vm.0"));
    assert(vm_table);
    agent_->set_vm_table(vm_table);
    vm_table->set_agent(agent_);

    SgTable *sg_table;
    sg_table = static_cast<SgTable *>(db->CreateTable("db.sg.0"));
    assert(sg_table);
    agent_->set_sg_table(sg_table);
    sg_table->set_agent(agent_);

    TagTable *tag_table;
    tag_table = static_cast<TagTable *>(db->CreateTable("db.tag.0"));
    assert(tag_table);
    agent_->set_tag_table(tag_table);
    tag_table->set_agent(agent_);

    VnTable *vn_table;
    vn_table = static_cast<VnTable *>(db->CreateTable("db.vn.0"));
    assert(vn_table);
    agent_->set_vn_table(vn_table);
    vn_table->set_agent(agent_);

    MplsTable *mpls_table;
    mpls_table = static_cast<MplsTable *>(db->CreateTable("db.mpls.0"));
    assert(mpls_table);
    agent_->set_mpls_table(mpls_table);
    mpls_table->set_agent(agent_);
    mpls_table->ReserveLabel(0, MplsTable::kStartLabel - 1);

    AclTable *acl_table;
    acl_table = static_cast<AclTable *>(db->CreateTable("db.acl.0"));
    assert(acl_table);
    agent_->set_acl_table(acl_table);
    acl_table->set_agent(agent_);

    MirrorTable *mirror_table;
    mirror_table = static_cast<MirrorTable *>
                   (db->CreateTable("db.mirror_table.0"));
    assert(mirror_table);
    agent_->set_mirror_table(mirror_table);
    mirror_table->set_agent(agent_);
    mirror_table->Initialize();

    VrfAssignTable *vassign_table = static_cast<VrfAssignTable *>
                   (db->CreateTable("db.vrf_assign.0"));
    assert(vassign_table);
    agent_->set_vrf_assign_table(vassign_table);
    vassign_table->set_agent(agent_);

    PolicySetTable *policy_set =
        static_cast<PolicySetTable *>(db->CreateTable("db.policy_set.0"));
    assert(policy_set);
    agent_->set_policy_set_table(policy_set);
    policy_set->set_agent(agent_);

    domain_config_.reset(new DomainConfig(agent_));

    VxLanTable *vxlan_table;
    vxlan_table = static_cast<VxLanTable *>(db->CreateTable("db.vxlan.0"));
    assert(vxlan_table);
    agent_->set_vxlan_table(vxlan_table);
    vxlan_table->set_agent(agent_);
    vxlan_table->Initialize();

    QosQueueTable *qos_queue_table;
    qos_queue_table =
        static_cast<QosQueueTable *>(db->CreateTable("db.qos_queue.0"));
    agent_->set_qos_queue_table(qos_queue_table);

    ForwardingClassTable *forwarding_class_table;
    forwarding_class_table = static_cast<ForwardingClassTable *>(
                                 db->CreateTable("db.forwardingclass.0"));
    agent_->set_forwarding_class_table(forwarding_class_table);

    SecurityLoggingObjectTable *slo_table;
    slo_table = static_cast<SecurityLoggingObjectTable *>(
                                 db->CreateTable("db.security_logging_object.0"));
    agent_->set_slo_table(slo_table);

    AgentQosConfigTable *qos_config_table;
    qos_config_table =
        static_cast<AgentQosConfigTable *>(db->CreateTable("db.qos_config.0"));
    agent_->set_qos_config_table(qos_config_table);

    BridgeDomainTable *bd_table;
    bd_table =
        static_cast<BridgeDomainTable *>(db->CreateTable("db.bridge_domain.0"));
    assert(bd_table);
    agent_->set_bridge_domain_table(bd_table);

    MulticastPolicyTable *mp_table;
    mp_table = static_cast<MulticastPolicyTable *>(
                                db->CreateTable("db.multicast_policy.0"));
    assert(mp_table);
    agent_->set_mp_table(mp_table);
    mp_table->set_agent(agent_);

    acl_table->ListenerInit();

    route_walk_manager_ =
        std::unique_ptr<AgentRouteWalkerManager>(new AgentRouteWalkerManager(agent_));
    multicast_ = std::unique_ptr<MulticastHandler>(new MulticastHandler(agent_));
    global_vrouter_ = std::unique_ptr<GlobalVrouter> (new GlobalVrouter(agent_));
    route_preference_module_ =
        std::unique_ptr<PathPreferenceModule>(new PathPreferenceModule(agent_));
    route_preference_module_->Init();

    ServiceInstanceTable *si_table =
        static_cast<ServiceInstanceTable *>(
            db->CreateTable("db.service-instance.0"));
    agent_->set_service_instance_table(si_table);
    si_table->Initialize(agent_->cfg()->cfg_graph(), dependency_manager_.get());
    si_table->set_agent(agent_);

    PhysicalDeviceTable *dev_table =
        DBTableCreate<PhysicalDeviceTable>(db, agent_, this,
                                           "db.physical_devices.0");
    agent_->set_physical_device_table(dev_table);

    PhysicalDeviceVnTable *dev_vn_table =
        DBTableCreate<PhysicalDeviceVnTable>(db, agent_, this,
                                             "db.physical_device_vn.0");
    agent_->set_physical_device_vn_table(dev_vn_table);
    profile_.reset(new AgentProfile(agent_, true));

    bgp_as_a_service_ = std::unique_ptr<BgpAsAService>(new BgpAsAService(agent_));
    bgp_router_config_ =
        std::unique_ptr<BgpRouterConfig> (new BgpRouterConfig(agent_));

    vrouter_ = std::unique_ptr<VRouter> (new VRouter(agent_));
    global_qos_config_ =
        std::unique_ptr<GlobalQosConfig>(new GlobalQosConfig(agent_));
    global_system_config_ =
        std::unique_ptr<GlobalSystemConfig>(new GlobalSystemConfig(agent_));
    network_ipam_ = std::unique_ptr<OperNetworkIpam>
        (new OperNetworkIpam(agent_, domain_config_.get()));
    virtual_dns_ = std::unique_ptr<OperVirtualDns>
        (new OperVirtualDns(agent_, domain_config_.get()));
    tsn_elector_ = std::unique_ptr<TsnElector>(new TsnElector(agent_));
    vxlan_routing_manager_= std::unique_ptr<VxlanRoutingManager>
        (new VxlanRoutingManager(agent_));
    hbf_handler_= std::unique_ptr<HBFHandler>
        (new HBFHandler(agent_));
}

void OperDB::Init() {
    dependency_manager_->Initialize(agent());

    // Unit tests may not initialize the agent configuration parameters.
    std::string netns_cmd;
    std::string docker_cmd;
    int netns_workers = -1;
    int netns_timeout = -1;
    if (agent_->params()) {
        netns_cmd = agent_->params()->si_netns_command();
        docker_cmd = agent_->params()->si_docker_command();
        netns_workers = agent_->params()->si_netns_workers();
        netns_timeout = agent_->params()->si_netns_timeout();
    }
    instance_manager_->Initialize(agent_->db(), netns_cmd,
                    docker_cmd, netns_workers, netns_timeout);
    if (nexthop_manager_.get()) {
        nexthop_manager_->Initialize(agent_->db());
    }

    if (agent_sandesh_manager_.get()) {
        agent_sandesh_manager_->Init();
    }

    agent_->config_manager()->Init();
    domain_config_->Init();
}

void OperDB::InitDone() {
    profile_->InitDone();
}

void OperDB::RegisterDBClients() {
    IFMapDependencyManager *mgr = agent_->oper_db()->dependency_manager();
    agent_->physical_device_table()->RegisterDBClients(mgr);
    agent_->interface_table()->RegisterDBClients(mgr);

    multicast_.get()->Register();
    global_vrouter_.get()->CreateDBClients();
    route_leak_manager_.reset(new RouteLeakManager(agent_));
    tsn_elector_.get()->Register();
    vxlan_routing_manager_.get()->Register();
    hbf_handler_.get()->Register();
}

OperDB::OperDB(Agent *agent)
        : agent_(agent),
          dependency_manager_(
              AgentStaticObjectFactory::Create<IFMapDependencyManager>(
                  agent->db(), agent->cfg()->cfg_graph())),
          instance_manager_(
                  AgentStaticObjectFactory::Create<InstanceManager>(agent)) {
    if (agent_->params() &&
        agent_->params()->nexthop_server_endpoint().length() > 0) {
        nexthop_manager_.reset(new NexthopManager(agent_->event_manager(),
                               agent->params()->nexthop_server_endpoint()));
    }

    agent_sandesh_manager_.reset(new AgentSandeshManager(agent));
}

OperDB::~OperDB() {
}

void OperDB::Shutdown() {
    agent_->mpls_table()->FreeReserveLabel(0, MplsTable::kStartLabel - 1);
    instance_manager_->Terminate();
    if (nexthop_manager_.get()) {
        nexthop_manager_->Terminate();
    }
    dependency_manager_->Terminate();
    global_vrouter_.reset();

    bgp_router_config_.reset();

    global_qos_config_.reset();
    global_system_config_.reset();

    route_preference_module_->Shutdown();
    multicast_->Shutdown();
    multicast_->Terminate();
    route_walk_manager_->Shutdown();
    tsn_elector_->Shutdown();
    vxlan_routing_manager_->Shutdown();
    hbf_handler_->Terminate();

    if (agent_sandesh_manager_.get()) {
        agent_sandesh_manager_->Shutdown();
    }
#if 0
    agent_->interface_table()->Clear();
    agent_->nexthop_table()->Clear();
    agent_->vrf_table()->Clear();
    agent_->vn_table()->Clear();
    agent_->sg_table()->Clear();
    agent_->vm_table()->Clear();
    agent_->mpls_table()->Clear();
    agent_->acl_table()->Clear();
    agent_->mirror_table()->Clear();
    agent_->vrf_assign_table()->Clear();
    agent_->vxlan_table()->Clear();
    agent_->service_instance_table()->Clear();
    agent_->mp_table()->Clear();
#endif

    route_preference_module_->Shutdown();
    domain_config_->Terminate();
    if (vrouter_.get()) {
        vrouter_->Shutdown();
        vrouter_.reset();
    }
    if (agent()->mirror_table()) {
        agent()->mirror_table()->Shutdown();
    }

    if (agent()->vxlan_table()) {
        agent()->vxlan_table()->Shutdown();
    }

    //route_walk_manager_.reset();
    profile_.reset();
    route_leak_manager_.reset();
    vxlan_routing_manager_.reset();
    hbf_handler_.reset();
}

void OperDB::DeleteRoutes() {
    agent_->vrf_table()->DeleteRoutes();
}