test_xml_oper.cc

Go to the documentation of this file.

/*
 * Copyright (c) 2014 Juniper Networks, Inc. All rights reserved.
 */
#include <base/os.h>
#include <iostream>
#include <string>
#include <fstream>
#include <pugixml/pugixml.hpp>
#include <boost/uuid/uuid.hpp>
 
#include <test/test_cmn_util.h>
#include <pkt/test/test_pkt_util.h>
#include <net/tunnel_encap_type.h>
#include <pkt/flow_mgmt.h>
#include <oper/global_vrouter.h>
#include "test_xml.h"
#include "test_xml_oper.h"
#include "test_xml_validate.h"
#include "test_xml_packet.h"
 
using namespace std;
using namespace pugi;
using namespace boost::uuids;
using namespace AgentUtXmlUtils;
 
AgentUtXmlValidationNode *CreateValidateNode(const string &type,
                                             const string &name, const uuid &id,
                                             const xml_node &node) {
    if (type == "global-vrouter-config")
        return new AgentUtXmlGlobalVrouterValidate(name, id, node);
    if (type == "virtual-network" || type == "vn")
        return new AgentUtXmlVnValidate(name, id, node);
    if (type == "virtual-machine" || type == "vm")
        return new AgentUtXmlVmValidate(name, id, node);
    if (type == "vxlan")
        return new AgentUtXmlVxlanValidate(name, id, node);
    if (type == "virtual-machine-interface" || type == "vm-interface"
        || type == "vmi")
        return new AgentUtXmlVmInterfaceValidate(name, id, node);
    if (type == "ethernet-interface" || type == "eth-port")
        return new AgentUtXmlEthInterfaceValidate(name, id, node);
    if (type == "flow")
        return new AgentUtXmlFlowValidate(name, node);
    if (type == "routing-instance" || type == "vrf")
        return new AgentUtXmlVrfValidate(name, node);
    if (type == "access-control-list" || type == "acl")
        return new AgentUtXmlAclValidate(name, node);
    if (type == "pkt-parse")
        return new AgentUtXmlPktParseValidate(name, node);
    if (type == "fdb")
        return new AgentUtXmlL2RouteValidate(name, node);
    if (type == "l3-route")
        return new AgentUtXmlL3RouteValidate(name, node);
    return NULL;
}
 
AgentUtXmlNode *CreateNode(const string &type, const string &name,
                           const uuid &id, const xml_node &node,
                           AgentUtXmlTestCase *test_case) {
    if (type == "global-vrouter-config")
        return new AgentUtXmlGlobalVrouter(name, id, node, test_case);
    if (type == "virtual-network" || type == "vn")
        return new AgentUtXmlVn(name, id, node, test_case);
    if (type == "virtual-machine" || type == "vm")
        return new AgentUtXmlVm(name, id, node, test_case);
    if (type == "virtual-machine-interface" || type == "vm-interface"
        || type == "vmi")
        return new AgentUtXmlVmInterface(name, id, node, test_case);
    if (type == "ethernet-interface" || type == "eth-port")
        return new AgentUtXmlEthInterface(name, id, node, test_case);
    if (type == "routing-instance" || type == "vrf")
        return new AgentUtXmlVrf(name, id, node, test_case);
    if (type == "access-control-list" || type == "acl")
        return new AgentUtXmlAcl(name, id, node, test_case);
    if (type == "virtual-machine-interface-routing-instance" ||
        type == "vmi-vrf")
        return new AgentUtXmlVmiVrf(name, id, node, test_case);
    if (type == "fdb" || type == "l2-route")
        return new AgentUtXmlL2Route(name, id, node, test_case);
    if (type == "l3-route")
        return new AgentUtXmlL3Route(name, id, node, test_case);
    if (type == "sg" || type == "securiy-group")
        return new AgentUtXmlSg(name, id, node, test_case);
    if (type == "iip" || type == "instance-ip")
        return new AgentUtXmlInstanceIp(name, id, node, test_case);
    return NULL;
}
 
void AgentUtXmlOperInit(AgentUtXmlTest *test) {
    test->AddConfigEntry("global-vrouter-config", CreateNode);
 
    test->AddConfigEntry("virtual-network", CreateNode);
    test->AddConfigEntry("vn", CreateNode);
 
    test->AddConfigEntry("virtual-machine", CreateNode);
    test->AddConfigEntry("vm", CreateNode);
 
    test->AddConfigEntry("vxlan", CreateNode);
 
    test->AddConfigEntry("virtual-machine-interface", CreateNode);
    test->AddConfigEntry("vm-interface", CreateNode);
    test->AddConfigEntry("vmi", CreateNode);
 
    test->AddConfigEntry("ethernet-interface", CreateNode);
    test->AddConfigEntry("eth-port", CreateNode);
 
    test->AddConfigEntry("routing-instance", CreateNode);
    test->AddConfigEntry("vrf", CreateNode);
 
    test->AddConfigEntry("access-control-list", CreateNode);
    test->AddConfigEntry("acl", CreateNode);
 
    test->AddConfigEntry("virtual-machine-interface-routing-instance",
                         CreateNode);
    test->AddConfigEntry("vmi-vrf", CreateNode);
    test->AddConfigEntry("fdb", CreateNode);
    test->AddConfigEntry("l2-route", CreateNode);
    test->AddConfigEntry("l3-route", CreateNode);
    test->AddConfigEntry("sg", CreateNode);
    test->AddConfigEntry("security-group", CreateNode);
    test->AddConfigEntry("instance-ip", CreateNode);
 
    test->AddValidateEntry("global-vrouter-config", CreateValidateNode);
 
    test->AddValidateEntry("virtual-network", CreateValidateNode);
    test->AddValidateEntry("vn", CreateValidateNode);
    test->AddValidateEntry("vxlan", CreateValidateNode);
    test->AddValidateEntry("virtual-machine", CreateValidateNode);
    test->AddValidateEntry("vm", CreateValidateNode);
    test->AddValidateEntry("virtual-machine-interface", CreateValidateNode);
    test->AddValidateEntry("vm-interface", CreateValidateNode);
    test->AddValidateEntry("vmi", CreateValidateNode);
    test->AddValidateEntry("ethernet-interface", CreateValidateNode);
    test->AddValidateEntry("eth-port", CreateValidateNode);
    test->AddValidateEntry("flow", CreateValidateNode);
    test->AddValidateEntry("routing-instance", CreateValidateNode);
    test->AddValidateEntry("vrf", CreateValidateNode);
    test->AddValidateEntry("access-control-list", CreateValidateNode);
    test->AddValidateEntry("acl", CreateValidateNode);
    test->AddValidateEntry("pkt-parse", CreateValidateNode);
    test->AddValidateEntry("fdb", CreateValidateNode);
    test->AddValidateEntry("l2-route", CreateValidateNode);
    test->AddValidateEntry("l3-route", CreateValidateNode);
}
 
//  AgentUtXmlGlobalVrouter routines
AgentUtXmlGlobalVrouter::AgentUtXmlGlobalVrouter(const std::string &name,
                                                 const uuid &id,
                                                 const xml_node &node,
                                                 AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, test_case) {
}
 
AgentUtXmlGlobalVrouter::~AgentUtXmlGlobalVrouter() {
}
 
bool AgentUtXmlGlobalVrouter::ReadXml() {
    if (AgentUtXmlConfig::ReadXml() == false) {
        return false;
    }
    GetStringAttribute(node(), "vxlan-mode", &vxlan_mode_);
    bool got_attr = GetIntAttribute(node(), "flow-export-rate",
                                    &flow_export_rate_);
    if (!got_attr) {
        flow_export_rate_ = 0;
    }
    return true;
}
 
