macsecmgr init

Signed-off-by: Ze Gan <ganze718@gmail.com>

cfgmgr/Makefile.am

@@ -3,7 +3,7 @@ CFLAGS_SAI = -I /usr/include/sai
 LIBNL_CFLAGS = -I/usr/include/libnl3
 LIBNL_LIBS = -lnl-genl-3 -lnl-route-3 -lnl-3
 
-bin_PROGRAMS = vlanmgrd teammgrd portmgrd intfmgrd buffermgrd vrfmgrd nbrmgrd vxlanmgrd sflowmgrd natmgrd
+bin_PROGRAMS = vlanmgrd teammgrd portmgrd intfmgrd buffermgrd vrfmgrd nbrmgrd vxlanmgrd sflowmgrd natmgrd macsecmgrd
 
 if DEBUG
 DBGFLAGS = -ggdb -DDEBUG
@@ -60,3 +60,8 @@ natmgrd_SOURCES = natmgrd.cpp natmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_
 natmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
 natmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
 natmgrd_LDADD = -lswsscommon
+
+macsecmgrd_SOURCES = macsecmgrd.cpp macsecmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
+macsecmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
+macsecmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
+macsecmgrd_LDADD = -lswsscommon

cfgmgr/macsecmgr.cpp

@@ -0,0 +1,16 @@
+#include <vector>
+
+#include "macsecmgr.h"
+
+using namespace std;
+using namespace swss;
+
+MACsecMgr::MACsecMgr(DBConnector *cfgDb, DBConnector *appDb, DBConnector *stateDb, const vector<std::string> &tables) :
+        Orch(cfgDb, tables)
+{
+}
+
+void MACsecMgr::doTask(Consumer &consumer)
+{
+
+}

cfgmgr/macsecmgr.h

@@ -0,0 +1,27 @@
+#ifndef __MACSECMGR__
+#define __MACSECMGR__
+
+// The following definitions should be moved to schema.h
+
+#define CFG_MACSEC_PROFILE_TABLE_NAME           "MACSEC_PROFILE"
+
+// End define
+
+#include <orch.h>
+
+
+namespace swss {
+
+class MACsecMgr : public Orch
+{
+public:
+    using Orch::doTask;
+    MACsecMgr(DBConnector *cfgDb, DBConnector *appDb, DBConnector *stateDb, const std::vector<std::string> &tableNames);
+
+private:
+    void doTask(Consumer &consumer);
+};
+
+}
+
+#endif

cfgmgr/macsecmgrd.cpp

@@ -0,0 +1,96 @@
+#include <unistd.h>
+#include <vector>
+#include <sstream>
+#include <fstream>
+#include <iostream>
+#include <mutex>
+#include <algorithm>
+
+#include <logger.h>
+#include <producerstatetable.h>
+#include <macaddress.h>
+#include <exec.h>
+#include <tokenize.h>
+#include <shellcmd.h>
+#include <warm_restart.h>
+#include <select.h>
+
+#include "macsecmgr.h"
+
+using namespace std;
+using namespace swss;
+
+/* select() function timeout retry time, in millisecond */
+#define SELECT_TIMEOUT 1000
+
+MacAddress gMacAddress;
+
+/*
+ * Following global variables are defined here for the purpose of
+ * using existing Orch class which is to be refactored soon to
+ * eliminate the direct exposure of the global variables.
+ *
+ * Once Orch class refactoring is done, these global variables
+ * should be removed from here.
+ */
+int gBatchSize = 0;
+bool gSwssRecord = false;
+bool gLogRotate = false;
+ofstream gRecordOfs;
+string gRecordFile;
+/* Global database mutex */
+mutex gDbMutex;
+
+
+int main(int argc, char **argv)
+{
+
+    try
+    {
+
+        swss::DBConnector cfgDb("CONFIG_DB", 0);
+        DBConnector appDb("APPL_DB", 0);
+        DBConnector stateDb("STATE_DB", 0);
+
+        std::vector<std::string> cfg_macsec_tables = {
+            CFG_MACSEC_PROFILE_TABLE_NAME,
+        };
+
+        MACsecMgr macsecmgr(&cfgDb, &appDb, &stateDb, cfg_macsec_tables);
+
+        std::vector<Orch *> cfgOrchList = {&macsecmgr};
+
+        swss::Select s;
+        for (Orch *o : cfgOrchList)
+        {
+            s.addSelectables(o->getSelectables());
+        }
+
+        SWSS_LOG_NOTICE("starting main loop");
+        while (true)
+        {
+            Selectable *sel;
+            int ret;
+
+            ret = s.select(&sel, SELECT_TIMEOUT);
+            if (ret == Select::ERROR)
+            {
+                SWSS_LOG_NOTICE("Error: %s!", strerror(errno));
+                continue;
+            }
+            if (ret == Select::TIMEOUT)
+            {
+                macsecmgr.doTask();
+                continue;
+            }
+
+            auto *c = (Executor *)sel;
+            c->execute();
+        }
+    }
+    catch(const std::exception &e)
+    {
+        SWSS_LOG_ERROR("Runtime error: %s", e.what());
+    }
+    return -1;
+}