Skip to content
Snippets Groups Projects
Commit 97ee88b2 authored by Jan David Mol's avatar Jan David Mol
Browse files

Task #3726: Merged into trunk

parents 75152721 cf36b6e3
Branches
Tags
No related merge requests found
Showing
with 324 additions and 233 deletions
...@@ -36,6 +36,7 @@ using namespace LOFAR::CEPCU; ...@@ -36,6 +36,7 @@ using namespace LOFAR::CEPCU;
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
try {
// args: cntlrname, parentHost, parentService // args: cntlrname, parentHost, parentService
GCFScheduler::instance()->init(argc, argv, "CEPHardwareMonitor"); GCFScheduler::instance()->init(argc, argv, "CEPHardwareMonitor");
...@@ -79,6 +80,10 @@ int main(int argc, char* argv[]) ...@@ -79,6 +80,10 @@ int main(int argc, char* argv[])
} }
double postRunTime = globalParameterSet()->getDouble("closingDelay", 1.5); double postRunTime = globalParameterSet()->getDouble("closingDelay", 1.5);
GCFScheduler::instance()->run(postRunTime); // let processes die. GCFScheduler::instance()->run(postRunTime); // let processes die.
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return (0); return (0);
} }
...@@ -49,15 +49,11 @@ int main (int argc, char* argv[]) ...@@ -49,15 +49,11 @@ int main (int argc, char* argv[])
loggerTask.start(); // make initial transition loggerTask.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
LOG_INFO_STR("Shutting down: " << argv[0]);
} }
catch (LOFAR::Exception& ex) { catch (LOFAR::Exception& ex) {
LOG_FATAL_STR("Caught exception: " << ex); LOG_FATAL_STR("Caught exception: " << ex);
LOG_FATAL ("Terminated by exception!");
return (1); return (1);
} }
LOG_INFO("Terminated normally");
return (0); return (0);
} }
...@@ -42,6 +42,7 @@ int main(int argc, char* argv[]) ...@@ -42,6 +42,7 @@ int main(int argc, char* argv[])
return(-1); return(-1);
} }
try {
GCFScheduler::instance()->init(argc, argv, argv[1]); GCFScheduler::instance()->init(argc, argv, argv[1]);
ParentControl* pc = ParentControl::instance(); ParentControl* pc = ParentControl::instance();
...@@ -51,6 +52,10 @@ int main(int argc, char* argv[]) ...@@ -51,6 +52,10 @@ int main(int argc, char* argv[])
olc.start(); // make initial transition olc.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return (0); return (0);
} }
......
...@@ -42,6 +42,7 @@ int main(int argc, char* argv[]) ...@@ -42,6 +42,7 @@ int main(int argc, char* argv[])
return(-1); return(-1);
} }
try {
GCFScheduler::instance()->init(argc, argv, "PythonControl"); GCFScheduler::instance()->init(argc, argv, "PythonControl");
ParentControl* pc = ParentControl::instance(); ParentControl* pc = ParentControl::instance();
...@@ -51,6 +52,10 @@ int main(int argc, char* argv[]) ...@@ -51,6 +52,10 @@ int main(int argc, char* argv[])
pyc.start(); // make initial transition pyc.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return (0); return (0);
} }
......
...@@ -38,6 +38,8 @@ int main(int argc, char* argv[]) ...@@ -38,6 +38,8 @@ int main(int argc, char* argv[])
printf("%s usage: %s <controller name>\n",argv[0],argv[0]); printf("%s usage: %s <controller name>\n",argv[0],argv[0]);
exit(-1); exit(-1);
} }
try {
GCFTask::init(argc, argv); GCFTask::init(argc, argv);
ParentControl* pc = ParentControl::instance(); ParentControl* pc = ParentControl::instance();
...@@ -47,6 +49,10 @@ int main(int argc, char* argv[]) ...@@ -47,6 +49,10 @@ int main(int argc, char* argv[])
ofc.start(); // make initial transition ofc.start(); // make initial transition
GCFTask::run(); GCFTask::run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
......
...@@ -35,6 +35,7 @@ int main(int argc, char* argv[]) ...@@ -35,6 +35,7 @@ int main(int argc, char* argv[])
{ {
// signal (SIGCHLD, SIG_IGN); // signal (SIGCHLD, SIG_IGN);
try {
GCFScheduler::instance()->init(argc, argv, "CTStartDaemon"); GCFScheduler::instance()->init(argc, argv, "CTStartDaemon");
LOG_INFO("MACProcessScope: LOFAR_PermSW_Daemons_CTStartDaemon"); LOG_INFO("MACProcessScope: LOFAR_PermSW_Daemons_CTStartDaemon");
...@@ -44,6 +45,10 @@ int main(int argc, char* argv[]) ...@@ -44,6 +45,10 @@ int main(int argc, char* argv[])
sd.start(); // make initial transition sd.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
......
...@@ -36,6 +36,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -36,6 +36,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char *argv[]) int main(int argc, char *argv[])
{ {
try {
GCFScheduler::instance()->init(argc, argv, "ServiceBroker"); GCFScheduler::instance()->init(argc, argv, "ServiceBroker");
LOG_INFO("MACProcessScope: LOFAR_PermSW_Daemons_ServiceBroker"); LOG_INFO("MACProcessScope: LOFAR_PermSW_Daemons_ServiceBroker");
...@@ -45,6 +46,10 @@ int main(int argc, char *argv[]) ...@@ -45,6 +46,10 @@ int main(int argc, char *argv[])
sb.start(); // make initial transition sb.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
...@@ -35,6 +35,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -35,6 +35,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char *argv[]) int main(int argc, char *argv[])
{ {
try {
GCFScheduler::instance()->init(argc, argv, "KeyValueLogger"); GCFScheduler::instance()->init(argc, argv, "KeyValueLogger");
LOG_INFO("MACProcessScope: LOFAR_PermSW_Daemons_KVLogger"); LOG_INFO("MACProcessScope: LOFAR_PermSW_Daemons_KVLogger");
...@@ -42,6 +43,10 @@ int main(int argc, char *argv[]) ...@@ -42,6 +43,10 @@ int main(int argc, char *argv[])
kvl.start(); // make initial transition kvl.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return (0); return (0);
} }
...@@ -35,6 +35,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -35,6 +35,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char *argv[]) int main(int argc, char *argv[])
{ {
try {
GCFScheduler::instance()->init(argc, argv, "LogProcessor"); GCFScheduler::instance()->init(argc, argv, "LogProcessor");
// LOG_INFO("MACProcessScope: LOFAR_PermSW_Daemons_LogProcessor"); // LOG_INFO("MACProcessScope: LOFAR_PermSW_Daemons_LogProcessor");
...@@ -42,6 +43,10 @@ int main(int argc, char *argv[]) ...@@ -42,6 +43,10 @@ int main(int argc, char *argv[])
clp.start(); // make initial transition clp.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return (0); return (0);
} }
...@@ -35,6 +35,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -35,6 +35,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char *argv[]) int main(int argc, char *argv[])
{ {
try {
GCFScheduler::instance()->init(argc, argv, "SASGateway"); GCFScheduler::instance()->init(argc, argv, "SASGateway");
LOG_INFO("MACProcessScope: LOFAR_PermSW_Daemons_SASGateway"); LOG_INFO("MACProcessScope: LOFAR_PermSW_Daemons_SASGateway");
...@@ -42,6 +43,10 @@ int main(int argc, char *argv[]) ...@@ -42,6 +43,10 @@ int main(int argc, char *argv[])
SGW.start(); // make initial transition SGW.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return (0); return (0);
} }
...@@ -40,6 +40,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -40,6 +40,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
try {
// args: cntlrname, parentHost, parentService // args: cntlrname, parentHost, parentService
GCFScheduler::instance()->init(argc, argv, "SoftwareMonitor"); GCFScheduler::instance()->init(argc, argv, "SoftwareMonitor");
...@@ -62,6 +63,10 @@ int main(int argc, char* argv[]) ...@@ -62,6 +63,10 @@ int main(int argc, char* argv[])
double postRunTime = globalParameterSet()->getDouble("closingDelay", 1.5); double postRunTime = globalParameterSet()->getDouble("closingDelay", 1.5);
GCFScheduler::instance()->run(postRunTime); // let processes die. GCFScheduler::instance()->run(postRunTime); // let processes die.
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return (0); return (0);
} }
......
...@@ -35,7 +35,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -35,7 +35,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
try {
// args: cntlrname // args: cntlrname
GCFScheduler::instance()->init(argc, argv, argv[0]); GCFScheduler::instance()->init(argc, argv, argv[0]);
...@@ -43,6 +43,10 @@ int main(int argc, char* argv[]) ...@@ -43,6 +43,10 @@ int main(int argc, char* argv[])
tc.start(); // make initial transition tc.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
......
...@@ -36,6 +36,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -36,6 +36,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
try {
GCFScheduler::instance()->init(argc, argv, "MACScheduler"); GCFScheduler::instance()->init(argc, argv, "MACScheduler");
ChildControl* cc = ChildControl::instance(); ChildControl* cc = ChildControl::instance();
...@@ -45,6 +46,10 @@ int main(int argc, char* argv[]) ...@@ -45,6 +46,10 @@ int main(int argc, char* argv[])
ms.start(); // make initial transition ms.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
......
...@@ -36,6 +36,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -36,6 +36,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
try {
// args: cntlrname, parentHost, parentService // args: cntlrname, parentHost, parentService
GCFScheduler::instance()->init(argc, argv, argv[1]); GCFScheduler::instance()->init(argc, argv, argv[1]);
...@@ -49,6 +50,10 @@ int main(int argc, char* argv[]) ...@@ -49,6 +50,10 @@ int main(int argc, char* argv[])
oc.start(); // make initial transition oc.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
......
...@@ -34,6 +34,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -34,6 +34,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
try {
// args: cntlrname, parentHost, parentService // args: cntlrname, parentHost, parentService
GCFScheduler::instance()->init(argc, argv, argv[1]); GCFScheduler::instance()->init(argc, argv, argv[1]);
...@@ -44,6 +45,10 @@ int main(int argc, char* argv[]) ...@@ -44,6 +45,10 @@ int main(int argc, char* argv[])
bc.start(); // make initial transition bc.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
......
...@@ -34,6 +34,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -34,6 +34,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
try {
// args: cntlrname, parentHost, parentService // args: cntlrname, parentHost, parentService
GCFScheduler::instance()->init(argc, argv, argv[1]); GCFScheduler::instance()->init(argc, argv, argv[1]);
...@@ -44,6 +45,10 @@ int main(int argc, char* argv[]) ...@@ -44,6 +45,10 @@ int main(int argc, char* argv[])
cc.start(); // make initial transition cc.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
......
...@@ -39,6 +39,7 @@ int main(int argc, char* argv[]) ...@@ -39,6 +39,7 @@ int main(int argc, char* argv[])
return (1); return (1);
} }
try {
// args: cntlrname, parentHost, parentService // args: cntlrname, parentHost, parentService
GCFScheduler::instance()->init(argc, argv, "ClockControl"); GCFScheduler::instance()->init(argc, argv, "ClockControl");
...@@ -49,6 +50,10 @@ int main(int argc, char* argv[]) ...@@ -49,6 +50,10 @@ int main(int argc, char* argv[])
cc.start(); // make initial transition cc.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
......
...@@ -42,6 +42,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -42,6 +42,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
try {
// args: cntlrname, parentHost, parentService // args: cntlrname, parentHost, parentService
GCFScheduler::instance()->init(argc, argv, "HardwareMonitor"); GCFScheduler::instance()->init(argc, argv, "HardwareMonitor");
...@@ -101,6 +102,10 @@ int main(int argc, char* argv[]) ...@@ -101,6 +102,10 @@ int main(int argc, char* argv[])
} }
double postRunTime = globalParameterSet()->getDouble("closingDelay", 1.5); double postRunTime = globalParameterSet()->getDouble("closingDelay", 1.5);
GCFScheduler::instance()->run(postRunTime); // let processes die. GCFScheduler::instance()->run(postRunTime); // let processes die.
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return (0); return (0);
} }
......
...@@ -37,6 +37,7 @@ int main(int argc, char* argv[]) ...@@ -37,6 +37,7 @@ int main(int argc, char* argv[])
{ {
using LOFAR::basename; using LOFAR::basename;
try {
// args: cntlrname, parentHost, parentService // args: cntlrname, parentHost, parentService
GCFScheduler::instance()->init(argc, argv, basename(argv[0])); GCFScheduler::instance()->init(argc, argv, basename(argv[0]));
...@@ -57,6 +58,10 @@ int main(int argc, char* argv[]) ...@@ -57,6 +58,10 @@ int main(int argc, char* argv[])
sc.start(); // make initial transition sc.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
......
...@@ -34,6 +34,7 @@ Exception::TerminateHandler t(Exception::terminate); ...@@ -34,6 +34,7 @@ Exception::TerminateHandler t(Exception::terminate);
int main(int argc, char* argv[]) int main(int argc, char* argv[])
{ {
try {
// args: cntlrname, parentHost, parentService // args: cntlrname, parentHost, parentService
GCFScheduler::instance()->init(argc, argv, argv[0]); GCFScheduler::instance()->init(argc, argv, argv[0]);
GCFScheduler::instance()->disableQueue(); // run as fast as possible GCFScheduler::instance()->disableQueue(); // run as fast as possible
...@@ -45,6 +46,10 @@ int main(int argc, char* argv[]) ...@@ -45,6 +46,10 @@ int main(int argc, char* argv[])
tc.start(); // make initial transition tc.start(); // make initial transition
GCFScheduler::instance()->run(); GCFScheduler::instance()->run();
} catch( Exception &ex ) {
LOG_FATAL_STR("Caught exception: " << ex);
return 1;
}
return 0; return 0;
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment