vrf.cc

Go to the documentation of this file.

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

#include <cmn/agent_cmn.h>

#include <base/lifetime.h>
#include <base/parse_object.h>
#include <ifmap/ifmap_link.h>
#include <ifmap/ifmap_table.h>

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

#include <init/agent_init.h>
#include <cfg/cfg_init.h>
#include <route/route.h>
#include <oper/route_common.h>
#include <oper/vn.h>
#include <oper/vrf.h>
#include <oper/peer.h>
#include <oper/mirror_table.h>
#include <oper/agent_route_walker.h>
#include <controller/controller_init.h>
#include <controller/controller_vrf_export.h>
#include <oper/agent_sandesh.h>
#include <oper/nexthop.h>
#include <oper/config_manager.h>
#include <oper/agent_route_resync.h>
#include <resource_manager/resource_manager.h>
#include <resource_manager/mpls_index.h>
#include <resource_manager/vrf_index.h>

#define MAX_VRF_DELETE_TIMEOUT_RETRY_COUNT 10

using namespace std;
using namespace autogen;

VrfTable *VrfTable::vrf_table_;

class VrfEntry::DeleteActor : public LifetimeActor {
  public:
    DeleteActor(VrfEntry *vrf) :
        LifetimeActor((static_cast<VrfTable *>(vrf->get_table()))->
                      agent()->lifetime_manager()), table_(vrf, this) {
    }
    virtual ~DeleteActor() {
    }
    virtual bool MayDelete() const {
        //No table present, then this VRF can be deleted
        return table_->AllRouteTableDeleted();
    }
    virtual void Shutdown() {
    }
    virtual void Destroy() {
        table_->SendObjectLog(AgentLogEvent::DEL);
        table_ = NULL;
    }

  private:
    VrfEntryRef table_;
};

VrfEntry::VrfEntry(const string &name, uint32_t flags, Agent *agent) :
        name_(name), id_(kInvalidIndex), flags_(flags),
        walkid_(DBTableWalker::kInvalidWalkerId), deleter_(NULL),
        rt_table_db_(), delete_timeout_timer_(NULL),
        table_label_(MplsTable::kInvalidLabel),
        vxlan_id_(VxLanTable::kInvalidvxlan_id),
        rt_table_delete_bmap_(0),
        route_resync_walker_(NULL), allow_route_add_on_deleted_vrf_(false),
        layer2_control_word_(false),
        rd_(0), routing_vrf_(false), retries_(0),
        hbf_rintf_(Interface::kInvalidIndex),
        hbf_lintf_(Interface::kInvalidIndex), deleted_(false) {
        nh_.reset();
}

VrfEntry::~VrfEntry() {
    if (id_ != kInvalidIndex) {
        VrfTable *table = static_cast<VrfTable *>(get_table());
        SetNotify();

        //In case of PBB VRF is implictly created, hence upon
        //delete get the bmac VRF and trigger a notify,
        //so that if bridge domain is reused it can be recreated
        if (are_flags_set(VrfData::PbbVrf)) {
            table->VrfReuse(bmac_vrf_name_);
        }
        table->FreeVrfId(id_);
        table->VrfReuse(GetName());
        vrf_node_ptr_ = NULL;
    }
    //Delete timer
    if (delete_timeout_timer_)
        TimerManager::DeleteTimer(delete_timeout_timer_);
}

bool VrfEntry::IsLess(const DBEntry &rhs) const {
    const VrfEntry &a = static_cast<const VrfEntry &>(rhs);
    return (name_ < a.name_);
}

string VrfEntry::ToString() const {
    return "VRF";
}

bool VrfEntry::UpdateVxlanId(Agent *agent, uint32_t new_vxlan_id) {
    bool ret = false;
    if (new_vxlan_id == vxlan_id_) {
        return ret;
    }

    vxlan_id_ = new_vxlan_id;
    return ret;
}

void VrfEntry::CreateTableLabel(bool learning_enabled, bool l2,
                                bool flood_unknown_unicast,
                                bool layer2_control_word) {
    l2_ = l2;
    VrfTable *table = static_cast<VrfTable *>(get_table());
    Agent *agent = table->agent();

    // Create VrfNH and assign label from it
    DBRequest nh_req;
    nh_req.oper = DBRequest::DB_ENTRY_ADD_CHANGE;
    VrfNHKey *vrf_nh_key = new VrfNHKey(name_, false, l2);
    nh_req.key.reset(vrf_nh_key);
    nh_req.data.reset(new VrfNHData(flood_unknown_unicast, learning_enabled,
                                    layer2_control_word));
    agent->nexthop_table()->Process(nh_req);

    // Get label from nh
    NextHop *nh = static_cast<NextHop *>(
        agent->nexthop_table()->FindActiveEntry(vrf_nh_key));
    nh_ = nh;
    set_table_label(nh->mpls_label()->label());
}

void VrfEntry::CreateRouteTables() {
    DB *db = get_table()->database();
    VrfTable *table = static_cast<VrfTable *>(get_table());

    for (uint8_t type = (Agent::INVALID + 1); type < Agent::ROUTE_TABLE_MAX; type++) {
        rt_table_db_[type] = static_cast<AgentRouteTable *>
            (db->CreateTable(name_ +
                 AgentRouteTable::GetSuffix(Agent::RouteTableType(type))));
        rt_table_db_[type]->SetVrf(this);
        table->dbtree_[type].insert(VrfTable::VrfDbPair(name_, rt_table_db_[type]));
    }
}

void VrfEntry::DeleteRouteTables() {
    for (int table_type = (Agent::INVALID + 1);
         table_type < Agent::ROUTE_TABLE_MAX; table_type++) {
        VrfTable *vrf_table = ((VrfTable *) get_table());
        AgentRouteTable *route_table =
            vrf_table->GetRouteTable(name_, table_type);
        if (route_table) {
            vrf_table->DeleteFromDbTree(table_type, name_);
            vrf_table->database()->RemoveTable(route_table);
            delete route_table;
        }
    }
}