bool AgentUtXmlGlobalVrouter::ToXml(xml_node *parent) {
    xml_node n = AddXmlNodeWithAttr(parent, NodeType().c_str());
    AddXmlNodeWithValue(&n, "name", name());
    if (!vxlan_mode().empty()) {
        AddXmlNodeWithValue(&n, "vxlan-network-identifier-mode", vxlan_mode());
    }
    if (flow_export_rate() != 0) {
        AddXmlNodeWithIntValue(&n, "flow-export-rate", flow_export_rate());
    }
    AddIdPerms(&n);
    return true;
}
 
void AgentUtXmlGlobalVrouter::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlGlobalVrouter::NodeType() {
    return "global-vrouter-config";
}
 
//  AgentUtXmlVn routines
AgentUtXmlVn::AgentUtXmlVn(const string &name, const uuid &id,
                           const xml_node &node,
                           AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, test_case) {
}
 
AgentUtXmlVn::~AgentUtXmlVn() {
}
 
 
bool AgentUtXmlVn::ReadXml() {
    if (AgentUtXmlConfig::ReadXml() == false) {
        return false;
    }
    GetStringAttribute(node(), "vxlan-id", &vxlan_id_);
    GetStringAttribute(node(), "network-id", &network_id_);
    GetStringAttribute(node(), "flood-unknown-unicast", &flood_unknown_unicast_);
    return true;
}
 
bool AgentUtXmlVn::ToXml(xml_node *parent) {
    xml_node n = AddXmlNodeWithAttr(parent, NodeType().c_str());
    AddXmlNodeWithValue(&n, "name", name());
    if (!network_id().empty()) {
        xml_node n1 = n.append_child("virtual-network-properties");
        AddXmlNodeWithValue(&n1, "network-id", network_id());
    }
    if (!vxlan_id().empty() && op_delete() == false) {
        xml_node n1 = n.append_child("virtual-network-properties");
        AddXmlNodeWithValue(&n1, "vxlan-network-identifier", vxlan_id());
    }
 
    if (!flood_unknown_unicast().empty() && op_delete() == false) {
        if (flood_unknown_unicast() == "true" ||
            flood_unknown_unicast() == "yes")
            AddXmlNodeWithValue(&n, "flood-unknown-unicast", "true");
        else
            AddXmlNodeWithValue(&n, "flood-unknown-unicast", "false");
    }
    AddIdPerms(&n);
    return true;
}
 
void AgentUtXmlVn::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlVn::NodeType() {
    return "virtual-network";
}
 
//  AgentUtXmlVm routines
AgentUtXmlVm::AgentUtXmlVm(const string &name, const uuid &id,
                           const xml_node &node,
                           AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, test_case) {
}
 
AgentUtXmlVm::~AgentUtXmlVm() {
}
 
 
bool AgentUtXmlVm::ReadXml() {
    return AgentUtXmlConfig::ReadXml();
}
 
bool AgentUtXmlVm::ToXml(xml_node *parent) {
    xml_node n = AddXmlNodeWithAttr(parent, NodeType().c_str());
    AddXmlNodeWithValue(&n, "name", name());
    AddIdPerms(&n);
    return true;
}
 
void AgentUtXmlVm::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlVm::NodeType() {
    return "virtual-machine";
}
 
//  AgentUtXmlVmInterface routines
AgentUtXmlVmInterface::AgentUtXmlVmInterface(const string &name,
                                             const uuid &id,
                                             const xml_node &node,
                                             AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, test_case), vlan_tag_(-1), parent_vmi_() {
}
 
AgentUtXmlVmInterface::~AgentUtXmlVmInterface() {
}
 
bool AgentUtXmlVmInterface::ReadXml() {
    if (AgentUtXmlConfig::ReadXml() == false)
        return false;
 
    GetStringAttribute(node(), "mac", &mac_);
 
    vm_name_ = "";
    vn_uuid_ = nil_uuid();
    vm_uuid_ = nil_uuid();
    vrf_ = "";
    add_nova_ = false;
    ip_ = "0.0.0.0";
 
    GetStringAttribute(node(), "vn-name", &vn_name_);
    uint16_t id = 0;
    GetUintAttribute(node(), "vn-uuid", &id);
    if (id) {
        vn_uuid_ = MakeUuid(id);
    }
 
    GetStringAttribute(node(), "vm-name", &vm_name_);
    id = 0;
    GetUintAttribute(node(), "vm-uuid", &id);
    if (id) {
        vm_uuid_ = MakeUuid(id);
    }
 
    GetStringAttribute(node(), "vrf", &vrf_);
    GetStringAttribute(node(), "ip", &ip_);
 
    string str;
    if (GetStringAttribute(node(), "nova", &str) ||
        GetUintAttribute(node(), "nova", &id)) {
        add_nova_ = true;
    }
 
    if (GetStringAttribute(node(), "nova", &str) ||
        GetUintAttribute(node(), "nova", &id)) {
        add_nova_ = true;
    }
 
    vlan_tag_ = 0;
    GetUintAttribute(node(), "vlan-tag", &vlan_tag_);
    GetStringAttribute(node(), "parent-vmi", &parent_vmi_);
 
     xml_attribute attr = node().attribute("fat-flow");
     for (;attr != xml_attribute(); attr = attr.next_attribute()) {
         if (std::string(attr.name()) == "fat-flow") {
             uint32_t value = attr.as_uint();
             fat_flow_port_.push_back(value);
         } else {
             break;
         }
     }
    return true;
}
 
bool AgentUtXmlVmInterface::ToXml(xml_node *parent) {
    xml_node n = AddXmlNodeWithAttr(parent, NodeType().c_str());
    AddXmlNodeWithValue(&n, "name", name());
 
    if (op_delete() == false) {
        xml_node n1 = n.append_child("virtual-machine-interface-mac-address");
        AddXmlNodeWithValue(&n1, "mac-address", mac_);
        AddIdPerms(&n);
 
        if (vlan_tag_ > 0) {
            n1 = n.append_child("virtual-machine-interface-properties");
            char buff[32];
            sprintf(buff, "%d", vlan_tag_);
            AddXmlNodeWithValue(&n1, "sub-interface-vlan-tag", buff);
        }
 
        n1 = n.append_child("virtual-machine-interface-fat-flow-protocols");
        std::vector<uint16_t>::const_iterator it = fat_flow_port_.begin();
        for(;it != fat_flow_port_.end(); it++) {
            xml_node n2 = n1.append_child("fat-flow-protocol");
            AddXmlNodeWithValue(&n2, "protocol", "UDP");
            stringstream s;
            s << *it;
            AddXmlNodeWithValue(&n2, "port", s.str());
        }
    }
 
    if (add_nova_) {
        boost::system::error_code ec;
        Ip4Address ip = Ip4Address::from_string(ip_, ec);
        NovaIntfAdd(op_delete(), id(), ip, vm_uuid_, vm_uuid_, name(), mac_,
                    vm_name_);
    }
 
    if (vn_name_ != "") {
        LinkXmlNode(parent, NodeType(), name(), "virtual-network", vn_name_);
    }
 
    if (vm_name_ != "") {
        LinkXmlNode(parent, NodeType(), name(), "virtual-machine", vm_name_);
    }
 
    if (vrf_ != "") {
        string str = name() + "-" + vm_name_;
        LinkXmlNode(parent, "virtual-machine-interface-routing-instance",
                    str, "routing-instance", vrf_);
 
        LinkXmlNode(parent, NodeType(), name(),
                    "virtual-machine-interface-routing-instance", str);
    }
 
    if (parent_vmi_ != "") {
        LinkXmlNode(parent, NodeType(), name(), "virtual-machine-interface",
                    parent_vmi_);
    }
    return true;
}
 
