Add instrumentation.

[stg.git] / projects / stargazer / plugins / configuration / sgconfig / stgconfig.cpp

diff --git a/projects/stargazer/plugins/configuration/sgconfig/stgconfig.cpp b/projects/stargazer/plugins/configuration/sgconfig/stgconfig.cpp
index ca2dd4405e8594bbcff11abe20eb53143cc14524..0896bb85f434cacb392166e4e55c12db19099ae8 100644 (file)
--- a/projects/stargazer/plugins/configuration/sgconfig/stgconfig.cpp
+++ b/projects/stargazer/plugins/configuration/sgconfig/stgconfig.cpp
@@ -20,7 +20,6 @@
 
 #include "stgconfig.h"
 
 
 #include "stgconfig.h"
 

-#include "stg/plugin_creator.h"

 #include "stg/common.h"
 
 #include <algorithm>
 #include "stg/common.h"
 
 #include <algorithm>


@@ -31,18 +30,14 @@
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------

-static PLUGIN_CREATOR<STG_CONFIG> stgc;
-//-----------------------------------------------------------------------------
-//-----------------------------------------------------------------------------
-//-----------------------------------------------------------------------------
-bool STG_CONFIG_SETTINGS::ParseSettings(const MODULE_SETTINGS & s)
+bool STG_CONFIG_SETTINGS::ParseSettings(const STG::ModuleSettings & s)

 {
 {

-    PARAM_VALUE pv;
-    std::vector<PARAM_VALUE>::const_iterator pvi;
+    STG::ParamValue pv;
+    std::vector<STG::ParamValue>::const_iterator pvi;

     ///////////////////////////
     pv.param = "Port";
     pvi = std::find(s.moduleParams.begin(), s.moduleParams.end(), pv);
     ///////////////////////////
     pv.param = "Port";
     pvi = std::find(s.moduleParams.begin(), s.moduleParams.end(), pv);

-    if (pvi == s.moduleParams.end())
+    if (pvi == s.moduleParams.end() || pvi->value.empty())

         {
         errorStr = "Parameter \'Port\' is not found.";
         printfd(__FILE__, "%s\n", errorStr.c_str());
         {
         errorStr = "Parameter \'Port\' is not found.";
         printfd(__FILE__, "%s\n", errorStr.c_str());


@@ -59,7 +54,7 @@ bool STG_CONFIG_SETTINGS::ParseSettings(const MODULE_SETTINGS & s)
 
     pv.param = "BindAddress";
     pvi = std::find(s.moduleParams.begin(), s.moduleParams.end(), pv);
 
     pv.param = "BindAddress";
     pvi = std::find(s.moduleParams.begin(), s.moduleParams.end(), pv);

-    if (pvi != s.moduleParams.end())
+    if (pvi != s.moduleParams.end() && !pvi->value.empty())

         m_bindAddress = pvi->value[0];
 
     return true;
         m_bindAddress = pvi->value[0];
 
     return true;


@@ -67,9 +62,10 @@ bool STG_CONFIG_SETTINGS::ParseSettings(const MODULE_SETTINGS & s)
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------

-extern "C" PLUGIN * GetPlugin()
+extern "C" STG::Plugin * GetPlugin()

 {
 {

-return stgc.GetPlugin();
+    static STG_CONFIG plugin;
+    return &plugin;

 }
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------
 }
 //-----------------------------------------------------------------------------
 //-----------------------------------------------------------------------------


@@ -77,7 +73,7 @@ return stgc.GetPlugin();
 STG_CONFIG::STG_CONFIG()
     : nonstop(false),
       isRunning(false),
 STG_CONFIG::STG_CONFIG()
     : nonstop(false),
       isRunning(false),

-      logger(GetPluginLogger(GetStgLogger(), "conf_sg")),
+      logger(STG::PluginLogger::get("conf_sg")),

       config(logger)
 {
 }
       config(logger)
 {
 }


@@ -106,13 +102,7 @@ int STG_CONFIG::Start()
         return -1;
     }
 
         return -1;
     }
 

-    if (pthread_create(&thread, NULL, Run, this))
-    {
-        errorStr = std::string("Cannot create thread: '") + strerror(errno) + "'.";
-        printfd(__FILE__, "%s\n", errorStr.c_str());
-        logger(errorStr);
-        return -1;
-    }
+    m_thread = std::jthread([this](auto token){ Run(token); });

 
     return 0;
 }
 
     return 0;
 }


@@ -123,6 +113,7 @@ int STG_CONFIG::Stop()
         return 0;
 
     config.Stop();
         return 0;
 
     config.Stop();

+    m_thread.request_stop();

 
     //5 seconds to thread stops itself
     for (size_t i = 0; i < 25; ++i)
 
     //5 seconds to thread stops itself
     for (size_t i = 0; i < 25; ++i)


@@ -135,23 +126,22 @@ int STG_CONFIG::Stop()
     }
 
     if (isRunning)
     }
 
     if (isRunning)

-        return -1;
+        m_thread.detach();
+    else
+        m_thread.join();

 
     return 0;
 }
 //-----------------------------------------------------------------------------
 
     return 0;
 }
 //-----------------------------------------------------------------------------

-void * STG_CONFIG::Run(void * d)
+void STG_CONFIG::Run(std::stop_token token)

 {
     sigset_t signalSet;
     sigfillset(&signalSet);
     pthread_sigmask(SIG_BLOCK, &signalSet, NULL);
 
 {
     sigset_t signalSet;
     sigfillset(&signalSet);
     pthread_sigmask(SIG_BLOCK, &signalSet, NULL);
 

-    STG_CONFIG & stgConf = *static_cast<STG_CONFIG *>(d);
-    stgConf.isRunning = true;
-
-    stgConf.config.Run();
+    isRunning = true;

 
 

-    stgConf.isRunning = false;
+    config.Run(token);

 
 

-    return NULL;
+    isRunning = false;

 }
 }