void VrfEntry::PostAdd() {
    VrfTable *table = static_cast<VrfTable *>(get_table());
    Agent *agent = table->agent();
    // get_table() would return NULL in Add(), so move dependent functions and
    // initialization to PostAdd
    deleter_.reset(new DeleteActor(this));
    if (route_resync_walker_.get() == NULL) {
        route_resync_walker_ = new AgentRouteResync("VrfRouteResyncWalker",
                                                    agent);
        agent->oper_db()->agent_route_walk_manager()->
            RegisterWalker(static_cast<AgentRouteWalker *>
                           (route_resync_walker_.get()));
    }
    // Create the route-tables and insert them into dbtree_
    CreateRouteTables();

    uint32_t vxlan_id = VxLanTable::kInvalidvxlan_id;
    if (vn_) {
        vxlan_id = vn_->GetVxLanId();
    }
    UpdateVxlanId(agent, vxlan_id);

    // Add the L2 Receive routes for VRRP mac
    BridgeAgentRouteTable *l2_table = static_cast<BridgeAgentRouteTable *>
        (rt_table_db_[Agent::BRIDGE]);
    l2_table->AddBridgeReceiveRoute(agent->local_vm_peer(), name_, 0,
                                    agent->vrrp_mac(), "");
    l2_table->AddBridgeReceiveRoute(agent->local_peer(), name_,
                                    agent->left_si_mac(), "", "pkt0", true);
    l2_table->AddBridgeReceiveRoute(agent->local_peer(), name_,
                                    agent->right_si_mac(), "", "pkt0", true);

    // Add the L2 Receive routes for xconnect interface to vhost
    // Note, vhost is not created when fabric VRF is created. We only need
    // VRRP MAC on fabric vrf. So, we are good for now
    const VmInterface *vhost = dynamic_cast<const VmInterface *>
        (agent->vhost_interface());
    if (vhost && vhost->parent_list().empty() == false) {
        for (size_t i = 0; i < vhost->parent_list().size(); i++) {
            l2_table->AddBridgeReceiveRoute(agent->local_vm_peer(), name_, 0,
                    vhost->parent_list()[i]->mac(), "");
        }
    }

    //Add receive route for vmware physical interface mac, so
    //that packets hitting this mac gets routed(inter-vn traffic)
    if (agent->isVmwareMode()) {
        PhysicalInterfaceKey key(agent->params()->vmware_physical_port());
        Interface *intf = static_cast<Interface *>
            (agent->interface_table()->FindActiveEntry(&key));
        if (intf) {
             l2_table->AddBridgeReceiveRoute(agent->local_vm_peer(), name_, 0,
                                             intf->mac(), "");
        }
    }

    SendObjectLog(AgentLogEvent::ADD);
}

DBEntryBase::KeyPtr VrfEntry::GetDBRequestKey() const {
    VrfKey *key = new VrfKey(name_);
    return DBEntryBase::KeyPtr(key);
}

void VrfEntry::SetKey(const DBRequestKey *key) {
    const VrfKey *k = static_cast<const VrfKey *>(key);
    name_ = k->name_;
}

InetUnicastRouteEntry *VrfEntry::GetUcRoute(const IpAddress &addr) const {
    InetUnicastAgentRouteTable *table = NULL;
    if (addr.is_v4()) {
        table = GetInet4UnicastRouteTable();
    } else if (addr.is_v6()) {
        table = GetInet6UnicastRouteTable();
    }
    if (table == NULL)
        return NULL;

    return table->FindLPM(addr);
}

InetUnicastRouteEntry *VrfEntry::GetUcRoute(const InetUnicastRouteEntry &rt_key) const {
    InetUnicastAgentRouteTable *table = NULL;

    if (rt_key.prefix_address().is_v4()) {
        table = GetInet4UnicastRouteTable();
    } else if (rt_key.prefix_address().is_v6()) {
        table = GetInet6UnicastRouteTable();
    }
    if (table == NULL)
        return NULL;

    return table->FindLPM(rt_key);
}

LifetimeActor *VrfEntry::deleter() {
    return deleter_.get();
}

bool VrfEntry::AllRouteTableDeleted() const {
    for (int i = Agent::INET4_UNICAST; i < Agent::ROUTE_TABLE_MAX; i++) {
        if ((rt_table_delete_bmap_ & (1 << i)) == 0)
            return false;
    }

    return true;
}

bool VrfEntry::RouteTableDeleted(uint8_t table_type) const {
    return (rt_table_delete_bmap_ & (1 << table_type));
}

void VrfEntry::SetRouteTableDeleted(uint8_t table_type) {
    rt_table_delete_bmap_ |= (1 << table_type);
}

AgentRouteTable *VrfEntry::GetRouteTable(uint8_t table_type) const {
    return (RouteTableDeleted(table_type) ? NULL : rt_table_db_[table_type]);
}

const std::string VrfEntry::GetTableTypeString(uint8_t table_type) const {
    switch (table_type) {
      case Agent::INET4_UNICAST: {
          return "inet4_unicast";
          break;
      }
      case Agent::INET4_MPLS: {
          return "inet4_mpls";
          break;
      }
      case Agent::INET6_UNICAST: {
          return "inet6_unicast";
          break;
      }
      case Agent::INET4_MULTICAST: {
          return "inet4_multicast";
          break;
      }
      case Agent::BRIDGE: {
          return "bridge";
          break;
      }
      case Agent::EVPN: {
          return "evpn";
          break;
      }
    }
    return "None";
}

InetUnicastAgentRouteTable *VrfEntry::GetInet4UnicastRouteTable() const {
    return static_cast<InetUnicastAgentRouteTable *>(GetRouteTable(Agent::INET4_UNICAST));
}

InetUnicastAgentRouteTable *VrfEntry::GetInet4MplsUnicastRouteTable() const {
    return static_cast<InetUnicastAgentRouteTable *>(GetRouteTable(Agent::INET4_MPLS));
}
AgentRouteTable *VrfEntry::GetInet4MulticastRouteTable() const {
    return GetRouteTable(Agent::INET4_MULTICAST);
}

AgentRouteTable *VrfEntry::GetEvpnRouteTable() const {
    return GetRouteTable(Agent::EVPN);
}

AgentRouteTable *VrfEntry::GetBridgeRouteTable() const {
    return GetRouteTable(Agent::BRIDGE);
}

InetUnicastAgentRouteTable *VrfEntry::GetInet6UnicastRouteTable() const {
    return static_cast<InetUnicastAgentRouteTable *>(GetRouteTable(Agent::INET6_UNICAST));
}

