Method UpdateDBAttrs

Server/src/bgp/parseBGP.cpp:386–457

* Update the Database path attributes * * \details This method will update the database for the supplied path attributes * * \param attrs Reference to the parsed attributes map */

 * \param  attrs            Reference to the parsed attributes map
 */
void parseBGP::UpdateDBAttrs(bgp_msg::UpdateMsg::parsed_attrs_map &attrs) {

    /*
     * Setup the record
     */
    base_attr.as_path                  = (string)attrs[bgp_msg::ATTR_TYPE_AS_PATH];
    base_attr.cluster_list             = (string)attrs[bgp_msg::ATTR_TYPE_CLUSTER_LIST];
    base_attr.community_list           = (string)attrs[bgp_msg::ATTR_TYPE_COMMUNITIES];
    base_attr.ext_community_list       = (string)attrs[bgp_msg::ATTR_TYPE_EXT_COMMUNITY];
    base_attr.large_community_list     = (string)attrs[bgp_msg::ATTR_TYPE_LARGE_COMMUNITY];

    base_attr.atomic_agg               = ((string)attrs[bgp_msg::ATTR_TYPE_ATOMIC_AGGREGATE]).compare("1") == 0 ? true : false;

    if (((string)attrs[bgp_msg::ATTR_TYPE_LOCAL_PREF]).length() > 0)
        base_attr.local_pref = std::stoul(((string)attrs[bgp_msg::ATTR_TYPE_LOCAL_PREF]));
    else
        base_attr.local_pref = 0;

    if (((string)attrs[bgp_msg::ATTR_TYPE_MED]).length() > 0)
        base_attr.med = std::stoul(((string)attrs[bgp_msg::ATTR_TYPE_MED]));
    else
        base_attr.med = 0;

    if (((string)attrs[bgp_msg::ATTR_TYPE_INTERNAL_AS_COUNT]).length() > 0)
        base_attr.as_path_count = std::stoi(((string)attrs[bgp_msg::ATTR_TYPE_INTERNAL_AS_COUNT]));
    else
        base_attr.as_path_count = 0;

    if (((string)attrs[bgp_msg::ATTR_TYPE_INTERNAL_AS_ORIGIN]).length() > 0)
        base_attr.origin_as = std::stoul(((string)attrs[bgp_msg::ATTR_TYPE_INTERNAL_AS_ORIGIN]));
    else
        base_attr.origin_as = 0;

    if (((string)attrs[bgp_msg::ATTR_TYPE_ORIGINATOR_ID]).length() > 0)
        strncpy(base_attr.originator_id, ((string)attrs[bgp_msg::ATTR_TYPE_ORIGINATOR_ID]).c_str(), sizeof(base_attr.originator_id));
    else
        bzero(base_attr.originator_id, sizeof(base_attr.originator_id));

    if ( ((string)attrs[bgp_msg::ATTR_TYPE_NEXT_HOP]).find_first_of(':') ==  string::npos)
        base_attr.nexthop_isIPv4 = true;
    else // is IPv6
        base_attr.nexthop_isIPv4 = false;

    if ( ((string)attrs[bgp_msg::ATTR_TYPE_AGGEGATOR]).length() > 0)
        strncpy(base_attr.aggregator, ((string)attrs[bgp_msg::ATTR_TYPE_AGGEGATOR]).c_str(), sizeof(base_attr.aggregator));
    else
        bzero(base_attr.aggregator, sizeof(base_attr.aggregator));

    if ( ((string)attrs[bgp_msg::ATTR_TYPE_ORIGIN]).length() > 0)
            strncpy(base_attr.origin, ((string)attrs[bgp_msg::ATTR_TYPE_ORIGIN]).c_str(), sizeof(base_attr.origin));
    else
        bzero(base_attr.origin, sizeof(base_attr.origin));

    if ( ((string)attrs[bgp_msg::ATTR_TYPE_NEXT_HOP]).length() > 0)
        strncpy(base_attr.next_hop, ((string)attrs[bgp_msg::ATTR_TYPE_NEXT_HOP]).c_str(), sizeof(base_attr.next_hop));

    else {
        // Skip adding path attributes if next hop is missing