void AgentUtXmlVmInterface::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlVmInterface::NodeType() {
    return "virtual-machine-interface";
}
 
//  AgentUtXmlEthInterface routines
AgentUtXmlEthInterface::AgentUtXmlEthInterface(const string &name,
                                               const uuid &id,
                                               const xml_node &node,
                                               AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, false, test_case) {
}
 
AgentUtXmlEthInterface::~AgentUtXmlEthInterface() {
}
 
bool AgentUtXmlEthInterface::ReadXml() {
    return AgentUtXmlConfig::ReadXml();
}
 
bool AgentUtXmlEthInterface::ToXml(xml_node *parent) {
    assert(0);
    return true;
}
 
void AgentUtXmlEthInterface::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlEthInterface::NodeType() {
    return "physical-interface";
}
 
bool AgentUtXmlEthInterface::Run() {
    cout << "Create Ethernet Interface" << endl;
    return true;
}
//  AgentUtXmlVrf routines
AgentUtXmlVrf::AgentUtXmlVrf(const string &name, const uuid &id,
                             const xml_node &node,
                             AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, test_case) {
}
 
AgentUtXmlVrf::~AgentUtXmlVrf() {
}
 
 
bool AgentUtXmlVrf::ReadXml() {
    if (AgentUtXmlConfig::ReadXml() == false)
        return false;
 
    GetStringAttribute(node(), "vn", &vn_name_);
    return true;
}
 
bool AgentUtXmlVrf::ToXml(xml_node *parent) {
    xml_node n = AddXmlNodeWithAttr(parent, NodeType().c_str());
    AddXmlNodeWithValue(&n, "name", name());
    AddIdPerms(&n);
    if (vn_name_ != "") {
        LinkXmlNode(parent, NodeType(), name(), "virtual-network", vn_name_);
    }
    return true;
}
 
void AgentUtXmlVrf::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlVrf::NodeType() {
    return "routing-instance";
}
 
//  AgentUtXmlVmiVrf routines
AgentUtXmlVmiVrf::AgentUtXmlVmiVrf(const string &name, const uuid &id,
                                   const xml_node &node,
                                   AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, test_case) {
}
 
AgentUtXmlVmiVrf::~AgentUtXmlVmiVrf() {
}
 
 
bool AgentUtXmlVmiVrf::ReadXml() {
    return AgentUtXmlConfig::ReadXml();
}
 
bool AgentUtXmlVmiVrf::ToXml(xml_node *parent) {
    xml_node n = AddXmlNodeWithAttr(parent, NodeType().c_str());
    AddXmlNodeWithValue(&n, "name", name());
 
    xml_node n1 = n.append_child("value");
    AddXmlNodeWithValue(&n1, "direction", "both");
    AddXmlNodeWithValue(&n1, "vlan-tag", "0");
 
    AddIdPerms(&n);
    return true;
}
 
void AgentUtXmlVmiVrf::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlVmiVrf::NodeType() {
    return "virtual-machine-interface-routing-instance";
}
 
//  AgentUtXmlAcl routines
AgentUtXmlAcl::AgentUtXmlAcl(const string &name, const uuid &id,
                             const xml_node &node,
                             AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, test_case) {
}
 
AgentUtXmlAcl::~AgentUtXmlAcl() {
}
 
bool AgentUtXmlAcl::ReadXml() {
    if (AgentUtXmlConfig::ReadXml() == false)
        return false;
 
    for (xml_node n = node().first_child(); n; n = n.next_sibling()) {
        if (strcmp(n.name(), "ace") != 0) {
            continue;
        }
 
        Ace ace;
 
        GetUintAttribute(n, "src-sg", (uint16_t *)&ace.src_sg_);
        GetUintAttribute(n, "dst-sg", (uint16_t *)&ace.dst_sg_);
 
        GetStringAttribute(n, "src-vn", &ace.src_vn_);
        GetStringAttribute(n, "dst-vn", &ace.dst_vn_);
 
        GetStringAttribute(n, "src-ip", &ace.src_ip_);
        GetUintAttribute(n, "src-plen", (uint16_t *)&ace.src_ip_plen_);
        GetStringAttribute(n, "dst-ip", &ace.dst_ip_);
        GetUintAttribute(n, "dst-plen", (uint16_t *)&ace.dst_ip_plen_);
 
        std::string str;
        GetStringAttribute(n, "sport", &str);
        if (str.empty()) {
            ace.sport_begin_ = 0;
            ace.sport_end_ = 65535;
        } else {
            sscanf(str.c_str(), "%d:%d", &ace.sport_begin_, &ace.sport_end_);
        }
 
        GetStringAttribute(n, "dport", &str);
        if (str.empty()) {
            ace.dport_begin_ = 0;
            ace.dport_end_ = 65535;
        } else {
            sscanf(str.c_str(), "%d:%d", &ace.dport_begin_, &ace.dport_end_);
        }
 
        GetStringAttribute(n, "action", &ace.action_);
        GetStringAttribute(n, "direction", &ace.direction_);
        if (ace.direction_ != ">")
            ace.direction_ = "<";
 
        ace_list_.push_back(ace);
    }
 
    return true;
}
 
bool AgentUtXmlAcl::ToXml(xml_node *parent) {
    xml_node n = AddXmlNodeWithAttr(parent, NodeType().c_str());
    AddXmlNodeWithValue(&n, "name", name());
 
    xml_node n1 = n.append_child("access-control-list-entries");
    AddXmlNodeWithValue(&n1, "dynamic", "false");
 
    for (AceList::iterator it = ace_list_.begin(); it != ace_list_.end();
         it++) {
        xml_node n2 = n1.append_child("acl-rule");
 
        xml_node n3 = n2.append_child("match-condition");
        AddXmlNodeWithValue(&n3, "protocol", "any");
 
        xml_node n4 = n3.append_child("src-address");
 
        Ace ace = (*it);
        if (ace.src_sg_) {
            AddXmlNodeWithIntValue(&n4, "security-group", ace.src_sg_);
        }
 
        if (ace.src_vn_ != "") {
            AddXmlNodeWithValue(&n4, "virtual-network", ace.src_vn_);
        }
 
        if (ace.src_ip_ != "") {
            xml_node n5 = n4.append_child("subnet");
            AddXmlNodeWithValue(&n5, "ip-prefix", ace.src_ip_);
            AddXmlNodeWithIntValue(&n5, "ip-prefix-len", ace.src_ip_plen_);
        }
 
        n4 = n3.append_child("dst-address");
        if (ace.dst_sg_) {
            AddXmlNodeWithIntValue(&n4, "security-group", ace.dst_sg_);
        }
 
        if (ace.dst_vn_ != "") {
            AddXmlNodeWithValue(&n4, "virtual-network", ace.dst_vn_);
        }
 
        if (ace.dst_ip_ != "") {
            xml_node n5 = n4.append_child("subnet");
            AddXmlNodeWithValue(&n5, "ip-prefix", ace.dst_ip_);
            AddXmlNodeWithIntValue(&n5, "ip-prefix-len", ace.dst_ip_plen_);
        }
 
        stringstream str;
        n4 = n3.append_child("src-port");
        str.str("");
        str << ace.sport_begin_;
        AddXmlNodeWithValue(&n4, "start-port", str.str());
        str.str("");
        str << ace.sport_end_;
        AddXmlNodeWithValue(&n4, "end-port", str.str());
 
        n4 = n3.append_child("dst-port");
        str.str("");
        str << ace.dport_begin_;
        AddXmlNodeWithValue(&n4, "start-port", str.str());
        str.str("");
        str << ace.dport_end_;
        AddXmlNodeWithValue(&n4, "end-port", str.str());
 
        n3 = n2.append_child("action-list");
        AddXmlNodeWithValue(&n3, "simple-action", ace.action_);
    }
 
    AddIdPerms(&n);
    return true;
}
 