bool VrfEntry::DBEntrySandesh(Sandesh *sresp, std::string &name) const {
    VrfListResp *resp = static_cast<VrfListResp *>(sresp);

    if (name.empty() || GetName().find(name) != string::npos) {
        VrfSandeshData data;
        data.set_name(GetName());
        data.set_ucindex(vrf_id());
        data.set_mcindex(vrf_id());
        data.set_evpnindex(vrf_id());
        data.set_l2index(vrf_id());
        data.set_brindex(vrf_id());
        data.set_uc6index(vrf_id());
        std::string vrf_flags;
        if (flags() & VrfData::ConfigVrf)
            vrf_flags += "Config; ";
        if (flags() & VrfData::GwVrf)
            vrf_flags += "Gateway; ";
        if (flags() & VrfData::PbbVrf)
            vrf_flags += "PBB C-Vrf";
        data.set_source(vrf_flags);
        if (vn_.get()) {
            data.set_vn(vn_->GetName());
        } else {
            data.set_vn("N/A");
        }
        data.set_table_label(table_label());
        VrfTable *table = static_cast<VrfTable *>(get_table());
        stringstream rd;
        rd << table->agent()->compute_node_ip().to_string() << ":" <<
            RDInstanceId(table->agent()->tor_agent_enabled());
        data.set_RD(rd.str());

        std::vector<VrfSandeshData> &list =
                const_cast<std::vector<VrfSandeshData>&>(resp->get_vrf_list());
        data.set_vxlan_id(vxlan_id_);
        data.set_mac_aging_time(mac_aging_time_);
        data.set_layer2_control_word(layer2_control_word_);
        if (forwarding_vrf_.get()) {
            data.set_forwarding_vrf(forwarding_vrf_->name_);
        }
        data.set_hbf_rintf(hbf_rintf());
        data.set_hbf_lintf(hbf_lintf());
        list.push_back(data);
        return true;
    }

    return false;
}

void VrfEntry::SendObjectLog(AgentLogEvent::type event) const {
    VrfObjectLogInfo vrf;
    string str;
    switch (event) {
        case AgentLogEvent::ADD:
            str.assign("Addition ");
            break;
        case AgentLogEvent::DEL:
            str.assign("Deletion ");
            break;
        case AgentLogEvent::CHANGE:
            str.assign("Modification ");
            break;
        case AgentLogEvent::DELETE_TRIGGER:
            str.assign("Deletion Triggered ");
            break;
        default:
            str.assign("");
            break;
    }
    vrf.set_event(str);
    vrf.set_name(name_);
    vrf.set_index(id_);
    VRF_OBJECT_LOG_LOG("AgentVrf", SandeshLevel::SYS_INFO, vrf);
}

bool VrfEntry::DeleteTimeout() {
    uint32_t num_routes = 0;
    for (uint8_t type = (Agent::INVALID + 1);
         type < Agent::ROUTE_TABLE_MAX;
         type++) {
        num_routes += rt_table_db_[type]->Size();
    }
    if (num_routes) {
        std::ostringstream str;
        str << "Unicast routes: " << rt_table_db_[Agent::INET4_UNICAST]->Size();
        str << "Unicast MPLS routes: " << rt_table_db_[Agent::INET4_MPLS]->Size();
        str << " Mutlicast routes: " << rt_table_db_[Agent::INET4_MULTICAST]->Size();
        str << " EVPN routes: " << rt_table_db_[Agent::EVPN]->Size();
        str << " Bridge routes: " << rt_table_db_[Agent::BRIDGE]->Size();
        str << "Unicast v6 routes: " << rt_table_db_[Agent::INET6_UNICAST]->Size();
        str << " Reference: " << GetRefCount();
        OPER_TRACE_ENTRY(Vrf, static_cast<const AgentDBTable *>(get_table()),
                        "VRF delete failed, " + str.str(), name_);
        assert(0);
        return false;
    }

    // if number of routes is 0, and VRF ref count is non zero
    // then only reschedule delete timout
    if (retries_ >= MAX_VRF_DELETE_TIMEOUT_RETRY_COUNT) {
        OPER_TRACE_ENTRY(Vrf, static_cast<const AgentDBTable *>(get_table()),
                "VRF delete failed with max retries", name_);
        assert(0);
        return false;
    }
    retries_ = retries_+1;
    return true;
}

void VrfEntry::StartDeleteTimer() {
    Agent *agent = (static_cast<VrfTable *>(get_table()))->agent();
    delete_timeout_timer_ = TimerManager::CreateTimer(
                                *(agent->event_manager())->io_service(),
                                "VrfDeleteTimer");
    delete_timeout_timer_->Start(kDeleteTimeout,
                                 boost::bind(&VrfEntry::DeleteTimeout,
                                 this));
}

void VrfEntry::CancelDeleteTimer() {
    delete_timeout_timer_->Cancel();
}

bool VrfEntry::ResetVrfDelete() {
    delete_reuse_mutex_.lock();
    if (deleted_ == true) {
        delete_reuse_mutex_.unlock();
        return false;
    }
    if (AllRouteTablesEmpty()) {
        if (!AllRouteTableDeleted() ||
            deleter_->HasRefcount() ||
            deleter_->HasDependents()) {
            delete_reuse_mutex_.unlock();
            return false;
        }
        if (route_resync_walker_.get() != NULL) {
            if (route_resync_walker_.get()->refcount() > 1 ||
                route_resync_walker_.get()->IsValidDeleteWalkRef() ||
                route_resync_walker_.get()->IsValidVrfWalkRef() ||
                route_resync_walker_.get()->IsDeregisterDone() == false) {
                delete_reuse_mutex_.unlock();
                return false;
            }
        }
        ClearDelete();
        delete_reuse_mutex_.unlock();
        CancelDeleteTimer();
        rt_table_delete_bmap_ = 0;
        DeleteRouteTables();
        deleter_.reset(new DeleteActor(this));
        CreateRouteTables();
        VrfTable *table = static_cast<VrfTable *>(get_table());
        Agent *agent = table->agent();
        route_resync_walker_.reset(new AgentRouteResync("VrfRouteResyncWalker",
                                   agent));
        agent->oper_db()->agent_route_walk_manager()->
            RegisterWalker(static_cast<AgentRouteWalker *>
                    (route_resync_walker_.get()));
        SetNotify();
        table->VrfReuse(GetName());
        vrf_node_ptr_ = NULL;
        retries_ = 0;
        if (delete_timeout_timer_)
            TimerManager::DeleteTimer(delete_timeout_timer_);

        OPER_TRACE_ENTRY(Vrf, static_cast<const AgentDBTable *>(get_table()),
            "Reset Vrf Deletion", GetName());
        return true;
    }
    delete_reuse_mutex_.unlock();
    return false;
}

void VrfEntry::ResyncRoutes() {
    (static_cast<AgentRouteResync *>(route_resync_walker_.get()))->
        UpdateRoutesInVrf(this);
}

// Used to decide RD to be sent to CN for this VRF.
// In non tor-agent case vrf-id generated is used.
// However in tor-agent vn id(network-id) is used. This is because both active
// and backup TA can publish same route which will be sent to BGP router peered
// to CN. If both these TA end up generating different vrf-id for same Vrf, then
// RD using vrf_id will be different. Hence BGP router will get same route with
// two different RD causing undefined behavior.
// To avoid this both TA should generate same RD. As VN id is generated by config
// it is unique and common across both TA so same can be used.
int VrfEntry::RDInstanceId(bool tor_agent_enabled) const {
    if (tor_agent_enabled == false) {
        return id_;
    }

    if (vn() == NULL)
        return kInvalidIndex;

    if (vn()->vnid() == 0)
        return kInvalidIndex;

    return vn()->vnid();
}

void VrfEntry::RetryDelete() {
    if (AllRouteTablesEmpty() == false)
        return;

    // Enqueue a DB Request to notify the entry, entry should always be
    // notified in db::DBTable task context
    DBRequest req(DBRequest::DB_ENTRY_NOTIFY);
    req.key = GetDBRequestKey();
    (static_cast<VrfTable *>(get_table()))->Enqueue(&req);
}

bool VrfEntry::AllRouteTablesEmpty() const {
    for (uint8_t type = (Agent::INVALID + 1);
         type < Agent::ROUTE_TABLE_MAX;
         type++) {
        if (rt_table_db_[type]->empty() == false) {
            return false;
        }
    }
    return true;
}

void VrfEntry::ReleaseWalker() {
    if (route_resync_walker_.get() != NULL) {
        VrfTable *table = static_cast<VrfTable *>(get_table());
        table->agent()->oper_db()->agent_route_walk_manager()->
            ReleaseWalker(route_resync_walker_.get());
    }
}

InetUnicastAgentRouteTable *
VrfEntry::GetInetUnicastRouteTable(const IpAddress &addr) const {
    if (addr.is_v4())
        return static_cast<InetUnicastAgentRouteTable *>
            (GetInet4UnicastRouteTable());
    return static_cast<InetUnicastAgentRouteTable *>
        (GetInet6UnicastRouteTable());
}

void VrfEntry::SetNotify() {
    VrfTable *table = static_cast<VrfTable *>(get_table());
    if (vrf_node_ptr_) {
        IFMapDependencyManager *dep = table->agent()->
            oper_db()->dependency_manager();
        IFMapNodeState *state = vrf_node_ptr_.get();
        dep->SetNotify(state->node(), true);
    }
}

class VrfDeleteWalker : public AgentRouteWalker {
public:
    VrfDeleteWalker(const std::string &name, Agent *agent) :
        AgentRouteWalker(name, agent) {
    }

    ~VrfDeleteWalker() { }

    //Override vrf notification
    bool VrfWalkNotify(DBTablePartBase *partition, DBEntryBase *e) {
        DBRequest req(DBRequest::DB_ENTRY_DELETE);
        req.key = e->GetDBRequestKey();
        (static_cast<VrfTable *>(e->get_table()))->Process(req);
        return true;
    }

    //Override route notification
    bool RouteWalkNotify(DBTablePartBase *partition, DBEntryBase *e) {
        assert(0);
        return false;
    }

    static void WalkDone(VrfDeleteWalker *walker) {
        walker->mgr()->ReleaseWalker(walker);
        walker->agent()->vrf_table()->reset_vrf_delete_walker();
    }

private:
};

void VrfTable::FreeVrfId(size_t index) {
    agent()->resource_manager()->Release(Resource::VRF_INDEX, index);
    index_table_.Remove(index);
};
void VrfTable::Clear() {
    if (route_delete_walker_.get())
        agent()->oper_db()->agent_route_walk_manager()->
            ReleaseWalker(route_delete_walker_.get());
    if (vrf_delete_walker_.get() != NULL)
        agent()->oper_db()->agent_route_walk_manager()->
            ReleaseWalker(vrf_delete_walker_.get());
}

std::unique_ptr<DBEntry> VrfTable::AllocEntry(const DBRequestKey *k) const {
    const VrfKey *key = static_cast<const VrfKey *>(k);
    VrfEntry *vrf = new VrfEntry(key->name_, 0, agent());
    return std::unique_ptr<DBEntry>(static_cast<DBEntry *>(vrf));
}

VrfTable::~VrfTable() {
}

DBEntry *VrfTable::OperDBAdd(const DBRequest *req) {
    VrfKey *key = static_cast<VrfKey *>(req->key.get());
    VrfData *data = static_cast<VrfData *>(req->data.get());
    VrfEntry *vrf = new VrfEntry(key->name_, data->flags_, agent());

    // Add VRF into name based tree
    if (FindVrfFromName(key->name_)) {
        delete vrf;
        assert(0);
        return NULL;
    }
    if (vrf) {
        ResourceManager::KeyPtr rkey(new VrfIndexResourceKey(
                                     agent()->resource_manager(), key->name_));
        vrf->id_ = static_cast<IndexResourceData *>(agent()->resource_manager()->
                                                    Allocate(rkey).get())->index();
        index_table_.InsertAtIndex(vrf->id_, vrf);
    }
    name_tree_.insert( VrfNamePair(key->name_, vrf));

    vrf->vn_.reset(agent()->vn_table()->Find(data->vn_uuid_));
    if (vrf->vn_) {
        vrf->set_routing_vrf(vrf->vn_->vxlan_routing_vn());
    }

    vrf->si_vn_ref_.reset(agent()->vn_table()->Find(data->si_vn_ref_uuid_));

    vrf->isid_ = data->isid_;
    vrf->bmac_vrf_name_ = data->bmac_vrf_name_;
    vrf->learning_enabled_ = data->learning_enabled_;
    vrf->mac_aging_time_ = data->mac_aging_time_;
    vrf->set_hbf_rintf(data->hbf_rintf_);
    vrf->set_hbf_lintf(data->hbf_lintf_);
    if (vrf->vn_.get()) {
        vrf->layer2_control_word_ = vrf->vn_->layer2_control_word();
    }
    vrf->set_rd(vrf->RDInstanceId(agent()->tor_agent_enabled()));
    if (data->forwarding_vrf_name_ != Agent::NullString()) {
        vrf->forwarding_vrf_ = FindVrfFromName(data->forwarding_vrf_name_);
    }
    return vrf;
}

