[fpmsyncd]: Routes update frequenct stats.

Signed-off-by: Praveen Chaudhary <[email protected]>
RB=
G=lnos-reviewers
R=pchaudhary,pmao,samaity,zxu
A=

Author: Praveen Chaudhary

fpmsyncd/routesync.cpp

@@ -12,6 +12,7 @@
 #include "macaddress.h"
 #include <string.h>
 #include <arpa/inet.h>
+#include <chrono>
 
 using namespace std;
 using namespace swss;
@@ -41,6 +42,13 @@ using namespace swss;
 
 #define ETHER_ADDR_STRLEN (3*ETH_ALEN)
 
+
+/* helper function for time */
+uint64_t getTimeEpochMsec() {
+  using namespace std::chrono;
+  return duration_cast<milliseconds>(system_clock::now().time_since_epoch()).count();
+}
+
 RouteSync::RouteSync(RedisPipeline *pipeline) :
     m_routeTable(pipeline, APP_ROUTE_TABLE_NAME, true),
     m_vnet_routeTable(pipeline, APP_VNET_RT_TABLE_NAME, true),
@@ -51,6 +59,19 @@ RouteSync::RouteSync(RedisPipeline *pipeline) :
     m_nl_sock = nl_socket_alloc();
     nl_connect(m_nl_sock, NETLINK_ROUTE);
     rtnl_link_alloc_cache(m_nl_sock, AF_UNSPEC, &m_link_cache);
+
+    /* TODO: read from configDb */
+    RED_THRESHOLD = 500;
+    ORANGE_THREASHOLD = 100;
+    currentRedroutes = 0;
+    currentOrangeroutes = 0;
+    /* update the time at start */
+    lastRedUpdated = getTimeEpochMsec();
+    lastOrangeUpdated = lastRedUpdated;
+    /* BGP_ROUTE_UPDATES Table */
+    DBConnector stateDb("STATE_DB", 0);
+    Table bgpChurnTable(&stateDb, "BGP_ROUTE_UPDATES");
+    this->bgpChurnTable = bgpChurnTable;
 }
 
 char *RouteSync::prefixMac2Str(char *mac, char *buf, int size)
@@ -723,6 +744,10 @@ void RouteSync::onRouteMsg(int nlmsg_type, struct nl_object *obj, char *vrf)
     fvVector.push_back(nh);
     fvVector.push_back(idx);
 
+    SWSS_LOG_NOTICE("PC: fpmsyncd debug image");
+
+    this->updateRouteFrequencyStats();
+
     if (!warmRestartInProgress)
     {
         m_routeTable.set(destipprefix, fvVector);
@@ -962,3 +987,25 @@ string RouteSync::getNextHopIf(struct rtnl_route *route_obj)
 
     return result;
 }
+
+void RouteSync::updateRouteFrequencyStats() {
+    
+    ++currentRedroutes;
+    ++currentOrangeroutes;
+
+    if (currentRedroutes >= RED_THRESHOLD) {
+        uint64_t curTime = getTimeEpochMsec();
+        SWSS_LOG_NOTICE("Red TH: %d routes are updated in %ld msecs\n", currentRedroutes, curTime-lastRedUpdated);
+        bgpChurnTable.hset("ROUTE_CHURN_FREQUENCY", "RED_THRESHOLD", std::to_string((currentRedroutes*1000)/(curTime-lastRedUpdated)));
+        lastRedUpdated = curTime;
+        currentRedroutes = 0;
+    }
+
+    if (currentOrangeroutes >= ORANGE_THREASHOLD) {
+        uint64_t curTime = getTimeEpochMsec();
+        SWSS_LOG_NOTICE("Orange TH: %d routes are updated in %ld msecs\n", currentOrangeroutes, curTime-lastOrangeUpdated);
+        bgpChurnTable.hset("ROUTE_CHURN_FREQUENCY", "ORANGE_THRESHOLD", std::to_string((currentOrangeroutes*1000)/(curTime-lastOrangeUpdated)));
+        lastOrangeUpdated = curTime;
+        currentOrangeroutes = 0;
+    }
+}

fpmsyncd/routesync.h

@@ -75,6 +75,16 @@ class RouteSync : public NetMsg
 
     /* Get next hop interfaces */
     string getNextHopIf(struct rtnl_route *route_obj);
+ 
+    void updateRouteFrequencyStats();
+
+    int RED_THRESHOLD;
+    int ORANGE_THREASHOLD;
+    uint16_t currentRedroutes;
+    uint16_t currentOrangeroutes;
+    uint64_t lastRedUpdated;
+    uint64_t lastOrangeUpdated;
+    Table bgpChurnTable = nullptr;
 };
 
 }