Line data    Source code

       1             : /*
       2             :  * Copyright (c) 2014 Juniper Networks, Inc. All rights reserved.
       3             :  */
       4             : 
       5             : #include "bgp/inet6/inet6_table.h"
       6             : 
       7             : #include "bgp/bgp_server.h"
       8             : #include "bgp/bgp_update.h"
       9             : #include "bgp/inet6vpn/inet6vpn_route.h"
      10             : #include "bgp/routing-instance/path_resolver.h"
      11             : #include "bgp/routing-instance/routing_instance.h"
      12             : 
      13         578 : Inet6Table::Inet6Table(DB *db, const std::string &name)
      14         578 :     : BgpTable(db, name) {
      15         578 : }
      16             : 
      17      714063 : size_t Inet6Table::HashFunction(const Inet6Prefix &prefix) {
      18      714063 :     const Ip6Address::bytes_type &addr_bytes = prefix.ToBytes();
      19     1426582 :     return boost::hash_range(addr_bytes.begin(), addr_bytes.end());
      20             : }
      21             : 
      22       32464 : std::unique_ptr<DBEntry> Inet6Table::AllocEntry(const DBRequestKey *key) const {
      23       32464 :     const RequestKey *rkey = static_cast<const RequestKey *>(key);
      24       32464 :     return std::unique_ptr<DBEntry> (new Inet6Route(rkey->prefix));
      25             : }
      26             : 
      27           0 : std::unique_ptr<DBEntry> Inet6Table::AllocEntryStr(
      28             :         const std::string &key_str) const {
      29           0 :     Inet6Prefix prefix = Inet6Prefix::FromString(key_str);
      30           0 :     return std::unique_ptr<DBEntry> (new Inet6Route(prefix));
      31             : }
      32             : 
      33      521089 : size_t Inet6Table::Hash(const DBEntry *entry) const {
      34      521089 :     const Inet6Route *route = static_cast<const Inet6Route *>(entry);
      35      521089 :     size_t value = HashFunction(route->GetPrefix());
      36      520100 :     return value % DB::PartitionCount();
      37             : }
      38             : 
      39         640 : size_t Inet6Table::Hash(const DBRequestKey *key) const {
      40         640 :     const RequestKey *rkey = static_cast<const RequestKey *>(key);
      41         640 :     size_t value = HashFunction(rkey->prefix);
      42         640 :     return value % DB::PartitionCount();
      43             : }
      44             : 
      45         640 : BgpRoute *Inet6Table::TableFind(DBTablePartition *partition,
      46             :                                 const DBRequestKey *key) {
      47         640 :     const RequestKey *rkey = static_cast<const RequestKey *>(key);
      48         640 :     Inet6Route route(rkey->prefix);
      49        1280 :     return static_cast<BgpRoute *>(partition->Find(&route));
      50         640 : }
      51             : 
      52         578 : DBTableBase *Inet6Table::CreateTable(DB *db, const std::string &name) {
      53         578 :     Inet6Table *table = new Inet6Table(db, name);
      54         578 :     table->Init();
      55         578 :     return table;
      56             : }
      57             : 
      58       43265 : BgpRoute *Inet6Table::RouteReplicate(BgpServer *server, BgpTable *src_table,
      59             :         BgpRoute *src_rt, const BgpPath *path, ExtCommunityPtr community) {
      60       43265 :     assert((src_table->family()  == Address::INET6) ||
      61             :            (src_table->family()  == Address::INET6VPN));
      62             : 
      63       43264 :     Inet6Route *source = dynamic_cast<Inet6Route *>(src_rt);
      64             : 
      65       43264 :     RouteDistinguisher rd;
      66             : 
      67       43262 :     boost::scoped_ptr<Inet6Prefix> prefix;
      68       43262 :     if (source) {
      69        6144 :         prefix.reset(new Inet6Prefix(source->GetPrefix().ip6_addr(),
      70        3072 :                                      source->GetPrefix().prefixlen()));
      71             :     } else {
      72       40190 :         Inet6VpnRoute *vpn_route = dynamic_cast<Inet6VpnRoute *> (src_rt);
      73       40190 :         assert(vpn_route);
      74       40190 :         rd = vpn_route->GetPrefix().route_distinguisher();
      75       80379 :         prefix.reset(new Inet6Prefix(vpn_route->GetPrefix().addr(),
      76       40189 :                                      vpn_route->GetPrefix().prefixlen()));
      77             :     }
      78             : 
      79       43261 :     Inet6Route route(*prefix);
      80             :     DBTablePartition *partition =
      81       43266 :         static_cast<DBTablePartition *>(GetTablePartition(&route));
      82       43243 :     BgpRoute *dest_route = static_cast<BgpRoute *>(partition->Find(&route));
      83       43265 :     if (dest_route == NULL) {
      84       24832 :         dest_route = new Inet6Route(route.GetPrefix());
      85       24831 :         partition->Add(dest_route);
      86             :     } else {
      87       18433 :         dest_route->ClearDelete();
      88             :     }
      89             : 
      90             :     // Replace the extended community with the one provided.
      91       43260 :     BgpAttrDB *attr_db = server->attr_db();
      92             :     BgpAttrPtr new_attr = attr_db->ReplaceExtCommunityAndLocate(path->GetAttr(),
      93       43256 :                                                                 community);
      94             : 
      95       43267 :     if (!source) {
      96       40196 :         new_attr = attr_db->ReplaceSourceRdAndLocate(new_attr.get(), rd);
      97             :     }
      98             : 
      99             :     // Check whether there's already a path with the given peer and path id.
     100             :     BgpPath *dest_path =
     101       43267 :         dest_route->FindSecondaryPath(src_rt, path->GetSource(),
     102             :                                       path->GetPeer(), path->GetPathId());
     103       43268 :     if (dest_path != NULL) {
     104       36872 :         if ((new_attr != dest_path->GetOriginalAttr()) ||
     105       36872 :             (path->GetFlags() != dest_path->GetFlags()) ||
     106       14852 :             (path->GetLabel() != dest_path->GetLabel())) {
     107             :             // Update Attributes and notify (if needed)
     108        3584 :             if (dest_path->NeedsResolution()) {
     109           0 :                 path_resolver()->StopPathResolution(partition->index(),
     110             :                                                     dest_path);
     111             :             }
     112        3584 :             assert(dest_route->RemoveSecondaryPath(src_rt, path->GetSource(),
     113             :                 path->GetPeer(), path->GetPathId()));
     114             :         } else {
     115       14852 :             return dest_route;
     116             :         }
     117             :     }
     118             : 
     119             :     BgpSecondaryPath *replicated_path =
     120       28416 :         new BgpSecondaryPath(path->GetPeer(), path->GetPathId(),
     121       28415 :             path->GetSource(), new_attr, path->GetFlags(), path->GetLabel());
     122       28416 :     replicated_path->SetReplicateInfo(src_table, src_rt);
     123             : 
     124             :     // For VPN to VRF replication, start path resolution if fast convergence is
     125             :     // enabled and update path flag to indicate need for resolution.
     126       28415 :     if (!source && (server->IsNextHopCheckEnabled()) &&
     127           0 :         (replicated_path->GetSource() == BgpPath::BGP_XMPP)) {
     128           0 :         Address::Family family = replicated_path->GetAttr()->nexthop_family();
     129           0 :         RoutingInstanceMgr *mgr = server->routing_instance_mgr();
     130           0 :         RoutingInstance *master_ri = mgr->GetDefaultRoutingInstance();
     131           0 :         BgpTable *table = master_ri->GetTable(family);
     132           0 :         replicated_path->SetResolveNextHop();
     133           0 :         path_resolver()->StartPathResolution(dest_route, replicated_path,
     134             :                                              table);
     135             :     }
     136             : 
     137       28414 :     dest_route->InsertPath(replicated_path);
     138             : 
     139             :     // Notify the route even if the best path may not have changed. For XMPP
     140             :     // peers, we support sending multiple ECMP next-hops for a single route.
     141             :     //
     142             :     // TODO(ananth): Can be optimized for changes that does not result in
     143             :     // any change to ECMP list
     144       28413 :     partition->Notify(dest_route);
     145             : 
     146       28416 :     return dest_route;
     147       43268 : }
     148             : 
     149       33076 : bool Inet6Table::Export(RibOut *ribout, Route *route, const RibPeerSet &peerset,
     150             :         UpdateInfoSList &uinfo_slist) {
     151       33076 :     BgpRoute *bgp_route = static_cast<BgpRoute *> (route);
     152       33076 :     UpdateInfo *uinfo = GetUpdateInfo(ribout, bgp_route, peerset);
     153       33110 :     if (!uinfo) {
     154           0 :         return false;
     155             :     }
     156             : 
     157       33110 :     if (ribout->ExportPolicy().encoding == RibExportPolicy::BGP) {
     158           0 :         BgpAttrDB *attr_db = routing_instance()->server()->attr_db();
     159             :         // Strip ExtCommunity.
     160           0 :         if (uinfo->roattr.attr()->ext_community()) {
     161             :             BgpAttrPtr new_attr = attr_db->ReplaceExtCommunityAndLocate(
     162           0 :                 uinfo->roattr.attr(), NULL);
     163           0 :             uinfo->roattr.set_attr(this, new_attr);
     164           0 :         }
     165             : 
     166             :         // Strip OriginVnPath.
     167           0 :         if (uinfo->roattr.attr()->origin_vn_path()) {
     168             :             BgpAttrPtr new_attr = attr_db->ReplaceOriginVnPathAndLocate(
     169           0 :                 uinfo->roattr.attr(), NULL);
     170           0 :             uinfo->roattr.set_attr(this, new_attr);
     171           0 :         }
     172             :     }
     173       33110 :     uinfo_slist->push_front(*uinfo);
     174             : 
     175       33107 :     return true;
     176             : }
     177             : 
     178         160 : PathResolver *Inet6Table::CreatePathResolver() {
     179         160 :     if (routing_instance()->IsMasterRoutingInstance())
     180           0 :         return NULL;
     181         160 :     return (new PathResolver(this));
     182             : }
     183             : 
     184           3 : static void RegisterFactory() {
     185           3 :     DB::RegisterFactory("inet6.0", &Inet6Table::CreateTable);
     186           3 : }
     187             : MODULE_INITIALIZER(RegisterFactory);