void AgentUtXmlAcl::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlAcl::NodeType() {
    return "access-control-list";
}
 
//  AgentUtXmlSg routines
AgentUtXmlSg::AgentUtXmlSg(const string &name, const uuid &id,
                           const xml_node &node,
                           AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, test_case) {
}
 
AgentUtXmlSg::~AgentUtXmlSg() {
}
 
bool AgentUtXmlSg::ReadXml() {
    if (AgentUtXmlConfig::ReadXml() == false)
        return false;
 
    GetStringAttribute(node(), "sg_id", &sg_id_);
    GetStringAttribute(node(), "ingress", &ingress_);
    GetStringAttribute(node(), "egress", &egress_);
    return true;
}
 
bool AgentUtXmlSg::ToXml(xml_node *parent) {
    xml_node n = AddXmlNodeWithAttr(parent, NodeType().c_str());
    AddXmlNodeWithValue(&n, "name", name());
    AddXmlNodeWithValue(&n, "security-group-id", sg_id_);
    AddIdPerms(&n);
 
    string str;
    if (ingress_ != "") {
        str = "ingress-access-control-list-" + ingress_;
        LinkXmlNode(parent, NodeType(), name(), "access-control-list", str);
    }
 
    if (egress_ != "") {
        str = "egress-access-control-list-" + egress_;
        LinkXmlNode(parent, NodeType(), name(), "access-control-list", str);
    }
 
    return true;
}
 
void AgentUtXmlSg::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlSg::NodeType() {
    return "security-group";
}
 
//  AgentUtXmlTag routines
AgentUtXmlTag::AgentUtXmlTag(const string &name, const uuid &id,
                           const xml_node &node,
                           AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, test_case) {
}
 
AgentUtXmlTag::~AgentUtXmlTag() {
}
 
bool AgentUtXmlTag::ReadXml() {
    if (AgentUtXmlConfig::ReadXml() == false)
        return false;
 
    GetStringAttribute(node(), "tag_id", &tag_id_);
    return true;
}
 
bool AgentUtXmlTag::ToXml(xml_node *parent) {
    xml_node n = AddXmlNodeWithAttr(parent, NodeType().c_str());
    AddXmlNodeWithValue(&n, "name", name());
    AddXmlNodeWithValue(&n, "tag-id", tag_id_);
    AddIdPerms(&n);
 
    return true;
}
 
void AgentUtXmlTag::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlTag::NodeType() {
    return "tag";
}
 
//  AgentUtXmlInstanceIp routines
AgentUtXmlInstanceIp::AgentUtXmlInstanceIp(const string &name, const uuid &id,
                                           const xml_node &node,
                                           AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, test_case) {
}
 
AgentUtXmlInstanceIp::~AgentUtXmlInstanceIp() {
}
 
 
bool AgentUtXmlInstanceIp::ReadXml() {
    if (AgentUtXmlConfig::ReadXml() == false)
        return false;
 
    GetStringAttribute(node(), "ip", &ip_);
    GetStringAttribute(node(), "vmi", &vmi_);
    std::string str;
    if (GetStringAttribute(node(), "ecmp", &str) == true) {
        ecmp_ = true;
    } else {
        ecmp_ = false;
    }
 
    return true;
}
 
bool AgentUtXmlInstanceIp::ToXml(xml_node *parent) {
    xml_node n = AddXmlNodeWithAttr(parent, NodeType().c_str());
    AddXmlNodeWithValue(&n, "name", name());
    if (op_delete() == false) {
        AddXmlNodeWithValue(&n, "instance-ip-address", ip_);
        if (ecmp_ == true) {
            AddXmlNodeWithValue(&n, "instance-ip-mode", "active-active");
        }
        AddIdPerms(&n);
    }
 
    if (vmi_ != "") {
        LinkXmlNode(parent, NodeType(), name(),
                    "virtual-machine-interface", vmi_);
    }
 
    return true;
}
 
void AgentUtXmlInstanceIp::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlInstanceIp::NodeType() {
    return "instance-ip";
}
 
//  AgentUtXmlNova routines
AgentUtXmlNova::AgentUtXmlNova(const string &name, const uuid &id,
                             const xml_node &node,
                             AgentUtXmlTestCase *test_case) :
    AgentUtXmlConfig(name, id, node, false, test_case) {
}
 
AgentUtXmlNova::~AgentUtXmlNova() {
}
 
bool AgentUtXmlNova::ReadXml() {
    if (AgentUtXmlNode::ReadXml() == false)
        return false;
 
    if (GetStringAttribute(node(), "mac", &mac_) == false) {
        cout << "Attribute \"mac\" not specified for nova. Skipping"
            << endl;
        return false;
    }
 
    uint16_t num;
    if (GetUintAttribute(node(), "vm-uuid", &num) == false) {
        cout << "Attribute \"vm-uuid\" not specified for nova. Skipping"
            << endl;
        return false;
    }
    vm_uuid_ = MakeUuid(num);
 
    if (GetUintAttribute(node(), "vn-uuid", &num) == false) {
        cout << "Attribute \"vn-uuid\" not specified for nova. Skipping"
            << endl;
        return false;
    }
    vn_uuid_ = MakeUuid(num);
 
    if (GetStringAttribute(node(), "vm-name", &vm_name_) == false) {
        cout << "Attribute \"vm_name\" not specified for nova. Skipping"
            << endl;
        return false;
    }
 
    if (GetStringAttribute(node(), "ip", &ip_) == false) {
        cout << "Attribute \"ip\" not specified for nova. Skipping"
            << endl;
        return false;
    }
 
    return true;
}
 
bool AgentUtXmlNova::ToXml(xml_node *parent) {
    assert(0);
    return false;
}
 
void AgentUtXmlNova::ToString(string *str) {
    AgentUtXmlConfig::ToString(str);
    *str += "\n";
    return;
}
 
string AgentUtXmlNova::NodeType() {
    return "Nova";
}
 
bool AgentUtXmlNova::Run() {
    boost::system::error_code ec;
    Ip4Address ip = Ip4Address::from_string(ip_, ec);
    NovaIntfAdd(op_delete(), id(), ip, vm_uuid_, vn_uuid_, name(), mac_,
                vm_name_);
    return true;
}
 
//  AgentUtXmlGlobalVrouterValidate routines
AgentUtXmlGlobalVrouterValidate::AgentUtXmlGlobalVrouterValidate(const string &name,
                                           const uuid &id,
                                           const xml_node &node) :
    AgentUtXmlValidationNode(name, node), id_(id), flow_export_rate_(-1) {
}
 
AgentUtXmlGlobalVrouterValidate::~AgentUtXmlGlobalVrouterValidate() {
}
 
