git.stg.codes
/
stg.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Moved base and utility classes from global scope.
[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 0a65c0d9c72a06b9f35dbd958c000af4ed472644..06381144944a8d04abbcb53d2fab44a8cdadcb99 100644
(file)
--- a/
projects/stargazer/plugins/configuration/sgconfig/stgconfig.cpp
+++ b/
projects/stargazer/plugins/configuration/sgconfig/stgconfig.cpp
@@
-12,7
+12,7
@@
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
-PLUGIN_CREATOR<STG_CONFIG> stgc;
+
static
PLUGIN_CREATOR<STG_CONFIG> stgc;
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
@@
-20,7
+20,7
@@
int STG_CONFIG_SETTINGS::ParseSettings(const MODULE_SETTINGS & s)
{
int p;
PARAM_VALUE pv;
{
int p;
PARAM_VALUE pv;
-vector<PARAM_VALUE>::const_iterator pvi;
+
std::
vector<PARAM_VALUE>::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);
@@
-36,7
+36,7
@@
if (ParseIntInRange(pvi->value[0], 2, 65535, &p))
printfd(__FILE__, "%s\n", errorStr.c_str());
return -1;
}
printfd(__FILE__, "%s\n", errorStr.c_str());
return -1;
}
-port =
p
;
+port =
static_cast<uint16_t>(p)
;
return 0;
}
return 0;
}
@@
-50,7
+50,7
@@
return stgc.GetPlugin();
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
-
const
std::string STG_CONFIG::GetVersion() const
+std::string STG_CONFIG::GetVersion() const
{
return "Stg configurator v.0.08";
}
{
return "Stg configurator v.0.08";
}
@@
-61,7
+61,8
@@
STG_CONFIG::STG_CONFIG()
thread(),
nonstop(false),
isRunning(false),
thread(),
nonstop(false),
isRunning(false),
- config(),
+ logger(GetPluginLogger(GetStgLogger(), "conf_sg")),
+ config(logger),
users(NULL),
admins(NULL),
tariffs(NULL),
users(NULL),
admins(NULL),
tariffs(NULL),
@@
-103,6
+104,7
@@
if (pthread_create(&thread, NULL, Run, this))
{
errorStr = "Cannot create thread.";
printfd(__FILE__, "Cannot create thread\n");
{
errorStr = "Cannot create thread.";
printfd(__FILE__, "Cannot create thread\n");
+ logger("Cannot create thread.");
return -1;
}
errorStr = "";
return -1;
}
errorStr = "";
@@
-127,24
+129,18
@@
for (i = 0; i < 25; i++)
nanosleep(&ts, NULL);
}
nanosleep(&ts, NULL);
}
-//after 5 seconds waiting thread still running. now killing it
if (isRunning)
if (isRunning)
- {
- //TODO pthread_cancel()
- if (pthread_kill(thread, SIGINT))
- {
- errorStr = "Cannot kill thread.";
- printfd(__FILE__, "Cannot kill thread\n");
- return -1;
- }
- printfd(__FILE__, "STG_CONFIG killed\n");
- }
+ return -1;
return 0;
}
//-----------------------------------------------------------------------------
void * STG_CONFIG::Run(void * d)
{
return 0;
}
//-----------------------------------------------------------------------------
void * STG_CONFIG::Run(void * d)
{
+sigset_t signalSet;
+sigfillset(&signalSet);
+pthread_sigmask(SIG_BLOCK, &signalSet, NULL);
+
STG_CONFIG * stgConf = (STG_CONFIG *)d;
stgConf->isRunning = true;
STG_CONFIG * stgConf = (STG_CONFIG *)d;
stgConf->isRunning = true;