bgpd: Code to handle BGP aggregate's l-communities.

With this commit:
1) The code to manage the large-communities attribute of the routes that are
   aggregatable under a configured aggregate-address is introduced.
2) The code to compute the aggregate-route's large-communities attribute is
   introduced.

Signed-off-by: NaveenThanikachalam <nthanikachal@vmware.com>

diff --git a/bgpd/bgp_lcommunity.c b/bgpd/bgp_lcommunity.c
index cfc9af7777e81a0827bb606c1e12c571849733b7..1e458971926080e27238ffcc6dfd97bc3694ca40 100644 (file)
--- a/bgpd/bgp_lcommunity.c
+++ b/bgpd/bgp_lcommunity.c
@@ -537,3 +537,112 @@ void lcommunity_del_val(struct lcommunity *lcom, uint8_t *ptr)
                i++;
        }
 }
+
+static struct lcommunity *bgp_aggr_lcommunity_lookup(
+                                               struct bgp_aggregate *aggregate,
+                                               struct lcommunity *lcommunity)
+{
+       return hash_lookup(aggregate->lcommunity_hash, lcommunity);
+}
+
+static void *bgp_aggr_lcommunty_hash_alloc(void *p)
+{
+       struct lcommunity *ref = (struct lcommunity *)p;
+       struct lcommunity *lcommunity = NULL;
+
+       lcommunity = lcommunity_dup(ref);
+       return lcommunity;
+}
+
+static void bgp_aggr_lcommunity_prepare(struct hash_backet *hb, void *arg)
+{
+       struct lcommunity *lcommerge = NULL;
+       struct lcommunity *hb_lcommunity = hb->data;
+       struct lcommunity **aggr_lcommunity = arg;
+
+       if (*aggr_lcommunity) {
+               lcommerge = lcommunity_merge(*aggr_lcommunity, hb_lcommunity);
+               *aggr_lcommunity = lcommunity_uniq_sort(lcommerge);
+               lcommunity_free(&lcommerge);
+       } else
+               *aggr_lcommunity = lcommunity_dup(hb_lcommunity);
+}
+
+void bgp_aggr_lcommunity_remove(void *arg)
+{
+       struct lcommunity *lcommunity = arg;
+
+       lcommunity_free(&lcommunity);
+}
+
+void bgp_compute_aggregate_lcommunity(struct bgp_aggregate *aggregate,
+                                     struct lcommunity *lcommunity)
+{
+       struct lcommunity *aggr_lcommunity = NULL;
+
+       if ((aggregate == NULL) || (lcommunity == NULL))
+               return;
+
+       /* Create hash if not already created.
+        */
+       if (aggregate->lcommunity_hash == NULL)
+               aggregate->lcommunity_hash = hash_create(
+                                       lcommunity_hash_make, lcommunity_cmp,
+                                       "BGP Aggregator lcommunity hash");
+
+       aggr_lcommunity = bgp_aggr_lcommunity_lookup(aggregate, lcommunity);
+       if (aggr_lcommunity == NULL) {
+               /* Insert lcommunity into hash.
+                */
+               aggr_lcommunity = hash_get(aggregate->lcommunity_hash,
+                                          lcommunity,
+                                          bgp_aggr_lcommunty_hash_alloc);
+
+               /* Re-compute aggregate's lcommunity.
+                */
+               if (aggregate->lcommunity)
+                       lcommunity_free(&aggregate->lcommunity);
+
+               hash_iterate(aggregate->lcommunity_hash,
+                            bgp_aggr_lcommunity_prepare,
+                            &aggregate->lcommunity);
+       }
+
+       /* Increment refernce counter.
+        */
+       aggr_lcommunity->refcnt++;
+}
+
+void bgp_remove_lcommunity_from_aggregate(struct bgp_aggregate *aggregate,
+                                         struct lcommunity *lcommunity)
+{
+       struct lcommunity *aggr_lcommunity = NULL;
+       struct lcommunity *ret_lcomm = NULL;
+
+       if ((aggregate == NULL) || (lcommunity == NULL))
+               return;
+
+       if (aggregate->lcommunity_hash == NULL)
+               return;
+
+       /* Look-up the lcommunity in the hash.
+        */
+       aggr_lcommunity = bgp_aggr_lcommunity_lookup(aggregate, lcommunity);
+       if (aggr_lcommunity) {
+               aggr_lcommunity->refcnt--;
+
+               if (aggr_lcommunity->refcnt == 0) {
+                       ret_lcomm = hash_release(aggregate->lcommunity_hash,
+                                                aggr_lcommunity);
+                       lcommunity_free(&ret_lcomm);
+
+                       lcommunity_free(&aggregate->lcommunity);
+
+                       /* Compute aggregate's lcommunity.
+                        */
+                       hash_iterate(aggregate->lcommunity_hash,
+                                    bgp_aggr_lcommunity_prepare,
+                                    &aggregate->lcommunity);
+               }
+       }
+}

diff --git a/bgpd/bgp_lcommunity.h b/bgpd/bgp_lcommunity.h
index 23c777d9fd38da5720f6b025ff18def08a1d3164..aa4e8c69fe4744e9a8eb3c24b6898ae26224ba90 100644 (file)
--- a/bgpd/bgp_lcommunity.h
+++ b/bgpd/bgp_lcommunity.h
@@ -22,6 +22,7 @@
 #define _QUAGGA_BGP_LCOMMUNITY_H
 
 #include "lib/json.h"
+#include "bgpd/bgp_route.h"
 
 /* Large Communities value is twelve octets long.  */
 #define LCOMMUNITY_SIZE                        12
@@ -70,4 +71,13 @@ extern int lcommunity_match(const struct lcommunity *,
 extern char *lcommunity_str(struct lcommunity *, bool make_json);
 extern int lcommunity_include(struct lcommunity *lcom, uint8_t *ptr);
 extern void lcommunity_del_val(struct lcommunity *lcom, uint8_t *ptr);
+
+extern void bgp_compute_aggregate_lcommunity(
+                                       struct bgp_aggregate *aggregate,
+                                       struct lcommunity *lcommunity);
+extern void bgp_remove_lcommunity_from_aggregate(
+                                       struct bgp_aggregate *aggregate,
+                                       struct lcommunity *lcommunity);
+extern void bgp_aggr_lcommunity_remove(void *arg);
+
 #endif /* _QUAGGA_BGP_LCOMMUNITY_H */