bool AgentUtXmlGlobalVrouterValidate::ReadXml() {
    GetIntAttribute(node(), "flow-export-rate", &flow_export_rate_);
    return true;
}
 
bool AgentUtXmlGlobalVrouterValidate::Validate() {
    GlobalVrouter *vr = Agent::GetInstance()->oper_db()->global_vrouter();
 
    if (vr == NULL)
        return false;
 
    if (flow_export_rate_ != -1) {
        int32_t rate = flow_export_rate_;
        if (vr->flow_export_rate() != rate)
            return false;
    }
 
    return true;
}
 
const string AgentUtXmlGlobalVrouterValidate::ToString() {
    return "global-vrouter-config";
}
 
//  AgentUtXmlVnValidate routines
AgentUtXmlVnValidate::AgentUtXmlVnValidate(const string &name,
                                           const uuid &id,
                                           const xml_node &node) :
    AgentUtXmlValidationNode(name, node), id_(id), vxlan_id_(0),
    vxlan_id_ref_(false) {
}
 
AgentUtXmlVnValidate::~AgentUtXmlVnValidate() {
}
 
bool AgentUtXmlVnValidate::ReadXml() {
    GetUintAttribute(node(), "vxlan-id", &vxlan_id_);
    check_vxlan_id_ref_ = GetUintAttribute(node(), "vxlan-id-ref", &vxlan_id_ref_);
    return true;
}
 
bool AgentUtXmlVnValidate::Validate() {
    VnEntry *vn = VnGet(id());
    if (present() == false) {
        return (vn == NULL);
    }
 
    if (vn == NULL)
        return false;
 
    if (vxlan_id_ != 0) {
        if (vn->GetVxLanId() != vxlan_id_)
            return false;
    }
 
    if (check_vxlan_id_ref_) {
        if (vxlan_id_ref_ == 0) {
            if (vn->vxlan_id_ref() != NULL)
                return false;
        }
 
        if (vxlan_id_ref_) {
            const VxLanId *vxlan = vn->vxlan_id_ref();
            if (vxlan == NULL)
                return false;
 
            if (vxlan->vxlan_id() != vxlan_id_ref_)
                return false;
        }
    }
 
 
    return true;
}
 
const string AgentUtXmlVnValidate::ToString() {
    return "virtual-network";
}
 
//  AgentUtXmlVmValidate routines
AgentUtXmlVmValidate::AgentUtXmlVmValidate(const string &name,
                                           const uuid &id,
                                           const xml_node &node) :
    AgentUtXmlValidationNode(name, node), id_(id) {
}
 
AgentUtXmlVmValidate::~AgentUtXmlVmValidate() {
}
 
bool AgentUtXmlVmValidate::ReadXml() {
    return true;
}
 
bool AgentUtXmlVmValidate::Validate() {
    return true;
}
 
const string AgentUtXmlVmValidate::ToString() {
    return "virtual-machine";
}
 
//  AgentUtXmlVxlanValidate routines
AgentUtXmlVxlanValidate::AgentUtXmlVxlanValidate(const string &name,
                                                 const uuid &id,
                                                 const xml_node &node) :
    AgentUtXmlValidationNode(name, node), id_(id), vxlan_id_(0), vrf_(),
    flood_unknown_unicast_() {
}
 
AgentUtXmlVxlanValidate::~AgentUtXmlVxlanValidate() {
}
 
bool AgentUtXmlVxlanValidate::ReadXml() {
    GetUintAttribute(node(), "vxlan-id", &vxlan_id_);
    GetStringAttribute(node(), "vrf", &vrf_);
    GetStringAttribute(node(), "flood-unknown-unicast", &flood_unknown_unicast_);
    return true;
}
 
bool AgentUtXmlVxlanValidate::Validate() {
    VxLanId *vxlan = VxlanGet(vxlan_id_);
 
    if (!present()) {
        return (vxlan == NULL);
    }
 
    if (vxlan == NULL)
        return false;
 
    if (vxlan->vxlan_id() != vxlan_id_)
        return false;
 
    if (flood_unknown_unicast_.empty() == false) {
        const VrfNH *nh = dynamic_cast<const VrfNH *>(vxlan->nexthop());
        if (nh == NULL)
            return false;
 
        if (flood_unknown_unicast_ == "true" ||
            flood_unknown_unicast_ == "yes") {
            return (nh->flood_unknown_unicast() == true);
        } else {
            return (nh->flood_unknown_unicast() == false);
        }
    }
 
    if (vrf_.empty() == false) {
        const VrfNH *nh = dynamic_cast<const VrfNH *>(vxlan->nexthop());
        if (nh == NULL)
            return false;
 
        if (nh->GetType() != NextHop::VRF)
            return false;
 
        const VrfEntry *vrf = nh->GetVrf();
        if (vrf == NULL)
            return false;
 
        if (vrf->GetName() != vrf_)
            return false;
    }
 
    return true;
}
 
const string AgentUtXmlVxlanValidate::ToString() {
    return "vxlan";
}
 
//  AgentUtXmlVmInterfaceValidate routines
AgentUtXmlVmInterfaceValidate::AgentUtXmlVmInterfaceValidate(const string &name,
                                           const uuid &id,
                                           const xml_node &node) :
    AgentUtXmlValidationNode(name, node), id_(id), vlan_tag_(0), vn_uuid_() {
}
 
AgentUtXmlVmInterfaceValidate::~AgentUtXmlVmInterfaceValidate() {
}
 
bool AgentUtXmlVmInterfaceValidate::ReadXml() {
    GetUintAttribute(node(), "vlan", &vlan_tag_);
    GetStringAttribute(node(), "active", &active_);
    GetStringAttribute(node(), "device-type", &device_type_);
    GetStringAttribute(node(), "vmi-type", &vmi_type_);
    uint16_t id = 0;
    GetUintAttribute(node(), "vn-uuid", &id);
    if (id) {
        vn_uuid_ = MakeUuid(id);
    }
 
    return true;
}
 
static string DeviceTypeToString(VmInterface::DeviceType type) {
    if (type == VmInterface::VM_ON_TAP)
        return "VM-Tap";
    if (type == VmInterface::VM_VLAN_ON_VMI)
        return "VM-Sub-Intf";
    if (type == VmInterface::TOR)
        return "Tor";
    if (type == VmInterface::LOCAL_DEVICE)
        return "Baremetal";
    return "Invalid";
 
}
 
static string VmiTypeToString(VmInterface::VmiType type) {
    if (type == VmInterface::INSTANCE)
        return "vm";
    if (type == VmInterface::BAREMETAL)
        return "Baremetal";
    if (type == VmInterface::GATEWAY)
        return "Gateway";
 
    return "Invalid";
}
 
bool AgentUtXmlVmInterfaceValidate::Validate() {
    VmInterface *vmi = VmInterfaceGet(id());
 
    if (present()) {
        if (vmi == NULL)
            return false;
    } else {
        return vmi == NULL;
    }
 
    if (active_.empty() == false) {
        if (boost::iequals(active_, "true") ||
            (boost::iequals(active_, "0") == false)){
            if (VmPortActive(id()) == false)
               return false;
        } else {
           if (VmPortActive(id()) == true)
               return false;
        }
    }
 
    if (device_type_.empty() == false) {
        if (boost::iequals(device_type_, DeviceTypeToString(vmi->device_type()))
            == false)
            return false;
    }
 
    if (vmi_type_.empty() == false) {
        if (boost::iequals(vmi_type_, VmiTypeToString(vmi->vmi_type()))
            == false)
            return false;
    }
 
    if (vlan_tag_ > 0) {
        if (vmi->rx_vlan_id() != vlan_tag_)
            return false;
    }
 
    if (vn_uuid_.is_nil() == false) {
        const VnEntry *vn = vmi->vn();
        if (vn == NULL)
            return false;
 
        if (vn->GetUuid() != vn_uuid_)
            return false;
    }
 
    return true;
}
 
