Method UpdateDBWdrawnPrefixes

Server/src/bgp/parseBGP.cpp:724–761

* Update the Database withdrawn prefixes * * \details This method will update the database for the supplied advertised prefixes * * \param wdrawn_prefixes Reference to the list of withdrawn prefixes */

 * \param  wdrawn_prefixes         Reference to the list<prefix_tuple> of withdrawn prefixes
 */
void parseBGP::UpdateDBWdrawnPrefixes(std::list<bgp::prefix_tuple> &wdrawn_prefixes) {
    vector<MsgBusInterface::obj_rib> rib_list;
    MsgBusInterface::obj_rib         rib_entry;

    /*
     * Loop through all prefixes and add/update them in the DB
     */
    for (std::list<bgp::prefix_tuple>::iterator it = wdrawn_prefixes.begin();
                                                it != wdrawn_prefixes.end();
                                                it++) {

        bgp::prefix_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));
        strncpy(rib_entry.prefix, tuple.prefix.c_str(), sizeof(rib_entry.prefix));

        rib_entry.prefix_len     = tuple.len;

        rib_entry.isIPv4 = tuple.isIPv4 ? 1 : 0;

        memcpy(rib_entry.prefix_bin, tuple.prefix_bin, sizeof(rib_entry.prefix_bin));

        rib_entry.path_id = tuple.path_id;
        snprintf(rib_entry.labels, sizeof(rib_entry.labels), "%s", tuple.labels.c_str());

        SELF_DEBUG("%s: Removing prefix=%s len=%d", p_entry->peer_addr, rib_entry.prefix, rib_entry.prefix_len);

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

    // Update the DB
    if (rib_list.size() > 0)
        mbus_ptr->update_unicastPrefix(*p_entry, rib_list, NULL, mbus_ptr->UNICAST_PREFIX_ACTION_DEL);

    rib_list.clear();
    wdrawn_prefixes.clear();
}

/**
 * Update the Database for bgp-ls