|
@@ -46,6 +46,7 @@
|
|
static volatile bool g_fRun = false;
|
|
static volatile bool g_fRun = false;
|
|
static volatile bool g_fPause = false;
|
|
static volatile bool g_fPause = false;
|
|
static volatile bool g_fZombie = false;
|
|
static volatile bool g_fZombie = false;
|
|
|
|
+static sigset_t g_set;
|
|
|
|
|
|
/////////////////////////////////////////////////////////////////////////////
|
|
/////////////////////////////////////////////////////////////////////////////
|
|
|
|
|
|
@@ -690,6 +691,16 @@ static void _EnumStorageDevices(GFA_SYSINFO_STORAGE_DEVICE_MAP &sdm, MountMap &m
|
|
|
|
|
|
/////////////////////////////////////////////////////////////////////////////
|
|
/////////////////////////////////////////////////////////////////////////////
|
|
|
|
|
|
|
|
+static void _LockSHM(HSHM hShm)
|
|
|
|
+{
|
|
|
|
+ ::GfaIpcLockSHMAndSigBlock(hShm, &g_set);
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+static void _UnlockSHM(HSHM hShm)
|
|
|
|
+{
|
|
|
|
+ ::GfaIpcUnlockSHMAndSigUnblock(hShm, &g_set);
|
|
|
|
+}
|
|
|
|
+
|
|
static void _SigHandler(int sig)
|
|
static void _SigHandler(int sig)
|
|
{
|
|
{
|
|
UNUSED(sig);
|
|
UNUSED(sig);
|
|
@@ -736,6 +747,8 @@ int main(int argc, char *argv[])
|
|
|
|
|
|
struct sigaction sa;
|
|
struct sigaction sa;
|
|
memset(&sa, 0, sizeof(sa));
|
|
memset(&sa, 0, sizeof(sa));
|
|
|
|
+ ::sigfillset(&g_set);
|
|
|
|
+ ::sigdelset(&g_set, SIGSEGV);
|
|
|
|
|
|
sa.sa_handler = _SigHandler;
|
|
sa.sa_handler = _SigHandler;
|
|
sigaction(SIGHUP, &sa, NULL); // handles user's terminal disconnect
|
|
sigaction(SIGHUP, &sa, NULL); // handles user's terminal disconnect
|
|
@@ -752,6 +765,10 @@ int main(int argc, char *argv[])
|
|
|
|
|
|
/////////////////////////////////////////////////////////////////////////
|
|
/////////////////////////////////////////////////////////////////////////
|
|
// initialize
|
|
// initialize
|
|
|
|
+
|
|
|
|
+ CMySqlInfo::EXEC_PARAMS myep;
|
|
|
|
+ CStgDevInfo::EXEC_PARAMS step;
|
|
|
|
+ CSpiInfo::EXEC_PARAMS spep;
|
|
|
|
|
|
do
|
|
do
|
|
{
|
|
{
|
|
@@ -763,6 +780,7 @@ int main(int argc, char *argv[])
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ ::GfaIpcAppCtrlSetLockUnlockFunctions(hAC, _LockSHM, _UnlockSHM);
|
|
::GfaIpcAppCtrlSetState(hAC, GIAS_Initializing);
|
|
::GfaIpcAppCtrlSetState(hAC, GIAS_Initializing);
|
|
|
|
|
|
if(!::GfaIpcAppCtrlCreateSysInfo(hAC))
|
|
if(!::GfaIpcAppCtrlCreateSysInfo(hAC))
|
|
@@ -778,13 +796,13 @@ int main(int argc, char *argv[])
|
|
TRACE("My PID: %d\n", getpid());
|
|
TRACE("My PID: %d\n", getpid());
|
|
TRACE("My Cycle: %d\n", _CYCLE_INTV);
|
|
TRACE("My Cycle: %d\n", _CYCLE_INTV);
|
|
|
|
|
|
- CMySqlInfo::EXEC_PARAMS myep = {hAC, sDbUser, sDbPass};
|
|
|
|
|
|
+ myep = {hAC, sDbUser, sDbPass};
|
|
mySqlInfo.Create(&myep);
|
|
mySqlInfo.Create(&myep);
|
|
|
|
|
|
- CStgDevInfo::EXEC_PARAMS step = {hAC};
|
|
|
|
|
|
+ step = {hAC};
|
|
stgDevInfo.Create(&step);
|
|
stgDevInfo.Create(&step);
|
|
|
|
|
|
- CSpiInfo::EXEC_PARAMS spep = {hAC};
|
|
|
|
|
|
+ spep = {hAC};
|
|
spiInfo.Create(&spep);
|
|
spiInfo.Create(&spep);
|
|
|
|
|
|
g_fZombie = false;
|
|
g_fZombie = false;
|