const string AgentUtXmlVmInterfaceValidate::ToString() {
    return "virtual-machine-interface";
}
 
//  AgentUtXmlEthInterfaceValidate routines
AgentUtXmlEthInterfaceValidate::AgentUtXmlEthInterfaceValidate(const string &name,
                                           const uuid &id,
                                           const xml_node &node) :
    AgentUtXmlValidationNode(name, node), id_(id) {
}
 
AgentUtXmlEthInterfaceValidate::~AgentUtXmlEthInterfaceValidate() {
}
 
bool AgentUtXmlEthInterfaceValidate::ReadXml() {
    return true;
}
 
bool AgentUtXmlEthInterfaceValidate::Validate() {
    return true;
}
 
const string AgentUtXmlEthInterfaceValidate::ToString() {
    return "eth-interface";
}
 
//  AgentUtXmlVrfValidate routines
AgentUtXmlVrfValidate::AgentUtXmlVrfValidate(const string &name,
                                             const xml_node &node) :
    AgentUtXmlValidationNode(name, node) {
}
 
AgentUtXmlVrfValidate::~AgentUtXmlVrfValidate() {
}
 
bool AgentUtXmlVrfValidate::ReadXml() {
    GetStringAttribute(node(), "vn", &vn_name_);
    return true;
}
 
bool AgentUtXmlVrfValidate::Validate() {
 
    VrfEntry *vrf = VrfGet(name().c_str(), true);
 
    if (present() && (vrf == NULL)) {
        return false;
    } else if (!present() && (vrf != NULL)) {
        return false;
    }
 
    if (vrf == NULL)
        return true;
 
    if (delete_marked()) {
        if (vrf->IsDeleted() == false)
            return false;
    }
 
    if (vn_name_ == "") {
        return true;
    }
 
    if (vn_name_ == "nil" || vn_name_ == "NIL") {
        return (vrf->vn() == NULL);
    }
 
    if (vrf->vn() == NULL)
        return false;
 
    return (vrf->vn()->GetName() == vn_name_);
}
 
const string AgentUtXmlVrfValidate::ToString() {
    return "vrf";
}
 
//  AgentUtXmlAclValidate routines
AgentUtXmlAclValidate::AgentUtXmlAclValidate(const string &name,
                                             const xml_node &node) :
    AgentUtXmlValidationNode(name, node) {
}
 
AgentUtXmlAclValidate::~AgentUtXmlAclValidate() {
}
 
bool AgentUtXmlAclValidate::ReadXml() {
    return true;
}
 
bool AgentUtXmlAclValidate::Validate() {
    if (present()) {
        return AclFind(id());
    } else {
        return !AclFind(id());
    }
}
 
const string AgentUtXmlAclValidate::ToString() {
    return "access-control-list";
}
 
//  AgentUtXmlFlowValidate routines
AgentUtXmlFlowValidate::AgentUtXmlFlowValidate(const string &name,
                                               const xml_node &node) :
    AgentUtXmlValidationNode(name, node), attempt_(0), nh_auto_(false) {
}
 
AgentUtXmlFlowValidate::~AgentUtXmlFlowValidate() {
}
 
bool AgentUtXmlFlowValidate::ReadXml() {
    if (GetUintAttribute(node(), "nh", &nh_id_) == false) {
        nh_id_ = 0;
        nh_auto_ = true;
    } else {
        nh_auto_ = false;
    }
 
    if (GetStringAttribute(node(), "sip", &sip_) == false) {
        cout << "Attribute \"sip\" not specified for Flow. Skipping" << endl;
        return false;
    }
 
    if (GetStringAttribute(node(), "dip", &dip_) == false) {
        cout << "Attribute \"dip\" not specified for Flow. Skipping" << endl;
        return false;
    }
 
    if (GetStringAttribute(node(), "proto", &proto_) == false &&
        GetUintAttribute(node(), "proto", &proto_id_) == false) {
        cout << "Attribute \"proto\" not specified for Flow. Skipping"
            << endl;
        return false;
    }
 
    if (proto_ == "tcp" || proto_ == "udp") {
        if (proto_ == "tcp")
            proto_id_ = 6;
        else
            proto_id_ = 17;
        if (GetUintAttribute(node(), "sport", &sport_) == false) {
            cout << "Attribute \"sport\" not specified for Flow. Skipping"
                << endl;
            return false;
        }
 
        if (GetUintAttribute(node(), "dport", &dport_) == false) {
            cout << "Attribute \"dport\" not specified for Flow. Skipping"
                << endl; return false;
        }
    }
 
    GetStringAttribute(node(), "svn", &svn_);
    GetStringAttribute(node(), "dvn", &dvn_);
    GetStringAttribute(node(), "action", &action_);
    if (GetUintAttribute(node(), "rpf_nh", &rpf_nh_) == false) {
        rpf_nh_ = 0;
    }
    if (GetStringAttribute(node(), "vrf", &vrf_) == false) {
        vrf_ ="";
    }
    if (GetStringAttribute(node(), "deleted", &deleted_) == false) {
        deleted_ = "false";
    }
    return true;
}
 
static bool MatchFlowAction(FlowEntry *flow, const string &str) {
    uint64_t action = flow->data().match_p.action_info.action;
    if (str == "pass") {
        return (action & (1 << TrafficAction::PASS));
    }
 
    if (str == "deny") {
        return (((action & TrafficAction::DROP_FLAGS) != 0) |
                (flow->IsShortFlow()));
    }
 
    return false;
}
 
void AgentUtXmlFlowValidate::SuggestNhId() {
    Agent *agent = Agent::GetInstance();
    if (agent == NULL || agent->nexthop_table() == NULL) {
        return;
    }
 
    cout << "  flow <" << name() << "> not found with nh=" << nh_id_
         << " (key: vrf=" << vrf_ << " " << sip_ << " -> " << dip_
         << " proto=" << proto_id_ << " " << sport_ << "/" << dport_ << ")"
         << endl;
 
    bool found = false;
    DBTablePartition *part = static_cast<DBTablePartition *>
        (agent->nexthop_table()->GetTablePartition(0));
    for (DBEntry *e = part->GetFirst(); e != NULL; e = part->GetNext(e)) {
        NextHop *nh = static_cast<NextHop *>(e);
        FlowEntry *f = FlowGet(0, sip_, dip_, proto_id_, sport_, dport_,
                               nh->id());
        if (f != NULL) {
            found = true;
            cout << "  ==> MATCHES with nh=\"" << nh->id() << "\""
                 << "  (nh type=" << nh->GetType()
                 << ", " << nh->ToString() << ")" << endl;
        }
    }
    if (found == false) {
        cout << "  ==> no nexthop index yields this flow; the flow itself was"
                " not created (check the packet, not the nh)" << endl;
    }
}
 