bool VrfTable::OperDBOnChange(DBEntry *entry, const DBRequest *req) {
    bool ret = false;
    VrfEntry *vrf = static_cast<VrfEntry *>(entry);
    VrfData *data = static_cast<VrfData *>(req->data.get());
    vrf->set_flags(data->flags_);

    if (vrf->are_flags_set(VrfData::PbbVrf)) {
        if (FindVrfFromName(vrf->bmac_vrf_name_) == NULL) {
            assert(0);
        }
    }

    VnEntry *vn = agent()->vn_table()->Find(data->vn_uuid_);
    bool resync_routes = false;

    if (vn != vrf->vn_.get()) {
        resync_routes = true;
        vrf->vn_.reset(vn);
        ret = true;
    }

    VnEntry *si_vn_ref = agent()->vn_table()->Find(data->si_vn_ref_uuid_);
    if (si_vn_ref != vrf->si_vn_ref_.get()) {
        vrf->si_vn_ref_.reset(si_vn_ref);
    }

    if (data->ifmap_node() && vrf->ifmap_node() != data->ifmap_node()) {
        ret = true;
    }

    bool layer2_control_word = false;
    if (vn) {
        layer2_control_word = vn->layer2_control_word();
    }

    if (vrf->layer2_control_word_ != layer2_control_word) {
        vrf->layer2_control_word_ = layer2_control_word;
        vrf->ResyncRoutes();
        ret = true;
    }

    if (vrf->learning_enabled_ != data->learning_enabled_) {
        vrf->learning_enabled_ = data->learning_enabled_;
        ret = true;
    }

    if (vrf->isid_ != data->isid_) {
        vrf->isid_ = data->isid_;
        ret = true;
    }

    if (vrf->rd() != vrf->RDInstanceId(agent()->tor_agent_enabled())) {
        resync_routes = true;
        vrf->set_rd(vrf->RDInstanceId(agent()->tor_agent_enabled()));
        ret = true;
    }

    if (resync_routes) {
        vrf->ResyncRoutes();
    }

    uint32_t vxlan_id = VxLanTable::kInvalidvxlan_id;
    if (vn) {
        vxlan_id = vn->GetVxLanId();
    }
    vrf->UpdateVxlanId(agent(), vxlan_id);

    if (data && vrf->mac_aging_time_ != data->mac_aging_time_) {
        vrf->mac_aging_time_ = data->mac_aging_time_;
    }

    VrfEntry *forwarding_vrf = NULL;
    if (data->forwarding_vrf_name_ != Agent::NullString()) {
        forwarding_vrf = FindVrfFromName(data->forwarding_vrf_name_);
    }

    if (forwarding_vrf != vrf->forwarding_vrf_) {
        vrf->forwarding_vrf_ = forwarding_vrf;
        ret = true;
    }

    if (vrf->hbf_rintf() != data->hbf_rintf_) {
        vrf->set_hbf_rintf(data->hbf_rintf_);
        ret = true;
    }
    if (vrf->hbf_lintf() != data->hbf_lintf_) {
        vrf->set_hbf_lintf(data->hbf_lintf_);
        ret = true;
    }

    return ret;
}

bool VrfTable::OperDBDelete(DBEntry *entry, const DBRequest *req) {
    VrfEntry *vrf = static_cast<VrfEntry *>(entry);
    VrfData *data = static_cast<VrfData *>(req->data.get());

    // VRF can be created by both config and VGW. VRF cannot be deleted till
    // both config and VGW delete it.
    // We want to retain flags like PbbVrf, hence mask only flags which
    // are needed to delete the VRF
    vrf->flags_ &= ~(data->flags_ & data->ConfigFlags());
    if ((vrf->flags_ & data->ConfigFlags()) != 0)
        return false;

    // Delete the L2 Receive routes added by default
    BridgeAgentRouteTable *l2_table = static_cast<BridgeAgentRouteTable *>
        (vrf->rt_table_db_[Agent::BRIDGE]);
    l2_table->Delete(agent()->local_vm_peer(), vrf->GetName(),
                     agent()->vrrp_mac(), 0);
    l2_table->Delete(agent()->local_peer(), vrf->GetName(),
                     agent()->left_si_mac(), -1);
    l2_table->Delete(agent()->local_peer(), vrf->GetName(),
                     agent()->right_si_mac(), -1);
    const VmInterface *vhost = dynamic_cast<const VmInterface *>
        (agent()->vhost_interface());
    if (vhost && vhost->parent_list().empty() == false) {
        for (size_t i = 0; i < vhost->parent_list().size(); i++) {
            l2_table->Delete(agent()->local_vm_peer(), vrf->GetName(),
                    vhost->parent_list()[i]->mac(), 0);
        }
    }

    if (agent()->isVmwareMode()) {
        PhysicalInterfaceKey key(agent()->params()->vmware_physical_port());
        Interface *intf = static_cast<Interface *>
            (agent()->interface_table()->FindActiveEntry(&key));
        if (intf) {
             l2_table->Delete(agent()->local_vm_peer(), vrf->GetName(),
                              intf->mac(), 0);
        }
    }

    vrf->UpdateVxlanId(agent(), VxLanTable::kInvalidvxlan_id);
    vrf->vn_.reset(NULL);
    if (vrf->table_label() != MplsTable::kInvalidLabel) {
        vrf->nh_.reset();
        vrf->set_table_label(MplsTable::kInvalidLabel);
    }
    vrf->deleter_->Delete();
    vrf->StartDeleteTimer();
    vrf->SendObjectLog(AgentLogEvent::DELETE_TRIGGER);


    if (vrf->ifmap_node()) {
        IFMapDependencyManager *dep = agent()->oper_db()->dependency_manager();
        vrf->vrf_node_ptr_ = dep->SetState(vrf->ifmap_node());
        dep->SetNotify(vrf->ifmap_node(), false);
    }
    vrf->ReleaseWalker();

    return true;
}

void VrfTable::VrfReuse(const std::string  name) {
    IFMapTable::RequestKey req_key;
    req_key.id_type = "routing-instance";
    req_key.id_name = name;
    IFMapNode *node = IFMapAgentTable::TableEntryLookup(database(), &req_key);

    if (!node || node->IsDeleted()) {
        return;
    }

    OPER_TRACE(Vrf, "Resyncing configuration for VRF: ", name);
    agent()->config_manager()->NodeResync(node);
}

void VrfTable::OnZeroRefcount(AgentDBEntry *e) {
    VrfEntry *vrf = static_cast<VrfEntry *>(e);
    tbb::mutex::scoped_lock lock(vrf->delete_reuse_mutex_);
    if (e->IsDeleted()) {
        vrf->DeleteRouteTables();
        name_tree_.erase(vrf->GetName());
        vrf->CancelDeleteTimer();
    vrf->deleted_ = true;
    }
}

DBTableBase *VrfTable::CreateTable(DB *db, const std::string &name) {
    vrf_table_ = new VrfTable(db, name);
    vrf_table_->Init();
    return vrf_table_;
};

VrfEntry *VrfTable::FindVrfFromName(const string &name) {
    VrfNameTree::const_iterator it;

    it = name_tree_.find(name);
    if (it == name_tree_.end()) {
        return NULL;
    }

    return static_cast<VrfEntry *>(it->second);
}

VrfEntry *VrfTable::FindVrfFromId(size_t index) {
    VrfEntry *vrf = index_table_.At(index);
    if (vrf && vrf->IsDeleted() == false) {
        return vrf;
    }
    return NULL;
}

