server stats publish

Author: sy-c

CMakeLists.txt

@@ -254,6 +254,7 @@ add_executable(
   src/infoLoggerServer.cxx
   src/InfoLoggerDispatch.cxx
   src/InfoLoggerDispatchBrowser.cxx
+  src/InfoLoggerDispatchStats.cxx
   src/ConfigInfoLoggerServer.cxx  
   src/infoLoggerMessageDecode.c
   src/InfoLoggerMessageHelper.cxx

src/ConfigInfoLoggerServer.cxx

@@ -38,5 +38,13 @@ void ConfigInfoLoggerServer::readFromConfigFile(ConfigFile& config)
 
   config.getOptionalValue<int>(INFOLOGGER_CONFIG_SECTION_NAME_SERVER ".serverPortTx", serverPortTx);
   config.getOptionalValue<int>(INFOLOGGER_CONFIG_SECTION_NAME_SERVER ".maxClientsTx", maxClientsTx);
+  
+  config.getOptionalValue<int>(INFOLOGGER_CONFIG_SECTION_NAME_SERVER ".statsEnabled", statsEnabled);
+  config.getOptionalValue<int>(INFOLOGGER_CONFIG_SECTION_NAME_SERVER ".statsPort", statsPort);
+  config.getOptionalValue<int>(INFOLOGGER_CONFIG_SECTION_NAME_SERVER ".statsMaxClients", statsMaxClients);
+  config.getOptionalValue<int>(INFOLOGGER_CONFIG_SECTION_NAME_SERVER ".statsPublishInterval", statsPublishInterval);
+  config.getOptionalValue<int>(INFOLOGGER_CONFIG_SECTION_NAME_SERVER ".statsResetInterval", statsResetInterval);
+  config.getOptionalValue<int>(INFOLOGGER_CONFIG_SECTION_NAME_SERVER ".statsHistory", statsHistory);
+  
 }
 

src/ConfigInfoLoggerServer.h

@@ -50,6 +50,14 @@ class ConfigInfoLoggerServer
   // settings for infoBrowser clients
   int serverPortTx = INFOLOGGER_DEFAULT_SERVER_TX_PORT;
   int maxClientsTx = 100;
+
+  // settings for infoLoggerStats clients
+  int statsEnabled = 1; // flag to enable/disable feature
+  int statsPort = INFOLOGGER_DEFAULT_SERVER_STATS_PORT; // TCP/IP port number
+  int statsMaxClients = 5; // max number of clients connections allowed
+  int statsPublishInterval = 5 ; // publish interval time (seconds)
+  int statsResetInterval = 60; // size of the stats window (seconds)
+  int statsHistory = 600; // backlog of stats kept and published (seconds)
 };
 
 #endif // SRC_CONFIGINFOLOGGERSERVER_H_

src/InfoLoggerDispatch.h

@@ -96,5 +96,18 @@ class InfoLoggerDispatchSQL : public InfoLoggerDispatch
   std::unique_ptr<InfoLoggerDispatchSQLImpl> dPtr;
 };
 
+// a class to dispatch stats about online messages
+class InfoLoggerDispatchStatsImpl;
+class InfoLoggerDispatchStats : public InfoLoggerDispatch
+{
+ public:
+  InfoLoggerDispatchStats(ConfigInfoLoggerServer* theConfig, SimpleLog* theLog);
+  ~InfoLoggerDispatchStats();
+  int customMessageProcess(std::shared_ptr<InfoLoggerMessageList> msg);
+  int customLoop();
+
+ private:
+  std::unique_ptr<InfoLoggerDispatchStatsImpl> dPtr;
+};
 #endif
 

src/infoLoggerDefaults.h

@@ -29,6 +29,9 @@
 // default infoLoggerServer listening port for infoBrowser
 #define INFOLOGGER_DEFAULT_SERVER_TX_PORT 6102
 
+// default infoLoggerServer listening port for stats plublish
+#define INFOLOGGER_DEFAULT_SERVER_STATS_PORT 6103
+
 // default listening socket name for infoLoggerD
 #define INFOLOGGER_DEFAULT_LOCAL_SOCKET "infoLoggerD"
 

src/infoLoggerServer.cxx

@@ -132,6 +132,10 @@ InfoLoggerServer::InfoLoggerServer(int argc, char* argv[]) : Daemon(argc, argv)
       try {
         //dispatchEngines.push_back(std::make_unique<InfoLoggerDispatchPrint>(&log));
         dispatchEngines.push_back(std::make_unique<InfoLoggerDispatchOnlineBrowser>(&configInfoLoggerServer, &log));
+        
+	if (configInfoLoggerServer.statsEnabled) {
+	  dispatchEngines.push_back(std::make_unique<InfoLoggerDispatchStats>(&configInfoLoggerServer, &log));
+	}
 
         if (configInfoLoggerServer.dbEnabled) {
 #ifdef WITH_MYSQL