FlowEntry *AgentUtXmlFlowValidate::FindFlowAnyNh(uint16_t *found_nh) {
    Agent *agent = Agent::GetInstance();
    if (agent == NULL || agent->nexthop_table() == NULL) {
        return NULL;
    }
 
    FlowEntry *result = NULL;
    uint32_t matches = 0;
    DBTablePartition *part = static_cast<DBTablePartition *>
        (agent->nexthop_table()->GetTablePartition(0));
    for (DBEntry *e = part->GetFirst(); e != NULL; e = part->GetNext(e)) {
        NextHop *nh = static_cast<NextHop *>(e);
        FlowEntry *f = FlowGet(0, sip_, dip_, proto_id_, sport_, dport_,
                               nh->id());
        if (f != NULL) {
            matches++;
            if (result == NULL) {
                result = f;
                *found_nh = nh->id();
            }
        }
    }
 
    if (matches > 1) {
        cout << "  flow <" << name() << "> matches " << matches
             << " nexthops; the key is ambiguous -- specify nh= explicitly"
             << endl;
        return NULL;
    }
    return result;
}
 
bool AgentUtXmlFlowValidate::Validate() {
    FlowEntry *flow = NULL;
    uint16_t used_nh = nh_id_;
    if (nh_auto_) {
        flow = FindFlowAnyNh(&used_nh);
    } else {
        flow = FlowGet(0, sip_, dip_, proto_id_, sport_, dport_, nh_id_);
    }
 
    if (deleted_ == "true" && flow == NULL) {
        return true;
    }
 
    if (present() == false)
        return (flow == NULL);
 
    if (flow == NULL) {
        if (nh_auto_ == false && ++attempt_ >= wait_count()) {
            SuggestNhId();
        }
        return false;
    }
 
    if (nh_auto_) {
        cout << "  flow <" << name() << "> resolved to nh=" << used_nh << endl;
    }
 
    if (svn_ != "" && !VnMatch(flow->data().source_vn_list, svn_))
        return false;
 
    if (dvn_ != "" && !VnMatch(flow->data().dest_vn_list, dvn_))
        return false;
 
    if (MatchFlowAction(flow, action_) == false) {
        return false;
    }
 
    if (rpf_nh_) {
        int nh_id = 0;
        if (vrf_ != "") {
            Agent *agent = Agent::GetInstance();
            InetUnicastAgentRouteTable *inet_table =
                static_cast<InetUnicastAgentRouteTable *>
                (agent->vrf_table()->GetInet4UnicastRouteTable(vrf_));
            InetUnicastRouteEntry *rt =
                inet_table->FindRoute(Ip4Address::from_string(sip_));
            if ( rt != NULL) {
                const NextHop *nh = rt->GetActiveNextHop();
                if ( nh && (nh->id() != rpf_nh_)) {
                    nh_id = nh->id();
                }
            }
        }
        if (rpf_nh_ == NextHopTable::kRpfDiscardIndex) {
            if (flow->data().rpf_nh.get() != NULL) {
                return false;
            }
        } else if (!flow->data().rpf_nh.get() ||
                   ((flow->data().rpf_nh.get()->id() != rpf_nh_) &&
                   (flow->data().rpf_nh.get()->id() != nh_id))) {
            return false;
        }
    }
    return true;
}
 
const string AgentUtXmlFlowValidate::ToString() {
    return ("flow <"  + name() + ">");
}
 
uint32_t AgentUtXmlFlowValidate::wait_count() const {
    if (present()) {
        return 10;
    } else {
        return AgentUtXmlValidationNode::wait_count();
    }
}
 
// AgentUtXmlL2Route routines
AgentUtXmlL2Route::AgentUtXmlL2Route(const string &name, const uuid &id,
                                     const xml_node &node,
                                     AgentUtXmlTestCase *test_case) :
    AgentUtXmlNode(name, node, false, test_case) {
}
 
AgentUtXmlL2Route::~AgentUtXmlL2Route() {
}
 
 
bool AgentUtXmlL2Route::ReadXml() {
    if (GetStringAttribute(node(), "mac", &mac_) == false) {
        cout << "Attribute \"mac\" not specified. Skipping" << endl;
        return false;
    }
 
    if (GetStringAttribute(node(), "vrf", &vrf_) == false) {
        cout << "Attribute \"vrf_\" not specified. Skipping" << endl;
        return false;
    }
 
    GetStringAttribute(node(), "ip", &ip_);
    GetStringAttribute(node(), "vn", &vn_);
    GetUintAttribute(node(), "vxlan_id", &vxlan_id_);
    GetStringAttribute(node(), "tunnel-dest", &tunnel_dest_);
    GetStringAttribute(node(), "tunnel-type", &tunnel_type_);
    GetUintAttribute(node(), "sg", &sg_id_);
    GetUintAttribute(node(), "tag", &tag_id_);
    GetUintAttribute(node(), "label", &label_);
    if (ip_.empty()) {
        ip_ = "0.0.0.0";
    }
    return true;
}
 
bool AgentUtXmlL2Route::ToXml(xml_node *parent) {
    assert(0);
    return true;
}
 
void AgentUtXmlL2Route::ToString(string *str) {
    *str = "L2-Route";
    return;
}
 
string AgentUtXmlL2Route::NodeType() {
    return "FDB";
}
 
bool AgentUtXmlL2Route::Run() {
    Agent *agent = Agent::GetInstance();
    EvpnAgentRouteTable *rt_table =
        static_cast<EvpnAgentRouteTable *>
        (Agent::GetInstance()->vrf_table()->GetEvpnRouteTable(vrf_));
 
    SecurityGroupList sg_list;
    TagList tag_list;
    if (sg_id_)
        sg_list.push_back(sg_id_);
    if (tag_id_)
        tag_list.push_back(tag_id_);
 
    TunnelType::TypeBmap bmap = 0;
    TunnelEncapType::Encap encap =
        TunnelEncapType::TunnelEncapFromString(tunnel_type_);
    if (encap == TunnelEncapType::MPLS_O_GRE)
        bmap |= (1 << TunnelType::MPLS_GRE);
    if (encap == TunnelEncapType::MPLS_O_UDP)
        bmap |= (1 << TunnelType::MPLS_UDP);
    if (encap == TunnelEncapType::VXLAN)
        bmap |= (1 << TunnelType::VXLAN);
    if (op_delete()) {
        rt_table->DeleteReq(bgp_peer_, vrf_,
                            MacAddress::FromString(mac_),
                            Ip4Address::from_string(ip_), 32, vxlan_id_,
                            (new ControllerVmRoute(bgp_peer_)));
    } else {
        VnListType vn_list;
        vn_list.insert(vn_);
        ControllerVmRoute *data =
            ControllerVmRoute::MakeControllerVmRoute(bgp_peer_,
                                                     agent->fabric_vrf_name(),
                                                     agent->router_id(), vrf_,
                                                     Ip4Address::from_string(tunnel_dest_),
                                                     bmap, label_, MacAddress(),
                                                     vn_list, sg_list, tag_list,
                                                     PathPreference(), false,
                                                     EcmpLoadBalance(), false);
        rt_table->AddRemoteVmRouteReq(bgp_peer_, vrf_,
                                      MacAddress::FromString(mac_),
                                      Ip4Address::from_string(ip_),
                                      32, vxlan_id_, data);
    }
    return true;
}
 
// AgentUtXmlL2RouteValidate routines
AgentUtXmlL2RouteValidate::AgentUtXmlL2RouteValidate(const string &name,
                                                     const xml_node &node) :
    AgentUtXmlValidationNode(name, node) {
}
 
AgentUtXmlL2RouteValidate::~AgentUtXmlL2RouteValidate() {
}
 
