Method UpdateDBeVPN

Server/src/bgp/parseBGP.cpp:570–619

* Updates for either advertised or withdrawn Evpn NLRI's * * \param [in] remove True if the records should be deleted, false if they are to be added/updated * \param [in] nlris Reference to the list * \param [in] attrs Reference to the parsed attributes map */

 * \param [in] attrs           Reference to the parsed attributes map
 */
void parseBGP::UpdateDBeVPN(bool remove, std::list<bgp::evpn_tuple> &nlris,
                           bgp_msg::UpdateMsg::parsed_attrs_map &attrs) {

    vector<MsgBusInterface::obj_evpn> rib_list;
    MsgBusInterface::obj_evpn         rib_entry;

    /*
     * Loop through all vpn and add/update them in the DB
     */
    for (std::list<bgp::evpn_tuple>::iterator it = nlris.begin();
         it != nlris.end();
         it++) {
        bgp::evpn_tuple &tuple = (*it);

        memcpy(rib_entry.path_attr_hash_id, path_hash_id, sizeof(rib_entry.path_attr_hash_id));
        memcpy(rib_entry.peer_hash_id, p_entry->hash_id, sizeof(rib_entry.peer_hash_id));

        rib_entry.rd_type = tuple.rd_type;
        rib_entry.rd_assigned_number = tuple.rd_assigned_number;
        rib_entry.rd_administrator_subfield = tuple.rd_administrator_subfield;

        strcpy(rib_entry.ethernet_tag_id_hex, tuple.ethernet_tag_id_hex.c_str());
        rib_entry.mpls_label_1 = tuple.mpls_label_1;
        rib_entry.mac_len = tuple.mac_len;
        strcpy(rib_entry.mac, tuple.mac.c_str());
        rib_entry.ip_len = tuple.ip_len;
        strcpy(rib_entry.ip, tuple.ip.c_str());
        rib_entry.mpls_label_2 = tuple.mpls_label_2;
        rib_entry.originating_router_ip_len = tuple.originating_router_ip_len;
        strcpy(rib_entry.originating_router_ip, tuple.originating_router_ip.c_str());
        strcpy(rib_entry.ethernet_segment_identifier, tuple.ethernet_segment_identifier.c_str());


        rib_entry.path_id = tuple.path_id;

        SELF_DEBUG("%s: %s evpn mac=%s ip=%s", p_entry->peer_addr,
                   remove ? "removing" : "adding", rib_entry.mac, rib_entry.ip);

        // Add entry to the list
        rib_list.insert(rib_list.end(), rib_entry);
    }

    // Update the DB
    if (rib_list.size() > 0)
        mbus_ptr->update_eVPN(*p_entry, rib_list, &base_attr,
                              remove ? mbus_ptr->VPN_ACTION_DEL : mbus_ptr->VPN_ACTION_ADD);

    rib_list.clear();
    nlris.clear();
}


/**