diff options
Diffstat (limited to 'ACE/netsvcs/servers/main.cpp')
| -rw-r--r-- | ACE/netsvcs/servers/main.cpp | 174 |
1 files changed, 174 insertions, 0 deletions
diff --git a/ACE/netsvcs/servers/main.cpp b/ACE/netsvcs/servers/main.cpp new file mode 100644 index 00000000000..5763af2a092 --- /dev/null +++ b/ACE/netsvcs/servers/main.cpp @@ -0,0 +1,174 @@ +// $Id$ + +#include "ace/Service_Config.h" +#include "ace/Logging_Strategy.h" +#include "ace/Sig_Adapter.h" +#include "TS_Clerk_Handler.h" +#include "TS_Server_Handler.h" +#include "Client_Logging_Handler.h" +#include "Name_Handler.h" +#include "Token_Handler.h" +#include "Server_Logging_Handler.h" + +int +ACE_TMAIN (int argc, ACE_TCHAR *argv[]) +{ + + // Try to link in the svc.conf entries dynamically, enabling the + // "ignore_debug_flag" as the last parameter so that we can override + // the default ACE_Log_Priority settings in the svc.conf file. + // + // Warning - do not try to move the ACE_Reactor signal handling work + // up to before this call - if the user specified -b (be a daemon), + // all handles will be closed, including the Reactor's pipe. + + if (ACE_Service_Config::open (argc, argv, ACE_DEFAULT_LOGGER_KEY, 1, 0, 1) == -1) + { + if (errno != ENOENT) + ACE_ERROR_RETURN ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("open")), + 1); + else // Use static linking. + { + if (ACE::debug () == 0) + ACE_LOG_MSG->priority_mask (~LM_DEBUG, + ACE_Log_Msg::PROCESS); + + // Calling ACE_SVC_INVOKE to create a new Service_Object. + // Stash the newly created Service_Object into an + // ACE_Service_Object_Ptr which is an <auto_ptr> specialized + // for ACE_Service_Object. + + ACE_TCHAR *l_argv[3]; + ACE_TCHAR name_port[] = + ACE_TEXT ("-p ") ACE_TEXT (ACE_DEFAULT_NAME_SERVER_PORT_STR); + + l_argv[0] = name_port; + l_argv[1] = 0; + ACE_Service_Object_Ptr sp_1 = ACE_SVC_INVOKE (ACE_Name_Acceptor); + + if (sp_1->init (1, l_argv) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("Name Service")), + 1); + + ACE_TCHAR time_port[] = + ACE_TEXT ("-p ") ACE_TEXT (ACE_DEFAULT_TIME_SERVER_PORT_STR); + l_argv[0] = time_port; + l_argv[1] = 0; + ACE_Service_Object_Ptr sp_2 = ACE_SVC_INVOKE (ACE_TS_Server_Acceptor); + + if (sp_2->init (1, l_argv) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("TS Server Acceptor")), + 1); + + ACE_TCHAR clerk_port[] = ACE_TEXT ("-p 10011"); + l_argv[0] = argv[0]; + l_argv[1] = clerk_port; + l_argv[2] = 0; + ACE_Service_Object_Ptr sp_3 = ACE_SVC_INVOKE (ACE_TS_Clerk_Processor); + + if (sp_3->init (2, l_argv) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("TS Clerk Processor")), + 1); + +#if defined (ACE_HAS_TOKENS_LIBRARY) + ACE_TCHAR token_port[] = + ACE_TEXT ("-p ") ACE_TEXT (ACE_DEFAULT_TOKEN_SERVER_PORT_STR); + l_argv[0] = token_port; + l_argv[1] = 0; + ACE_Service_Object_Ptr sp_4 = ACE_SVC_INVOKE (ACE_Token_Acceptor); + + if (sp_4->init (1, l_argv) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("Token Service")), + 1); +#endif /* ACE_HAS_TOKENS_LIBRARY */ + + ACE_TCHAR thr_logging_port[] = + ACE_TEXT ("-p ") ACE_TEXT (ACE_DEFAULT_THR_LOGGING_SERVER_PORT_STR); + l_argv[0] = thr_logging_port; + l_argv[1] = 0; + ACE_Service_Object_Ptr sp_5 = + ACE_SVC_INVOKE (ACE_Thr_Server_Logging_Acceptor); + + if (sp_5->init (1, l_argv) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("Threaded Logging Server")), + 1); + + ACE_TCHAR logging_port[] = + ACE_TEXT ("-p ") ACE_TEXT (ACE_DEFAULT_LOGGING_SERVER_PORT_STR); + l_argv[0] = logging_port; + l_argv[1] = 0; + ACE_Service_Object_Ptr sp_6 = + ACE_SVC_INVOKE (ACE_Server_Logging_Acceptor); + + if (sp_6->init (1, l_argv) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("Logging Server")), + 1); + + l_argv[0] = logging_port; + l_argv[1] = 0; + ACE_Service_Object_Ptr sp_7 = + ACE_SVC_INVOKE (ACE_Client_Logging_Acceptor); + + if (sp_7->init (1, l_argv) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("Logging Client")), + 1); + + // Run forever, performing the configured services until we + // are shut down by a SIGINT/SIGQUIT signal. + // Create an adapter to end the event loop. + ACE_Sig_Adapter sa ((ACE_Sig_Handler_Ex) ACE_Reactor::end_event_loop); + + ACE_Sig_Set sig_set; + sig_set.sig_add (SIGINT); + sig_set.sig_add (SIGQUIT); + if (ACE_Reactor::instance ()->register_handler (sig_set, + &sa) == -1) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("register signals"))); + else + ACE_Reactor::instance ()->run_reactor_event_loop (); + + // Destructors of ACE_Service_Object_Ptr's automagically + // call fini(). + } + } + else // Use dynamic linking. + { + // Run forever, performing the configured services until we are + // shut down by a SIGINT/SIGQUIT signal. + // Create an adapter to end the event loop. + ACE_Sig_Adapter sa ((ACE_Sig_Handler_Ex) ACE_Reactor::end_event_loop); + + ACE_Sig_Set sig_set; + sig_set.sig_add (SIGINT); + sig_set.sig_add (SIGQUIT); + + // Register ourselves to receive signals so we can shut down + // gracefully. + if (ACE_Reactor::instance ()->register_handler (sig_set, &sa) == -1) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("%p\n"), + ACE_TEXT ("register signals2"))); + else + ACE_Reactor::instance ()->run_reactor_event_loop (); + } + + return 0; +} |