bool AgentUtXmlL2RouteValidate::ReadXml() {
    if (GetStringAttribute(node(), "mac", &mac_) == false) {
        cout << "Attribute \"mac\" not specified. Skipping" << endl;
        return false;
    }
 
    if (GetStringAttribute(node(), "vrf", &vrf_) == false) {
        cout << "Attribute \"vrf_\" not specified. Skipping" << endl;
        return false;
    }
 
    if (GetStringAttribute(node(), "vn", &vn_) == false) {
        cout << "Attribute \"vn\" not specified. Skipping" << endl;
        return false;
    }
 
    string addr = "";
    GetStringAttribute(node(), "ip", &addr);
    boost::system::error_code ec;
    ip_ = IpAddress::from_string(addr, ec);
 
    GetUintAttribute(node(), "vxlan_id", &vxlan_id_);
    GetStringAttribute(node(), "tunnel-dest", &tunnel_dest_);
    GetStringAttribute(node(), "tunnel-type", &tunnel_type_);
    GetUintAttribute(node(), "intf", &intf_uuid_);
 
    return true;
}
 
bool AgentUtXmlL2RouteValidate::Validate() {
    Agent *agent = Agent::GetInstance();
    BridgeAgentRouteTable *bridge_table =
        static_cast<BridgeAgentRouteTable *>
        (agent->vrf_table()->GetBridgeRouteTable(vrf_));
    BridgeRouteEntry *rt =
        bridge_table->FindRoute(MacAddress::FromString(mac_));
    if (present() == false)
        return (rt == NULL);
 
    if (rt == NULL)
        return false;
 
    if (vn_ != "" && vn_ != rt->dest_vn_name())
        return false;
 
    return true;
}
 
const string AgentUtXmlL2RouteValidate::ToString() {
    return ("FDB <"  + name() + ">");
}
 
AgentUtXmlL3Route::AgentUtXmlL3Route(const string &name, const uuid &id,
                                     const xml_node &node,
                                     AgentUtXmlTestCase *test_case) :
    AgentUtXmlNode(name, node, false, test_case) {
}
 
AgentUtXmlL3Route::~AgentUtXmlL3Route() {
}
 
 
bool AgentUtXmlL3Route::ReadXml() {
    if (GetStringAttribute(node(), "src-ip", &src_ip_) == false) {
        cout << "Attribute \"ip\" not specified. Skipping" << endl;
        return false;
    }
 
    if (GetStringAttribute(node(), "vrf", &vrf_) == false) {
        cout << "Attribute \"vrf_\" not specified. Skipping" << endl;
        return false;
    }
 
    GetStringAttribute(node(), "ip", &ip_);
    GetStringAttribute(node(), "vn", &vn_);
    GetUintAttribute(node(), "plen", &plen_);
    GetUintAttribute(node(), "vxlan_id", &vxlan_id_);
    GetStringAttribute(node(), "tunnel-dest", &tunnel_dest_);
    GetStringAttribute(node(), "tunnel-type", &tunnel_type_);
    GetUintAttribute(node(), "sg", &sg_id_);
    GetUintAttribute(node(), "tag", &tag_id_);
    GetUintAttribute(node(), "label", &label_);
    if (ip_.empty()) {
        ip_ = "0.0.0.0";
    }
    return true;
}
 
bool AgentUtXmlL3Route::ToXml(xml_node *parent) {
    assert(0);
    return true;
}
 
void AgentUtXmlL3Route::ToString(string *str) {
    *str = "L3-Route";
    return;
}
 
string AgentUtXmlL3Route::NodeType() {
    return "L3-Route";
}
 
bool AgentUtXmlL3Route::Run() {
    Agent *agent = Agent::GetInstance();
    InetUnicastAgentRouteTable *rt_table =
        static_cast<InetUnicastAgentRouteTable *>
        (Agent::GetInstance()->vrf_table()->GetInet4UnicastRouteTable(vrf_));
 
    SecurityGroupList sg_list;
    TagList tag_list;
    if (sg_id_)
        sg_list.push_back(sg_id_);
    if (tag_id_)
        tag_list.push_back(tag_id_);
 
    TunnelType::TypeBmap bmap = 0;
    TunnelEncapType::Encap encap =
        TunnelEncapType::TunnelEncapFromString(tunnel_type_);
    if (encap == TunnelEncapType::MPLS_O_GRE)
        bmap |= (1 << TunnelType::MPLS_GRE);
    if (encap == TunnelEncapType::MPLS_O_UDP)
        bmap |= (1 << TunnelType::MPLS_UDP);
    if (encap == TunnelEncapType::VXLAN)
        bmap |= (1 << TunnelType::VXLAN);
    if (op_delete()) {
        rt_table->DeleteReq(bgp_peer_, vrf_,
                            Ip4Address::from_string(src_ip_), plen_,
                            (new ControllerVmRoute(bgp_peer_)));
    } else {
        VnListType vn_list;
        vn_list.insert(vn_);
        ControllerVmRoute *data =
            ControllerVmRoute::MakeControllerVmRoute(bgp_peer_,
                                                     agent->fabric_vrf_name(),
                                                     agent->router_id(), vrf_,
                                                     Ip4Address::from_string(tunnel_dest_),
                                                     bmap, label_, MacAddress(),
                                                     vn_list, sg_list, tag_list,
                                                     PathPreference(), false,
                                                     EcmpLoadBalance(),
                                                     false);
        rt_table->AddRemoteVmRouteReq(bgp_peer_, vrf_,
                                      Ip4Address::from_string(src_ip_), plen_,
                                      data);
    }
    return true;
}
 
AgentUtXmlL3RouteValidate::AgentUtXmlL3RouteValidate(const string &name,
                                                     const xml_node &node) :
    AgentUtXmlValidationNode(name, node) {
}
 
AgentUtXmlL3RouteValidate::~AgentUtXmlL3RouteValidate() {
}
 
bool AgentUtXmlL3RouteValidate::ReadXml() {
    if (GetStringAttribute(node(), "src-ip", &src_ip_) == false) {
        cout << "Attribute \"mac\" not specified. Skipping" << endl;
        return false;
    }
 
    if (GetStringAttribute(node(), "vrf", &vrf_) == false) {
        cout << "Attribute \"vrf_\" not specified. Skipping" << endl;
        return false;
    }
 
    if (GetStringAttribute(node(), "vn", &vn_) == false) {
        cout << "Attribute \"vn\" not specified. Skipping" << endl;
        return false;
    }
 
    string addr = "";
    GetStringAttribute(node(), "ip", &addr);
    boost::system::error_code ec;
    ip_ = IpAddress::from_string(addr, ec);
 
    GetUintAttribute(node(), "vxlan_id", &vxlan_id_);
    GetStringAttribute(node(), "tunnel-dest", &tunnel_dest_);
    GetStringAttribute(node(), "tunnel-type", &tunnel_type_);
    GetUintAttribute(node(), "intf", &intf_uuid_);
 
    return true;
}
 
bool AgentUtXmlL3RouteValidate::Validate() {
    Agent *agent = Agent::GetInstance();
    InetUnicastAgentRouteTable *inet_table =
        static_cast<InetUnicastAgentRouteTable *>
        (agent->vrf_table()->GetInet4UnicastRouteTable(vrf_));
    InetUnicastRouteEntry *rt =
        inet_table->FindRoute(Ip4Address::from_string(src_ip_));
    if (present() == false)
        return (rt == NULL);
 
    if (rt == NULL)
        return false;
 
    if (vn_ != "" && vn_ != rt->dest_vn_name())
        return false;
 
    return true;
}
 
const string AgentUtXmlL3RouteValidate::ToString() {
    return ("IP route <"  + name() + ">");
}