VrfEntry *VrfTable::FindVrfFromIdIncludingDeletedVrf(size_t index) {
    VrfEntry *vrf = index_table_.At(index);
    return vrf;
}

InetUnicastAgentRouteTable *VrfTable::GetInet4UnicastRouteTable
    (const string &vrf_name) {
    return static_cast<InetUnicastAgentRouteTable *>
        (GetRouteTable(vrf_name, Agent::INET4_UNICAST));
}

InetUnicastAgentRouteTable *VrfTable::GetInet4MplsUnicastRouteTable
    (const string &vrf_name) {
    return static_cast<InetUnicastAgentRouteTable *>
        (GetRouteTable(vrf_name, Agent::INET4_MPLS));
}

AgentRouteTable *VrfTable::GetInet4MulticastRouteTable(const string &vrf_name) {
    return GetRouteTable(vrf_name, Agent::INET4_MULTICAST);
}

AgentRouteTable *VrfTable::GetEvpnRouteTable(const string &vrf_name) {
    return GetRouteTable(vrf_name, Agent::EVPN);
}

AgentRouteTable *VrfTable::GetBridgeRouteTable(const string &vrf_name) {
    return GetRouteTable(vrf_name, Agent::BRIDGE);
}

InetUnicastAgentRouteTable *VrfTable::GetInet6UnicastRouteTable
    (const string &vrf_name) {
    return static_cast<InetUnicastAgentRouteTable *>
        (GetRouteTable(vrf_name, Agent::INET6_UNICAST));
}

AgentRouteTable *VrfTable::GetRouteTable(const string &vrf_name,
                                         uint8_t table_type) {
    VrfDbTree::const_iterator it;

    it = dbtree_[table_type].find(vrf_name);
    if (it == dbtree_[table_type].end()) {
        return NULL;
    }

    return static_cast<AgentRouteTable *>(it->second);
}

void VrfTable::CreateVrfReq(const string &name, uint32_t flags) {
    DBRequest req(DBRequest::DB_ENTRY_ADD_CHANGE);
    req.key.reset(new VrfKey(name));
    req.data.reset(new VrfData(agent(), NULL, flags, boost::uuids::nil_uuid(),
                               0, "", 0, false));
    Enqueue(&req);
}

void VrfTable::CreateVrfReq(const string &name,
                            const boost::uuids::uuid &vn_uuid,
                            uint32_t flags) {
    DBRequest req(DBRequest::DB_ENTRY_ADD_CHANGE);
    req.key.reset(new VrfKey(name));
    req.data.reset(new VrfData(agent(), NULL, flags, vn_uuid,
                               0, "", 0, false));
    Enqueue(&req);
}

void VrfTable::CreateVrf(const string &name, const boost::uuids::uuid &vn_uuid,
                         uint32_t flags, uint32_t isid,
                         const std::string &bmac_vrf_name,
                         uint32_t aging_timeout,
                         bool learning_enabled) {
    DBRequest req(DBRequest::DB_ENTRY_ADD_CHANGE);
    req.key.reset(new VrfKey(name));
    req.data.reset(new VrfData(agent(), NULL, flags, vn_uuid, isid,
                               bmac_vrf_name, aging_timeout,
                               learning_enabled));
    Process(req);
}

void VrfTable::CreateVrf(const string &name,
                         const boost::uuids::uuid &vn_uuid,
                         uint32_t flags) {
    DBRequest req(DBRequest::DB_ENTRY_ADD_CHANGE);
    req.key.reset(new VrfKey(name));
    req.data.reset(new VrfData(agent(), NULL, flags, vn_uuid, 0,
                               "", 0, false));
    Process(req);
}
void VrfTable::DeleteVrfReq(const string &name, uint32_t flags) {
    DBRequest req(DBRequest::DB_ENTRY_DELETE);
    req.key.reset(new VrfKey(name));
    req.data.reset(new VrfData(agent(), NULL, flags, boost::uuids::nil_uuid(),
                               0, "", 0, false));
    Enqueue(&req);
}

void VrfTable::DeleteVrf(const string &name, uint32_t flags) {
    DBRequest req(DBRequest::DB_ENTRY_DELETE);
    req.key.reset(new VrfKey(name));
    req.data.reset(new VrfData(agent(), NULL, flags, boost::uuids::nil_uuid(),
                               0, "", 0, false));
    Process(req);
}

void VrfTable::CreateStaticVrf(const string &name) {
    static_vrf_set_.insert(name);
    CreateVrf(name, boost::uuids::nil_uuid(), VrfData::ConfigVrf);
}

void VrfTable::CreateFabricPolicyVrf(const string &name) {
    static_vrf_set_.insert(name);
    DBRequest req(DBRequest::DB_ENTRY_ADD_CHANGE);
    req.key.reset(new VrfKey(name));
    VrfData *data = new VrfData(agent(), NULL, VrfData::ConfigVrf,
                                boost::uuids::nil_uuid(), 0, "", 0, false);
    data->forwarding_vrf_name_ = agent()->fabric_vrf_name();
    req.data.reset(data);
    Process(req);
}

void VrfTable::DeleteStaticVrf(const string &name) {
    static_vrf_set_.erase(name);
    DeleteVrfReq(name);
}

void VrfTable::DeleteFromDbTree(int table_type, const std::string &vrf_name) {
    dbtree_[table_type].erase(vrf_name);
}

void VrfTable::Input(DBTablePartition *partition, DBClient *client,
                     DBRequest *req) {

    VrfKey *key = static_cast<VrfKey *>(req->key.get());
    VrfEntry *entry = static_cast<VrfEntry *>(partition->Find(key));

    if (entry && entry->IsDeleted()) {
        if (req->oper != DBRequest::DB_ENTRY_NOTIFY) {
            OPER_TRACE(Vrf, "VRF pending delete, Ignoring DB operation for ",
                       entry->GetName());
            return;
        } else {
            // Allow DB Operation for DB Entry Notify, along with
            // validation for sub op as ADD_DEL_CHANGE
            AgentKey *key = static_cast<AgentKey *>(req->key.get());
            assert(key->sub_op_ == AgentKey::ADD_DEL_CHANGE);
        }
    }

    AgentDBTable::Input(partition, client, req);
    return;
}

