Application class

1 files changed, 182 insertions, 0 deletions

diff --git a/cpp/src/Ice/Application.cpp b/cpp/src/Ice/Application.cpp
new file mode 100644
index 00000000000..fdb7ec3d3b6
--- /dev/null
+++ b/cpp/src/Ice/Application.cpp
@@ -0,0 +1,182 @@
+// **********************************************************************
+//
+// Copyright (c) 2001
+// MutableRealms, Inc.
+// Huntsville, AL, USA
+//
+// All Rights Reserved
+//
+// **********************************************************************
+
+#include <Ice/Application.h>
+#ifndef WIN32
+#   include <signal.h>
+#endif
+
+using namespace std;
+using namespace Ice;
+
+const char* Application::_appName;
+CommunicatorPtr Application::_communicator;
+
+Ice::Application::Application()
+{
+}
+
+Ice::Application::~Application()
+{
+}
+
+int
+Ice::Application::main(int argc, char* argv[], const char* configFile)
+{
+    if (_communicator && _appName)
+    {
+	cerr << argv[0] << ": only one instance of the Application class can be used" << endl;
+	return EXIT_FAILURE;
+    }
+
+    _appName = argv[0];
+
+    int status;
+
+    try
+    {
+	if (configFile)
+	{
+	    PropertiesPtr properties = createPropertiesFromFile(argc, argv, configFile);
+	    _communicator = initializeWithProperties(properties);
+	}
+	else
+	{
+	    _communicator = initialize(argc, argv);
+	}
+	status = run(argc, argv);
+    }
+    catch(const LocalException& ex)
+    {
+	cerr << _appName << ": local exception: " << ex << endl;
+	status = EXIT_FAILURE;
+    }
+    catch(...)
+    {
+	cerr << _appName << ": unknown exception" << endl;
+	status = EXIT_FAILURE;
+    }
+
+    if (_communicator)
+    {
+	try
+	{
+	    _communicator->destroy();
+	}
+	catch(const LocalException& ex)
+	{
+	    cerr << _appName << ": local exception: " << ex << endl;
+	    status = EXIT_FAILURE;
+	}
+	catch(...)
+	{
+	    cerr << _appName << ": unknown exception" << endl;
+	    status = EXIT_FAILURE;
+	}
+	_communicator = 0;
+    }
+
+    _appName = 0;
+
+    return status;
+}
+
+const char*
+Ice::Application::appName()
+{
+    return _appName;
+}
+
+CommunicatorPtr
+Ice::Application::communicator()
+{
+    return _communicator;
+}
+
+#ifdef WIN32
+
+static BOOL WINAPI
+interruptHandler(DWORD)
+{
+    assert(Application::communicator());
+    Application::communicator()->shutdown();
+    return TRUE;
+}
+
+void
+Ice::Application::shutdownOnInterrupt()
+{
+    SetConsoleCtrlHandler(NULL, FALSE);
+    SetConsoleCtrlHandler(interruptHandler, TRUE);
+}
+
+void
+Ice::Application::ignoreInterrupt()
+{
+    SetConsoleCtrlHandler(interruptHandler, FALSE);
+    SetConsoleCtrlHandler(NULL, TRUE);
+}
+
+void
+Ice::Application::defaultInterrupt()
+{
+    SetConsoleCtrlHandler(interruptHandler, FALSE);
+    SetConsoleCtrlHandler(NULL, FALSE);
+}
+
+#else
+
+static void
+interruptHandler(int)
+{
+    assert(Application::communicator());
+    Application::communicator()->shutdown();
+}
+
+void
+Ice::Application::shutdownOnInterrupt()
+{
+    struct sigaction action;
+    action.sa_handler = interruptHandler;
+    sigemptyset(&action.sa_mask);
+    sigaddset(&action.sa_mask, SIGHUP);
+    sigaddset(&action.sa_mask, SIGINT);
+    sigaddset(&action.sa_mask, SIGTERM);
+    action.sa_flags = 0;
+    sigaction(SIGHUP, &action, 0);
+    sigaction(SIGINT, &action, 0);
+    sigaction(SIGTERM, &action, 0);
+}
+
+void
+Ice::Application::ignoreInterrupt()
+{
+    struct sigaction action;
+    action.sa_handler = SIG_IGN;
+    sigemptyset(&action.sa_mask);
+    action.sa_flags = 0;
+    sigaction(SIGHUP, &action, 0);
+    sigaction(SIGINT, &action, 0);
+    sigaction(SIGTERM, &action, 0);
+}
+
+void
+Ice::Application::defaultInterrupt()
+{
+    struct sigaction action;
+    action.sa_handler = SIG_DFL;
+    sigemptyset(&action.sa_mask);
+    action.sa_flags = 0;
+    sigaction(SIGHUP, &action, 0);
+    sigaction(SIGINT, &action, 0);
+    sigaction(SIGTERM, &action, 0);
+}
+
+#endif