1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
// $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"
ACE_RCSID(servers, main, "$Id$")
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;
}
|