static void FindHbfInterfacesFromHBS(Agent* agent, IFMapNode *node,
                              uint32_t &hbf_rintf, uint32_t &hbf_lintf) {
    IFMapAgentTable *table = static_cast<IFMapAgentTable *>(node->table());
    DBGraph *graph = table->GetGraph();

    for (DBGraphVertex::edge_iterator iter = node->edge_list_begin(graph);
         iter != node->edge_list_end(graph); ++iter) {
        if (iter->IsDeleted()) {
            continue;
        }
        IFMapNode *adj_node = static_cast<IFMapNode *>(iter.target());

        if (!strcmp(adj_node->table()->Typename(),
                    "host-based-service-virtual-network")) {
            autogen::HostBasedServiceVirtualNetwork *hbsvn =
                static_cast<HostBasedServiceVirtualNetwork *>
                (adj_node->GetObject());
            ServiceVirtualNetworkType type = hbsvn->data();

            for (DBGraphVertex::adjacency_iterator iter =
                 adj_node->begin(graph);
                 iter != node->end(graph); ++iter) {
                 IFMapNode *hbsvn_adj_node =
                         static_cast<IFMapNode *>(iter.operator->());
                 if (!strcmp(hbsvn_adj_node->table()->Typename(),
                             "virtual-network")) {
                     for (DBGraphVertex::adjacency_iterator iter =
                                                   hbsvn_adj_node->begin(graph);
                          iter != node->end(graph); ++iter) {
                         if (iter->IsDeleted()) {
                            continue;
                         }
                         IFMapNode *vmi_node =
                             static_cast<IFMapNode *>(iter.operator->());
                         if (!strcmp(vmi_node->table()->Typename(),
                                    "virtual-machine-interface")) {
                             VirtualMachineInterface *cfg =
                                 static_cast <VirtualMachineInterface *>
                                                      (vmi_node->GetObject());
                             autogen::IdPermsType id_perms = cfg->id_perms();
                             boost::uuids::uuid u;
                             CfgUuidSet(id_perms.uuid.uuid_mslong,
                                        id_perms.uuid.uuid_lslong, u);
                             InterfaceConstRef intf =
                                 agent->interface_table()->FindVmi(u);
                             if (!intf) {
                                 continue;
                             }
                             if (!strcmp(type.virtual_network_type.c_str(),
                                         "right")) {
                                 hbf_rintf = intf->id();
                             } else if (!strcmp(
                                 type.virtual_network_type.c_str(), "left")) {
                                 hbf_lintf = intf->id();
                             }
                         }
                     }
                }
            }
        }
    }
}

static void FindHbfInterfacesFromProject(Agent* agent, IFMapNode *node,
                              uint32_t &hbf_rintf, uint32_t &hbf_lintf) {
    IFMapAgentTable *table = static_cast<IFMapAgentTable *>(node->table());
    DBGraph *graph = table->GetGraph();

    for (DBGraphVertex::adjacency_iterator iter = node->begin(graph);
         iter != node->end(graph); ++iter) {
        if (iter->IsDeleted()) {
            continue;
        }
        IFMapNode *adj_node =
                         static_cast<IFMapNode *>(iter.operator->());

        if (strcmp(adj_node->table()->Typename(), "host-based-service") == 0) {
            FindHbfInterfacesFromHBS(agent, adj_node, hbf_rintf, hbf_lintf);
            break;
        }
    }
}

static void FindHbfInterfacesFromVmi(Agent* agent, IFMapNode *node,
                              uint32_t &hbf_rintf, uint32_t &hbf_lintf) {
    IFMapAgentTable *table = static_cast<IFMapAgentTable *>(node->table());
    DBGraph *graph = table->GetGraph();

    for (DBGraphVertex::adjacency_iterator iter = node->begin(graph);
         iter != node->end(graph); ++iter) {
        if (iter->IsDeleted()) {
            continue;
        }
        IFMapNode *adj_node =
                         static_cast<IFMapNode *>(iter.operator->());

        if (strcmp(adj_node->table()->Typename(), "project") == 0) {
            FindHbfInterfacesFromProject(agent, adj_node, hbf_rintf, hbf_lintf);
            break;
        }
    }
}

static void FindHbfInterfaces(Agent *agent, IFMapNode *vn_node,
                              uint32_t &hbf_rintf, uint32_t &hbf_lintf) {
    IFMapAgentTable *table = static_cast<IFMapAgentTable *>(vn_node->table());
    DBGraph *graph = table->GetGraph();

    for (DBGraphVertex::adjacency_iterator iter = vn_node->begin(graph);
         iter != vn_node->end(graph); ++iter) {
        if (iter->IsDeleted()) {
            continue;
        }
        IFMapNode *adj_node =
                         static_cast<IFMapNode *>(iter.operator->());

        if (strcmp(adj_node->table()->Typename(),
                   "virtual-machine-interface") == 0) {
            FindHbfInterfacesFromVmi(agent, adj_node, hbf_rintf, hbf_lintf);
            break;
        }
    }
}

static void BuildForwardingVrf(Agent *agent, IFMapNode *vn_node,
                               std::string &forwarding_vrf_name) {
    IFMapAgentTable *table = static_cast<IFMapAgentTable *>(vn_node->table());
    DBGraph *graph = table->GetGraph();
    for (DBGraphVertex::adjacency_iterator iter = vn_node->begin(graph);
         iter != vn_node->end(graph); ++iter) {
         IFMapNode *adj_node =
                         static_cast<IFMapNode *>(iter.operator->());
        if (iter->IsDeleted() ||
           (adj_node->table() != agent->cfg()->cfg_vn_table())) {
            continue;
        }

        VirtualNetwork *cfg =
            static_cast <VirtualNetwork *> (adj_node->GetObject());
        if (cfg == NULL) {
            continue;
        }

        if (adj_node->name() == agent->fabric_vn_name()) {
            forwarding_vrf_name = agent->fabric_vrf_name();
        }
    }
}

static VrfData *BuildData(Agent *agent, IFMapNode *node) {
    boost::uuids::uuid vn_uuid = boost::uuids::nil_uuid();
    boost::uuids::uuid si_vn_uuid = boost::uuids::nil_uuid();
    IFMapAgentTable *table = static_cast<IFMapAgentTable *>(node->table());
    DBGraph *graph = table->GetGraph();
    bool learning_enabled = false;
    std::string forwarding_vrf = "";
    uint32_t hbf_rintf = Interface::kInvalidIndex;
    uint32_t hbf_lintf = Interface::kInvalidIndex;

    uint32_t aging_timeout = 0;
    for (DBGraphVertex::adjacency_iterator iter = node->begin(graph);
         iter != node->end(graph); ++iter) {
        IFMapNode *adj_node =
            static_cast<IFMapNode *>(iter.operator->());

        if (iter->IsDeleted() ||
            (adj_node->table() != agent->cfg()->cfg_vn_table())) {
            continue;
        }

        VirtualNetwork *cfg =
            static_cast <VirtualNetwork *> (adj_node->GetObject());
        if (cfg == NULL) {
            continue;
        }

        BuildForwardingVrf(agent, adj_node, forwarding_vrf);

        FindHbfInterfaces(agent, adj_node, hbf_rintf, hbf_lintf);

        if (!IsVRFServiceChainingInstance(adj_node->name(), node->name())) {
            autogen::IdPermsType id_perms = cfg->id_perms();
            CfgUuidSet(id_perms.uuid.uuid_mslong, id_perms.uuid.uuid_lslong,
                       vn_uuid);
            aging_timeout = cfg->mac_aging_time();
            break;
        } else {
            autogen::IdPermsType id_perms = cfg->id_perms();
            CfgUuidSet(id_perms.uuid.uuid_mslong, id_perms.uuid.uuid_lslong,
                       si_vn_uuid);
            break;
        }
    }

    VrfData *vrf_data = new VrfData(agent, node, VrfData::ConfigVrf,
                                    vn_uuid, 0, "",
                                    aging_timeout, learning_enabled,
                                    hbf_rintf, hbf_lintf);
    if (node->name() == agent->fabric_policy_vrf_name()) {
        vrf_data->forwarding_vrf_name_ = agent->fabric_vrf_name();
    } else {
        vrf_data->forwarding_vrf_name_ = forwarding_vrf;
    }

    vrf_data->si_vn_ref_uuid_ = si_vn_uuid;

    return vrf_data;
}

