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       51136 : Inet6Table::Inet6Table(DB *db, const std::string &name)
      14       51136 :     : BgpTable(db, name) {
      15       51136 : }
      16             : 
      17     5003471 : size_t Inet6Table::HashFunction(const Inet6Prefix &prefix) {
      18     5003471 :     const Ip6Address::bytes_type &addr_bytes = prefix.ToBytes();
      19    10000980 :     return boost::hash_range(addr_bytes.begin(), addr_bytes.end());
      20             : }
      21             : 
      22      196398 : std::unique_ptr<DBEntry> Inet6Table::AllocEntry(const DBRequestKey *key) const {
      23      196398 :     const RequestKey *rkey = static_cast<const RequestKey *>(key);
      24      196398 :     return std::unique_ptr<DBEntry> (new Inet6Route(rkey->prefix));
      25             : }
      26             : 
      27          20 : std::unique_ptr<DBEntry> Inet6Table::AllocEntryStr(
      28             :         const std::string &key_str) const {
      29          20 :     Inet6Prefix prefix = Inet6Prefix::FromString(key_str);
      30          40 :     return std::unique_ptr<DBEntry> (new Inet6Route(prefix));
      31             : }
      32             : 
      33     3497929 : size_t Inet6Table::Hash(const DBEntry *entry) const {
      34     3497929 :     const Inet6Route *route = static_cast<const Inet6Route *>(entry);
      35     3497929 :     size_t value = HashFunction(route->GetPrefix());
      36     3494835 :     return value % DB::PartitionCount();
      37             : }
      38             : 
      39       38236 : size_t Inet6Table::Hash(const DBRequestKey *key) const {
      40       38236 :     const RequestKey *rkey = static_cast<const RequestKey *>(key);
      41       38236 :     size_t value = HashFunction(rkey->prefix);
      42       38236 :     return value % DB::PartitionCount();
      43             : }
      44             : 
      45       27010 : BgpRoute *Inet6Table::TableFind(DBTablePartition *partition,
      46             :                                 const DBRequestKey *key) {
      47       27010 :     const RequestKey *rkey = static_cast<const RequestKey *>(key);
      48       27010 :     Inet6Route route(rkey->prefix);
      49       54070 :     return static_cast<BgpRoute *>(partition->Find(&route));
      50       27043 : }
      51             : 
      52       51136 : DBTableBase *Inet6Table::CreateTable(DB *db, const std::string &name) {
      53       51136 :     Inet6Table *table = new Inet6Table(db, name);
      54       51136 :     table->Init();
      55       51136 :     return table;
      56             : }
      57             : 
      58      288620 : BgpRoute *Inet6Table::RouteReplicate(BgpServer *server, BgpTable *src_table,
      59             :         BgpRoute *src_rt, const BgpPath *path, ExtCommunityPtr community) {
      60      288620 :     assert((src_table->family()  == Address::INET6) ||
      61             :            (src_table->family()  == Address::INET6VPN));
      62             : 
      63      288611 :     Inet6Route *source = dynamic_cast<Inet6Route *>(src_rt);
      64             : 
      65      288611 :     RouteDistinguisher rd;
      66             : 
      67      288617 :     boost::scoped_ptr<Inet6Prefix> prefix;
      68      288617 :     if (source) {
      69       56596 :         prefix.reset(new Inet6Prefix(source->GetPrefix().ip6_addr(),
      70       28298 :                                      source->GetPrefix().prefixlen()));
      71             :     } else {
      72      260319 :         Inet6VpnRoute *vpn_route = dynamic_cast<Inet6VpnRoute *> (src_rt);
      73      260319 :         assert(vpn_route);
      74      260319 :         rd = vpn_route->GetPrefix().route_distinguisher();
      75      520602 :         prefix.reset(new Inet6Prefix(vpn_route->GetPrefix().addr(),
      76      260306 :                                      vpn_route->GetPrefix().prefixlen()));
      77             :     }
      78             : 
      79      288588 :     Inet6Route route(*prefix);
      80             :     DBTablePartition *partition =
      81      288609 :         static_cast<DBTablePartition *>(GetTablePartition(&route));
      82      288575 :     BgpRoute *dest_route = static_cast<BgpRoute *>(partition->Find(&route));
      83      288621 :     if (dest_route == NULL) {
      84      167781 :         dest_route = new Inet6Route(route.GetPrefix());
      85      167782 :         partition->Add(dest_route);
      86             :     } else {
      87      120840 :         dest_route->ClearDelete();
      88             :     }
      89             : 
      90             :     // Replace the extended community with the one provided.
      91      288618 :     BgpAttrDB *attr_db = server->attr_db();
      92             :     BgpAttrPtr new_attr = attr_db->ReplaceExtCommunityAndLocate(path->GetAttr(),
      93      288614 :                                                                 community);
      94             : 
      95      288627 :     if (!source) {
      96      260328 :         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      288628 :         dest_route->FindSecondaryPath(src_rt, path->GetSource(),
     102             :                                       path->GetPeer(), path->GetPathId());
     103      288609 :     if (dest_path != NULL) {
     104      231625 :         if ((new_attr != dest_path->GetOriginalAttr()) ||
     105      231623 :             (path->GetFlags() != dest_path->GetFlags()) ||
     106       99844 :             (path->GetLabel() != dest_path->GetLabel())) {
     107             :             // Update Attributes and notify (if needed)
     108       19009 :             if (dest_path->NeedsResolution()) {
     109           0 :                 path_resolver()->StopPathResolution(partition->index(),
     110             :                                                     dest_path);
     111             :             }
     112       19009 :             assert(dest_route->RemoveSecondaryPath(src_rt, path->GetSource(),
     113             :                 path->GetPeer(), path->GetPathId()));
     114             :         } else {
     115       99823 :             return dest_route;
     116             :         }
     117             :     }
     118             : 
     119             :     BgpSecondaryPath *replicated_path =
     120      188781 :         new BgpSecondaryPath(path->GetPeer(), path->GetPathId(),
     121      188781 :             path->GetSource(), new_attr, path->GetFlags(), path->GetLabel());
     122      188791 :     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      188788 :     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      188786 :     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      188790 :     partition->Notify(dest_route);
     145             : 
     146      188792 :     return dest_route;
     147      288615 : }
     148             : 
     149      217984 : bool Inet6Table::Export(RibOut *ribout, Route *route, const RibPeerSet &peerset,
     150             :         UpdateInfoSList &uinfo_slist) {
     151      217984 :     BgpRoute *bgp_route = static_cast<BgpRoute *> (route);
     152      217984 :     UpdateInfo *uinfo = GetUpdateInfo(ribout, bgp_route, peerset);
     153      218040 :     if (!uinfo) {
     154        4562 :         return false;
     155             :     }
     156             : 
     157      213478 :     if (ribout->ExportPolicy().encoding == RibExportPolicy::BGP) {
     158        4562 :         BgpAttrDB *attr_db = routing_instance()->server()->attr_db();
     159             :         // Strip ExtCommunity.
     160        4562 :         if (uinfo->roattr.attr()->ext_community()) {
     161             :             BgpAttrPtr new_attr = attr_db->ReplaceExtCommunityAndLocate(
     162        1675 :                 uinfo->roattr.attr(), NULL);
     163        1675 :             uinfo->roattr.set_attr(this, new_attr);
     164        1675 :         }
     165             : 
     166             :         // Strip OriginVnPath.
     167        4562 :         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      213479 :     uinfo_slist->push_front(*uinfo);
     174             : 
     175      213479 :     return true;
     176             : }
     177             : 
     178       42908 : PathResolver *Inet6Table::CreatePathResolver() {
     179       42908 :     if (routing_instance()->IsMasterRoutingInstance())
     180           0 :         return NULL;
     181       42908 :     return (new PathResolver(this));
     182             : }
     183             : 
     184         159 : static void RegisterFactory() {
     185         159 :     DB::RegisterFactory("inet6.0", &Inet6Table::CreateTable);
     186         159 : }
     187             : MODULE_INITIALIZER(RegisterFactory);