vn_ovsdb.cc

Go to the documentation of this file.

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

extern "C" {
#include <ovsdb_wrapper.h>
};

#include <oper/vn.h>
#include <oper/vrf.h>
#include <oper/vxlan.h>
#include <ovsdb_types.h>

#include <unicast_mac_local_ovsdb.h>
#include <multicast_mac_local_ovsdb.h>
#include <vn_ovsdb.h>

using OVSDB::OvsdbDBEntry;
using OVSDB::VnOvsdbEntry;
using OVSDB::VnOvsdbObject;

VnOvsdbEntry::VnOvsdbEntry(VnOvsdbObject *table,
        const boost::uuids::uuid &uuid) : OvsdbDBEntry(table), uuid_(uuid),
        vrf_(NULL, this), vxlan_id_(0), name_("") {
}

void VnOvsdbEntry::AddMsg(struct ovsdb_idl_txn *txn) {
    VnEntry *vn = static_cast<VnEntry *>(GetDBEntry());
    vrf_ = vn->GetVrf();
}

void VnOvsdbEntry::ChangeMsg(struct ovsdb_idl_txn *txn) {
    UnicastMacLocalOvsdb *uc_obj =
        table_->client_idl()->unicast_mac_local_ovsdb();
    // Entries in Unicast Mac Local Table are dependent on vn/vrf
    // and VxLAN ID on Change of this entry trigger Vrf re-eval for
    // entries in Unicast Mac Local Table
    uc_obj->VrfReEvalEnqueue(vrf_.get());

    // Update VRF with the current value.
    VnEntry *vn = static_cast<VnEntry *>(GetDBEntry());
    vrf_ = vn->GetVrf();
}

void VnOvsdbEntry::DeleteMsg(struct ovsdb_idl_txn *txn) {
    UnicastMacLocalOvsdb *uc_obj =
        table_->client_idl()->unicast_mac_local_ovsdb();
    // Entries in Unicast Mac Local Table are dependent on vn/vrf
    // on delete of this entry trigger Vrf re-eval for entries in
    // Unicast Mac Local Table
    uc_obj->VrfReEvalEnqueue(vrf_.get());
    //For multicast vrf delete needs to known for deleting
    //route.
    MulticastMacLocalOvsdb *mc_obj =
        table_->client_idl()->multicast_mac_local_ovsdb();
    mc_obj->VrfReEvalEnqueue(vrf_.get());
    vrf_ = NULL;
}

bool VnOvsdbEntry::Sync(DBEntry *db_entry) {
    VnEntry *vn = static_cast<VnEntry *>(db_entry);
    uint32_t vxlan_id = vn->GetVxLanId();
    bool ret = false;

    if (vrf_.get() != vn->GetVrf()) {
        // Update Vrf After taking action on previous vrf in Add/Change
        ret = true;
    }

    if (vxlan_id_ != vxlan_id) {
        vxlan_id_ = vxlan_id;
        ret = true;
    }

    if (name_ != vn->GetName()) {
        name_ = vn->GetName();
        ret = true;
    }

    return ret;
}

bool VnOvsdbEntry::IsLess(const KSyncEntry &entry) const {
    const VnOvsdbEntry &vn_entry = static_cast<const VnOvsdbEntry&>(entry);
    return uuid_ < vn_entry.uuid_;
}

KSyncEntry *VnOvsdbEntry::UnresolvedReference() {
    return NULL;
}

VrfEntry *VnOvsdbEntry::vrf() {
    return vrf_.get();
}

VnOvsdbObject::VnOvsdbObject(OvsdbClientIdl *idl, DBTable *table) :
    OvsdbDBObject(idl, table, false) {
}

VnOvsdbObject::~VnOvsdbObject() {
}

KSyncEntry *VnOvsdbObject::Alloc(const KSyncEntry *key, uint32_t index) {
    const VnOvsdbEntry *k_entry =
        static_cast<const VnOvsdbEntry *>(key);
    VnOvsdbEntry *entry = new VnOvsdbEntry(this, k_entry->uuid_);
    return entry;
}

KSyncEntry *VnOvsdbObject::DBToKSyncEntry(const DBEntry* db_entry) {
    const VnEntry *entry = static_cast<const VnEntry *>(db_entry);
    VnOvsdbEntry *key = new VnOvsdbEntry(this, entry->GetUuid());
    return static_cast<KSyncEntry *>(key);
}

KSyncDBObject::DBFilterResp VnOvsdbObject::OvsdbDBEntryFilter(
        const DBEntry *entry, const OvsdbDBEntry *ovsdb_entry) {
    const VnEntry *vn = static_cast<const VnEntry *>(entry);
    // only accept Virtual Networks with non-NULL vrf
    // and non zero vxlan id
    if (vn->GetVrf() == NULL || vn->GetVxLanId() == 0) {
        return DBFilterDelete;
    }
    return DBFilterAccept;
}