bool VrfTable::IFNodeToReq(IFMapNode *node, DBRequest &req,
        const boost::uuids::uuid &u) {
    //Trigger add or delete only for non fabric VRF
    if ((req.oper == DBRequest::DB_ENTRY_DELETE) || node->IsDeleted()) {
        req.key.reset(new VrfKey(node->name()));
        if (IsStaticVrf(node->name())) {
            //Fabric and link-local VRF will not be deleted,
            //upon config delete
            req.oper = DBRequest::DB_ENTRY_ADD_CHANGE;
        } else {
            req.oper = DBRequest::DB_ENTRY_DELETE;
        }

        VrfData *data = new VrfData(agent(), node, VrfData::ConfigVrf,
                                    boost::uuids::nil_uuid(), 0, "", 0, false);
        if (node->name() == agent()->fabric_policy_vrf_name()) {
            data->forwarding_vrf_name_ = agent()->fabric_vrf_name();
        }
        req.data.reset(data);
        Enqueue(&req);
        return false;
    }

    agent()->config_manager()->AddVrfNode(node);
    return false;
}

bool VrfTable::ProcessConfig(IFMapNode *node, DBRequest &req,
        const boost::uuids::uuid &u) {
    req.key.reset(new VrfKey(node->name()));

    //Trigger add or delete only for non fabric VRF
    if (node->IsDeleted()) {
        if (IsStaticVrf(node->name())) {
            //Fabric and link-local VRF will not be deleted,
            //upon config delete
            req.oper = DBRequest::DB_ENTRY_ADD_CHANGE;
        } else {
            req.oper = DBRequest::DB_ENTRY_DELETE;
        }

        VrfData *data = new VrfData(agent(), node, VrfData::ConfigVrf,
                                    boost::uuids::nil_uuid(), 0, "", 0, false,
                                    Interface::kInvalidIndex,
                                    Interface::kInvalidIndex);
        if (node->name() == agent()->fabric_policy_vrf_name()) {
            data->forwarding_vrf_name_ = agent()->fabric_vrf_name();
        }
        req.data.reset(data);
    } else {
        req.oper = DBRequest::DB_ENTRY_ADD_CHANGE;
        req.data.reset(BuildData(agent(), node));
    }

    //When VRF config delete comes, first enqueue VRF delete
    //so that when link evaluation happens, all point to deleted VRF
    Enqueue(&req);
    return false;
}

void VrfListReq::HandleRequest() const {
    AgentSandeshPtr sand(new AgentVrfSandesh(context(), get_name()));
    sand->DoSandesh(sand);
}

AgentSandeshPtr VrfTable::GetAgentSandesh(const AgentSandeshArguments *args,
                                          const std::string &context) {
    return AgentSandeshPtr(new AgentVrfSandesh(context,
                                               args->GetString("name")));
}

class RouteDeleteWalker : public AgentRouteWalker {
public:
    RouteDeleteWalker(const std::string &name, Agent *agent) :
        AgentRouteWalker(name, agent) {
    }

    ~RouteDeleteWalker() { }

    //Override route notification
    bool RouteWalkNotify(DBTablePartBase *partition, DBEntryBase *e) {
        AgentRoute *rt = static_cast<AgentRoute *>(e);
        for(Route::PathList::const_iterator it = rt->GetPathList().begin();
            it != rt->GetPathList().end(); ) {
            const AgentPath *path =
                static_cast<const AgentPath *>(it.operator->());
            Route::PathList::const_iterator next = ++it;

            DBRequest req(DBRequest::DB_ENTRY_DELETE);
            req.key = e->GetDBRequestKey();
            AgentRouteKey *key = static_cast<AgentRouteKey *>(req.key.get());
            key->peer_ = path->peer();
            (static_cast<AgentRouteTable *>(e->get_table()))->Process(req);
            it = next;
        }

        return true;
    }

    static void WalkDone(RouteDeleteWalker *walker) {
        walk_done_++;
        walker->mgr()->ReleaseWalker(walker);
        walker->agent()->vrf_table()->reset_route_delete_walker();
    }

    static uint32_t walk_start_;
    static uint32_t walk_done_;
};
uint32_t RouteDeleteWalker::walk_start_;
uint32_t RouteDeleteWalker::walk_done_;

void VrfTable::DeleteRoutes() {
    if (route_delete_walker_.get() == NULL) {
        route_delete_walker_ = new RouteDeleteWalker("RouteDeleteWalker",
                                                     agent());
        agent()->oper_db()->agent_route_walk_manager()->
            RegisterWalker(static_cast<AgentRouteWalker *>
                           (route_delete_walker_.get()));
    }
    route_delete_walker_->WalkDoneCallback
        (boost::bind(&RouteDeleteWalker::WalkDone,
                static_cast<RouteDeleteWalker *>(route_delete_walker_.get())));
    route_delete_walker_->StartVrfWalk();
}

void VrfTable::Shutdown() {
    if (vrf_delete_walker_.get() == NULL) {
        vrf_delete_walker_ = new VrfDeleteWalker("VrfDeleteWalker",
                                                 agent());
        agent()->oper_db()->agent_route_walk_manager()->
            RegisterWalker(static_cast<AgentRouteWalker *>
                           (vrf_delete_walker_.get()));
    }
    vrf_delete_walker_.get()->WalkDoneCallback(boost::bind
               (&VrfDeleteWalker::WalkDone,
               static_cast<VrfDeleteWalker *>( vrf_delete_walker_.get())));
    vrf_delete_walker_.get()->StartVrfWalk();
}