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
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
|
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html><head><meta http-equiv="Content-Type" content="text/html;charset=iso-8859-1">
<title>OmniEvents: main.cc Source File</title>
<link href="doxygen.css" rel="stylesheet" type="text/css">
</head><body>
<!-- Generated by Doxygen 1.4.3-20050530 -->
<div class="qindex"><a class="qindex" href="main.html">Main Page</a> | <a class="qindex" href="namespaces.html">Namespace List</a> | <a class="qindex" href="hierarchy.html">Class Hierarchy</a> | <a class="qindex" href="annotated.html">Class List</a> | <a class="qindex" href="dirs.html">Directories</a> | <a class="qindex" href="files.html">File List</a> | <a class="qindex" href="namespacemembers.html">Namespace Members</a> | <a class="qindex" href="functions.html">Class Members</a> | <a class="qindex" href="globals.html">File Members</a></div>
<div class="nav">
<a class="el" href="dir_000000.html">src</a></div>
<h1>main.cc</h1><a href="a00106.html">Go to the documentation of this file.</a><div class="fragment"><pre class="fragment"><a name="l00001"></a>00001 <span class="comment">// Package : omniEvents</span>
<a name="l00002"></a>00002 <span class="comment">// main.cc Created : 2004/08/01</span>
<a name="l00003"></a>00003 <span class="comment">// Author : Alex Tingle.</span>
<a name="l00004"></a>00004 <span class="comment">//</span>
<a name="l00005"></a>00005 <span class="comment">// Copyright (C) 1998 Paul Nader, 2004-2005 Alex Tingle.</span>
<a name="l00006"></a>00006 <span class="comment">//</span>
<a name="l00007"></a>00007 <span class="comment">// This file is part of the omniEvents application.</span>
<a name="l00008"></a>00008 <span class="comment">//</span>
<a name="l00009"></a>00009 <span class="comment">// omniEvents is free software; you can redistribute it and/or</span>
<a name="l00010"></a>00010 <span class="comment">// modify it under the terms of the GNU Lesser General Public</span>
<a name="l00011"></a>00011 <span class="comment">// License as published by the Free Software Foundation; either</span>
<a name="l00012"></a>00012 <span class="comment">// version 2.1 of the License, or (at your option) any later version.</span>
<a name="l00013"></a>00013 <span class="comment">//</span>
<a name="l00014"></a>00014 <span class="comment">// omniEvents is distributed in the hope that it will be useful,</span>
<a name="l00015"></a>00015 <span class="comment">// but WITHOUT ANY WARRANTY; without even the implied warranty of</span>
<a name="l00016"></a>00016 <span class="comment">// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU</span>
<a name="l00017"></a>00017 <span class="comment">// Lesser General Public License for more details.</span>
<a name="l00018"></a>00018 <span class="comment">//</span>
<a name="l00019"></a>00019 <span class="comment">// You should have received a copy of the GNU Lesser General Public</span>
<a name="l00020"></a>00020 <span class="comment">// License along with this library; if not, write to the Free Software</span>
<a name="l00021"></a>00021 <span class="comment">// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA</span>
<a name="l00022"></a>00022 <span class="comment">//</span>
<a name="l00023"></a>00023 <span class="comment">// Description:</span>
<a name="l00024"></a>00024 <span class="comment">// Event Services Channel Factory implementation. The factory registers</span>
<a name="l00025"></a>00025 <span class="comment">// itself with the naming service. Clients wishing to create event</span>
<a name="l00026"></a>00026 <span class="comment">// channels can either use the factory by resolving its name with the</span>
<a name="l00027"></a>00027 <span class="comment">// naming service or create in-process channels.</span>
<a name="l00028"></a>00028 <span class="comment">//</span>
<a name="l00029"></a>00029
<a name="l00030"></a>00030 <span class="preprocessor">#ifdef HAVE_CONFIG_H</span>
<a name="l00031"></a>00031 <span class="preprocessor"></span><span class="preprocessor"># include "<a class="code" href="a00083.html">config.h</a>"</span>
<a name="l00032"></a>00032 <span class="preprocessor">#endif</span>
<a name="l00033"></a>00033 <span class="preprocessor"></span>
<a name="l00034"></a>00034 <span class="preprocessor">#ifdef HAVE_GETOPT</span>
<a name="l00035"></a>00035 <span class="preprocessor"></span><span class="preprocessor"># include <unistd.h></span>
<a name="l00036"></a>00036 <span class="keyword">extern</span> <span class="keywordtype">char</span>* <a class="code" href="a00104.html#a3">optarg</a>;
<a name="l00037"></a>00037 <span class="keyword">extern</span> <span class="keywordtype">int</span> <a class="code" href="a00104.html#a2">optind</a>;
<a name="l00038"></a>00038 <span class="preprocessor">#else</span>
<a name="l00039"></a>00039 <span class="preprocessor"></span><span class="preprocessor"># include "<a class="code" href="a00105.html">getopt.h</a>"</span>
<a name="l00040"></a>00040 <span class="preprocessor">#endif</span>
<a name="l00041"></a>00041 <span class="preprocessor"></span>
<a name="l00042"></a>00042 <span class="preprocessor">#include "<a class="code" href="a00107.html">main.h</a>"</span>
<a name="l00043"></a>00043 <span class="preprocessor">#include "<a class="code" href="a00112.html">omniEvents.h</a>"</span>
<a name="l00044"></a>00044 <span class="preprocessor">#include "<a class="code" href="a00110.html">naming.h</a>"</span>
<a name="l00045"></a>00045 <span class="preprocessor">#include "<a class="code" href="a00114.html">omniEventsLog.h</a>"</span>
<a name="l00046"></a>00046 <span class="preprocessor">#include "<a class="code" href="a00096.html">EventChannelFactory.h</a>"</span>
<a name="l00047"></a>00047 <span class="preprocessor">#include "<a class="code" href="a00116.html">Orb.h</a>"</span>
<a name="l00048"></a>00048 <span class="preprocessor">#include "<a class="code" href="a00086.html">daemon.h</a>"</span>
<a name="l00049"></a>00049 <span class="preprocessor">#include "<a class="code" href="a00140.html">version.h</a>"</span>
<a name="l00050"></a>00050
<a name="l00051"></a>00051 <span class="preprocessor">#if defined(HAVE_SIGNAL_H) && defined(HAVE_SIGSET)</span>
<a name="l00052"></a>00052 <span class="preprocessor"></span><span class="preprocessor"># include <signal.h></span>
<a name="l00053"></a>00053 <span class="preprocessor"># define SIGSET(sig,func) ::sigset(sig,func)</span>
<a name="l00054"></a>00054 <span class="preprocessor"></span><span class="preprocessor">#elif defined(HAVE_SIGNAL_H)</span>
<a name="l00055"></a>00055 <span class="preprocessor"></span><span class="preprocessor"># include <signal.h></span>
<a name="l00056"></a>00056 <span class="preprocessor"># define SIGSET(sig,func) ::signal(sig,func)</span>
<a name="l00057"></a>00057 <span class="preprocessor"></span><span class="preprocessor">#endif</span>
<a name="l00058"></a>00058 <span class="preprocessor"></span>
<a name="l00059"></a>00059 <span class="preprocessor">#ifdef HAVE_OMNIORB4</span>
<a name="l00060"></a>00060 <span class="preprocessor"></span><span class="preprocessor"># include <omniORB4/internal/orbOptions.h></span>
<a name="l00061"></a>00061 <span class="preprocessor">#endif</span>
<a name="l00062"></a>00062 <span class="preprocessor"></span>
<a name="l00063"></a>00063 <span class="preprocessor">#include <stdio.h></span> <span class="comment">// for sprintf</span>
<a name="l00064"></a>00064
<a name="l00065"></a><a class="code" href="a00107.html#a0">00065</a> <span class="keywordtype">int</span> <a class="code" href="a00106.html#a0">main</a>(<span class="keywordtype">int</span> argc, <span class="keywordtype">char</span>** argv)
<a name="l00066"></a>00066 {
<a name="l00067"></a>00067 <a class="code" href="a00044.html">OmniEvents::Daemon</a> <a class="code" href="a00141.html#a0">daemon</a>(argc,argv);
<a name="l00068"></a>00068
<a name="l00069"></a>00069 <span class="preprocessor">#ifdef HAVE_OMNIORB4</span>
<a name="l00070"></a>00070 <span class="preprocessor"></span> <span class="keywordflow">try</span>
<a name="l00071"></a>00071 {
<a name="l00072"></a>00072 <span class="comment">// Duplicate argv & argc.</span>
<a name="l00073"></a>00073 <span class="keywordtype">int</span> originalArgc =argc;
<a name="l00074"></a>00074 <span class="keywordtype">char</span>** originalArgv =<span class="keyword">new</span> <span class="keywordtype">char</span>*[originalArgc];
<a name="l00075"></a>00075 <span class="keywordflow">for</span>(<span class="keywordtype">int</span> i=0; i<originalArgc; ++i)
<a name="l00076"></a>00076 originalArgv[i]=strdup(argv[i]);
<a name="l00077"></a>00077
<a name="l00078"></a>00078 <span class="comment">// Remove ORB arguments from argc & argv.</span>
<a name="l00079"></a>00079 <span class="keywordflow">try</span> {
<a name="l00080"></a>00080 omni::orbOptions::singleton().extractInitOptions(argc,argv);
<a name="l00081"></a>00081 }
<a name="l00082"></a>00082 <span class="keywordflow">catch</span>(...) {
<a name="l00083"></a>00083 argc=originalArgc;
<a name="l00084"></a>00084 argv=originalArgv;
<a name="l00085"></a>00085 }
<a name="l00086"></a>00086 <span class="preprocessor">#endif</span>
<a name="l00087"></a>00087 <span class="preprocessor"></span>
<a name="l00088"></a>00088 <span class="keyword">using</span> <span class="keyword">namespace </span>OmniEvents;
<a name="l00089"></a>00089
<a name="l00090"></a>00090 <span class="comment">//</span>
<a name="l00091"></a>00091 <span class="comment">// Process Options</span>
<a name="l00092"></a>00092 <span class="keyword">const</span> <span class="keywordtype">char</span>* endPointNoListen =NULL;
<a name="l00093"></a>00093 <span class="keywordtype">int</span> port =0;
<a name="l00094"></a>00094 <span class="keyword">const</span> <span class="keywordtype">char</span>* logDir =NULL;
<a name="l00095"></a>00095 <span class="keyword">const</span> <span class="keywordtype">char</span>* factoryName =<span class="stringliteral">"EventChannelFactory"</span>;
<a name="l00096"></a>00096 <span class="keywordtype">bool</span> verbose =<span class="keyword">false</span>;
<a name="l00097"></a>00097
<a name="l00098"></a>00098 <span class="keywordtype">int</span> c;
<a name="l00099"></a>00099 <span class="keywordflow">while</span> ((c = <a class="code" href="a00104.html#a5">getopt</a>(argc,argv,<span class="stringliteral">"O:a:p:l:P:N:dft:vVh"</span>)) != EOF)
<a name="l00100"></a>00100 {
<a name="l00101"></a>00101 <span class="keywordflow">switch</span> (c)
<a name="l00102"></a>00102 {
<a name="l00103"></a>00103 <span class="keywordflow">case</span> <span class="charliteral">'O'</span>: <span class="keywordflow">break</span>; <span class="comment">// Helps protect us from -ORB arguments.</span>
<a name="l00104"></a>00104
<a name="l00105"></a>00105 <span class="comment">// Initialisation options (only useful on first run)</span>
<a name="l00106"></a>00106 <span class="keywordflow">case</span> <span class="charliteral">'a'</span>: endPointNoListen=<a class="code" href="a00104.html#a3">optarg</a>;
<a name="l00107"></a>00107 <span class="keywordflow">break</span>;
<a name="l00108"></a>00108
<a name="l00109"></a>00109 <span class="keywordflow">case</span> <span class="charliteral">'p'</span>: port=atoi(<a class="code" href="a00104.html#a3">optarg</a>);
<a name="l00110"></a>00110 <span class="keywordflow">if</span> (port <= 0)
<a name="l00111"></a>00111 {
<a name="l00112"></a>00112 cerr<<<span class="stringliteral">"\nError: port must be a positive integer"</span><<endl;
<a name="l00113"></a>00113 <a class="code" href="a00141.html#a5">usage</a>(argc,argv);
<a name="l00114"></a>00114 }
<a name="l00115"></a>00115 <span class="keywordflow">break</span>;
<a name="l00116"></a>00116
<a name="l00117"></a>00117 <span class="comment">// Other options</span>
<a name="l00118"></a>00118 <span class="keywordflow">case</span> <span class="charliteral">'l'</span>: logDir=<a class="code" href="a00104.html#a3">optarg</a>;
<a name="l00119"></a>00119 <span class="keywordflow">break</span>;
<a name="l00120"></a>00120
<a name="l00121"></a>00121 <span class="keywordflow">case</span> <span class="charliteral">'P'</span>: daemon.<a class="code" href="a00044.html#a3">pidfile</a>(<a class="code" href="a00104.html#a3">optarg</a>);
<a name="l00122"></a>00122 <span class="keywordflow">break</span>;
<a name="l00123"></a>00123
<a name="l00124"></a>00124 <span class="keywordflow">case</span> <span class="charliteral">'N'</span>: factoryName=<a class="code" href="a00104.html#a3">optarg</a>;
<a name="l00125"></a>00125 <span class="keywordflow">break</span>;
<a name="l00126"></a>00126
<a name="l00127"></a>00127 <span class="keywordflow">case</span> <span class="charliteral">'d'</span>: cerr<<<span class="stringliteral">"Option '-d' is deprecated. Use '-f' instead."</span><<endl;
<a name="l00128"></a>00128 daemon.<a class="code" href="a00044.html#a4">foreground</a>(<span class="keyword">true</span>);
<a name="l00129"></a>00129 <span class="keywordflow">break</span>;
<a name="l00130"></a>00130
<a name="l00131"></a>00131 <span class="keywordflow">case</span> <span class="charliteral">'f'</span>: daemon.<a class="code" href="a00044.html#a4">foreground</a>(<span class="keyword">true</span>);
<a name="l00132"></a>00132 <span class="keywordflow">break</span>;
<a name="l00133"></a>00133
<a name="l00134"></a>00134 <span class="comment">// Informational options</span>
<a name="l00135"></a>00135 <span class="keywordflow">case</span> <span class="charliteral">'t'</span>: daemon.<a class="code" href="a00044.html#a2">tracefile</a>(<a class="code" href="a00104.html#a3">optarg</a>);
<a name="l00136"></a>00136 <span class="keywordflow">break</span>;
<a name="l00137"></a>00137
<a name="l00138"></a>00138 <span class="keywordflow">case</span> <span class="charliteral">'v'</span>: verbose=<span class="keyword">true</span>;
<a name="l00139"></a>00139 <span class="keywordflow">break</span>;
<a name="l00140"></a>00140
<a name="l00141"></a>00141 <span class="keywordflow">case</span> <span class="charliteral">'V'</span>: cout<<<a class="code" href="a00141.html#a11">OmniEvents::version</a>()<<endl;
<a name="l00142"></a>00142 ::exit(0);
<a name="l00143"></a>00143
<a name="l00144"></a>00144 <span class="keywordflow">case</span> <span class="charliteral">'h'</span>:
<a name="l00145"></a>00145 <span class="keywordflow">default</span> : <a class="code" href="a00141.html#a5">usage</a>(argc,argv);
<a name="l00146"></a>00146 <span class="keywordflow">break</span>;
<a name="l00147"></a>00147 }
<a name="l00148"></a>00148 }
<a name="l00149"></a>00149
<a name="l00150"></a>00150 <span class="comment">//</span>
<a name="l00151"></a>00151 <span class="comment">// Create database instance.</span>
<a name="l00152"></a>00152 omniEventsLog logfile(logDir);
<a name="l00153"></a>00153 PersistNode* initialState =NULL;
<a name="l00154"></a>00154 <span class="keywordflow">if</span>(logfile.fileExists(logfile.activeFilename()))
<a name="l00155"></a>00155 {
<a name="l00156"></a>00156 <span class="comment">// Read library file.</span>
<a name="l00157"></a>00157 initialState=logfile.parse();
<a name="l00158"></a>00158 <span class="comment">// Check for incompatibilities between options and the file.</span>
<a name="l00159"></a>00159 <span class="keywordflow">if</span>(port && port!=initialState->child(<span class="stringliteral">"ecf"</span>)->attrLong(<span class="stringliteral">"port"</span>))
<a name="l00160"></a>00160 {
<a name="l00161"></a>00161 cerr<<
<a name="l00162"></a>00162 <span class="stringliteral">"Error: Option '-p "</span><<port<<<span class="stringliteral">"' conflicts with value '"</span><<
<a name="l00163"></a>00163 initialState->child(<span class="stringliteral">"ecf"</span>)->attrLong(<span class="stringliteral">"port"</span>)<<<span class="stringliteral">"'\n stored in"</span>
<a name="l00164"></a>00164 <span class="stringliteral">" database file '"</span><<logfile.activeFilename()<<<span class="stringliteral">"'.\n"</span>
<a name="l00165"></a>00165 <span class="stringliteral">" Either delete the file to clear the database, or do not use the"</span>
<a name="l00166"></a>00166 <span class="stringliteral">" '-p' option."</span><<endl;
<a name="l00167"></a>00167 exit(1);
<a name="l00168"></a>00168 }
<a name="l00169"></a>00169 <span class="keywordflow">if</span>(endPointNoListen && string(endPointNoListen)!=
<a name="l00170"></a>00170 initialState->child(<span class="stringliteral">"ecf"</span>)->attrString(<span class="stringliteral">"endPointNoListen"</span>))
<a name="l00171"></a>00171 {
<a name="l00172"></a>00172 cerr<<
<a name="l00173"></a>00173 <span class="stringliteral">"Error: Option '-a "</span><<endPointNoListen<<<span class="stringliteral">"' conflicts with value '"</span><<
<a name="l00174"></a>00174 initialState->child(<span class="stringliteral">"ecf"</span>)->attrString(<span class="stringliteral">"endPointNoListen"</span>)<<<span class="stringliteral">"'\n"</span>
<a name="l00175"></a>00175 <span class="stringliteral">" stored in database file '"</span><<logfile.activeFilename()<<<span class="stringliteral">"'.\n"</span>
<a name="l00176"></a>00176 <span class="stringliteral">" Either delete the file to clear the database, or do not use the"</span>
<a name="l00177"></a>00177 <span class="stringliteral">" '-a' option."</span><<endl;
<a name="l00178"></a>00178 exit(1);
<a name="l00179"></a>00179 }
<a name="l00180"></a>00180 }
<a name="l00181"></a>00181 <span class="keywordflow">else</span> <span class="keywordflow">if</span>(logfile.fileExists(logfile.backupFilename()))
<a name="l00182"></a>00182 {
<a name="l00183"></a>00183 <span class="comment">// Quit with an error.</span>
<a name="l00184"></a>00184 cerr <<
<a name="l00185"></a>00185 <span class="stringliteral">"Error: backup file '"</span> << logfile.backupFilename() << <span class="stringliteral">"' exists.\n"</span>
<a name="l00186"></a>00186 <span class="stringliteral">" Rename it to '"</span> << logfile.activeFilename() << <span class="stringliteral">"'\n"</span>
<a name="l00187"></a>00187 <span class="stringliteral">" to recover the server's state, or delete it to create a new\n"</span>
<a name="l00188"></a>00188 <span class="stringliteral">" database file."</span> << endl;
<a name="l00189"></a>00189 exit(1);
<a name="l00190"></a>00190 }
<a name="l00191"></a>00191 <span class="keywordflow">else</span>
<a name="l00192"></a>00192 {
<a name="l00193"></a>00193 <span class="comment">// Create initial state without a library file.</span>
<a name="l00194"></a>00194 initialState=logfile.bootstrap(port?port:11169,endPointNoListen);
<a name="l00195"></a>00195 }
<a name="l00196"></a>00196 port=initialState->child(<span class="stringliteral">"ecf"</span>)->attrLong(<span class="stringliteral">"port"</span>,port);
<a name="l00197"></a>00197 string endPoint2=initialState->child(<span class="stringliteral">"ecf"</span>)->attrString(<span class="stringliteral">"endPointNoListen"</span>);
<a name="l00198"></a>00198
<a name="l00199"></a>00199 <span class="comment">//</span>
<a name="l00200"></a>00200 <span class="comment">// Daemonise</span>
<a name="l00201"></a>00201 daemon.<a class="code" href="a00044.html#a5">daemonize</a>();
<a name="l00202"></a>00202
<a name="l00203"></a>00203 <span class="comment">//</span>
<a name="l00204"></a>00204 <span class="comment">// Initialise orb & POAs.</span>
<a name="l00205"></a>00205 <span class="preprocessor">#ifdef HAVE_OMNIORB4</span>
<a name="l00206"></a>00206 <span class="preprocessor"></span> <span class="keywordtype">char</span> endPoint[64];
<a name="l00207"></a>00207 sprintf(endPoint,<span class="stringliteral">"giop:::%d"</span>,port);
<a name="l00208"></a>00208 <span class="keywordflow">if</span>(endPoint2.empty())
<a name="l00209"></a>00209 {
<a name="l00210"></a>00210 <span class="keyword">const</span> <span class="keywordtype">char</span>* opts[][2] ={ {<span class="stringliteral">"endPoint"</span>,endPoint}, {0,0} };
<a name="l00211"></a>00211 <a class="code" href="a00059.html#e0">Orb::inst</a>()._orb=CORBA::ORB_init(originalArgc,originalArgv,<span class="stringliteral">"omniORB4"</span>,opts);
<a name="l00212"></a>00212 }
<a name="l00213"></a>00213 <span class="keywordflow">else</span>
<a name="l00214"></a>00214 {
<a name="l00215"></a>00215 <span class="keyword">const</span> <span class="keywordtype">char</span>* opts[][2] ={
<a name="l00216"></a>00216 {<span class="stringliteral">"endPoint"</span>,endPoint},
<a name="l00217"></a>00217 {<span class="stringliteral">"endPointNoListen"</span>,endPoint2.c_str()},
<a name="l00218"></a>00218 {0,0} };
<a name="l00219"></a>00219 <a class="code" href="a00059.html#e0">Orb::inst</a>()._orb=CORBA::ORB_init(originalArgc,originalArgv,<span class="stringliteral">"omniORB4"</span>,opts);
<a name="l00220"></a>00220 }
<a name="l00221"></a>00221 <span class="preprocessor">#else</span>
<a name="l00222"></a>00222 <span class="preprocessor"></span> <a class="code" href="a00141.html#a6">insertArgs</a>(argc, argv, 1, 2);
<a name="l00223"></a>00223 argv[1] = strdup(<span class="stringliteral">"-ORBpoa_iiop_port"</span>);
<a name="l00224"></a>00224 argv[2] = <span class="keyword">new</span> <span class="keywordtype">char</span>[32 + 1];
<a name="l00225"></a>00225 sprintf(argv[2], <span class="stringliteral">"%d"</span>, port);
<a name="l00226"></a>00226 <a class="code" href="a00059.html#e0">Orb::inst</a>()._orb=CORBA::ORB_init(argc,argv);
<a name="l00227"></a>00227 <span class="preprocessor">#endif</span>
<a name="l00228"></a>00228 <span class="preprocessor"></span> <a class="code" href="a00059.html#e0">Orb::inst</a>().resolveInitialReferences();
<a name="l00229"></a>00229 {
<a name="l00230"></a>00230 PortableServer::POAManager_var pman;
<a name="l00231"></a>00231 pman=<a class="code" href="a00059.html#e0">Orb::inst</a>()._RootPOA->the_POAManager();
<a name="l00232"></a>00232 pman->activate();
<a name="l00233"></a>00233 pman=<a class="code" href="a00059.html#e0">Orb::inst</a>()._omniINSPOA->the_POAManager();
<a name="l00234"></a>00234 pman->activate();
<a name="l00235"></a>00235 }
<a name="l00236"></a>00236
<a name="l00237"></a>00237 <span class="comment">//</span>
<a name="l00238"></a>00238 <span class="comment">// If omniEvents is restarting then the omniEventsLog object</span>
<a name="l00239"></a>00239 <span class="comment">// will take care of creating the factory and any subordinate</span>
<a name="l00240"></a>00240 <span class="comment">// event channels, proxies, etc under it.</span>
<a name="l00241"></a>00241 logfile.incarnateFactory(initialState);
<a name="l00242"></a>00242 <span class="keyword">delete</span> initialState; <span class="comment">// Tidy up.</span>
<a name="l00243"></a>00243 initialState=NULL;
<a name="l00244"></a>00244
<a name="l00245"></a>00245 {
<a name="l00246"></a>00246 <span class="comment">//</span>
<a name="l00247"></a>00247 <span class="comment">// Register factory with the Naming Service.</span>
<a name="l00248"></a>00248 omniEvents::EventChannelFactory_var factory( logfile.factory()->_this() );
<a name="l00249"></a>00249 <a class="code" href="a00109.html#a2">bindName2Object</a>(
<a name="l00250"></a>00250 <a class="code" href="a00059.html#e0">Orb::inst</a>()._NameService.in(),
<a name="l00251"></a>00251 <a class="code" href="a00109.html#a1">str2name</a>(factoryName),
<a name="l00252"></a>00252 factory.in()
<a name="l00253"></a>00253 );
<a name="l00254"></a>00254
<a name="l00255"></a>00255 <span class="comment">//</span>
<a name="l00256"></a>00256 <span class="comment">// Print the factory IOR.</span>
<a name="l00257"></a>00257 <span class="keywordflow">if</span>(verbose)
<a name="l00258"></a>00258 {
<a name="l00259"></a>00259 <a class="code" href="a00116.html#a2">DB</a>(1,<span class="stringliteral">"Starting omniEvents on port "</span><<port)
<a name="l00260"></a>00260 <span class="keywordflow">if</span>(!endPoint2.empty())
<a name="l00261"></a>00261 <a class="code" href="a00116.html#a2">DB</a>(1,<span class="stringliteral">"Alternate endPoint "</span><<endPoint2.c_str())
<a name="l00262"></a>00262 CORBA::String_var iorstr =
<a name="l00263"></a>00263 <a class="code" href="a00059.html#e0">Orb::inst</a>()._orb->object_to_string(factory.in());
<a name="l00264"></a>00264 <a class="code" href="a00116.html#a2">DB</a>(1,iorstr.in())
<a name="l00265"></a>00265 }
<a name="l00266"></a>00266 } <span class="comment">// factory reference is released.</span>
<a name="l00267"></a>00267
<a name="l00268"></a>00268 <span class="preprocessor">#ifdef HAVE_SIGNAL_H</span>
<a name="l00269"></a>00269 <span class="preprocessor"></span> SIGSET(SIGINT , ::<a class="code" href="a00106.html#a1">OmniEvents_Orb_shutdown</a>);
<a name="l00270"></a>00270 SIGSET(SIGTERM, ::<a class="code" href="a00106.html#a1">OmniEvents_Orb_shutdown</a>);
<a name="l00271"></a>00271 <span class="preprocessor"># ifdef SIGUSR1</span>
<a name="l00272"></a>00272 <span class="preprocessor"></span> SIGSET(SIGUSR1, ::<a class="code" href="a00106.html#a2">OmniEvents_Orb_bumpTraceLevel</a>);
<a name="l00273"></a>00273 <span class="preprocessor"># endif</span>
<a name="l00274"></a>00274 <span class="preprocessor"></span><span class="preprocessor"># ifdef SIGPIPE</span>
<a name="l00275"></a>00275 <span class="preprocessor"></span> SIGSET(SIGPIPE, SIG_IGN); <span class="comment">// Ignore broken pipes</span>
<a name="l00276"></a>00276 <span class="preprocessor"># endif</span>
<a name="l00277"></a>00277 <span class="preprocessor"></span><span class="preprocessor">#endif</span>
<a name="l00278"></a>00278 <span class="preprocessor"></span>
<a name="l00279"></a>00279 daemon.<a class="code" href="a00044.html#a6">runningOk</a>();
<a name="l00280"></a>00280
<a name="l00281"></a>00281 <span class="comment">//</span>
<a name="l00282"></a>00282 <span class="comment">// Start the background tasks.</span>
<a name="l00283"></a>00283 logfile.runWorker(); <span class="comment">// Logfile's worker thread.</span>
<a name="l00284"></a>00284 <a class="code" href="a00059.html#e0">Orb::inst</a>().run(); <span class="comment">// Use the main thread to collect orphaned responses.</span>
<a name="l00285"></a>00285
<a name="l00286"></a>00286 <a class="code" href="a00116.html#a2">DB</a>(1,<span class="stringliteral">"Shutdown requested."</span>)
<a name="l00287"></a>00287 <a class="code" href="a00059.html#e0">Orb::inst</a>()._orb->shutdown(1); <span class="comment">// Synchronous shutdown</span>
<a name="l00288"></a>00288 <a class="code" href="a00059.html#e0">Orb::inst</a>()._orb->destroy(); <span class="comment">// clean up</span>
<a name="l00289"></a>00289
<a name="l00290"></a>00290 <span class="keywordflow">return</span> 0; <span class="comment">// Delete any pidfile & exit.</span>
<a name="l00291"></a>00291
<a name="l00292"></a>00292 <span class="preprocessor">#ifdef HAVE_OMNIORB4</span>
<a name="l00293"></a>00293 <span class="preprocessor"></span> }
<a name="l00294"></a>00294 <span class="keywordflow">catch</span> (CORBA::SystemException& ex) {
<a name="l00295"></a>00295 <a class="code" href="a00116.html#a2">DB</a>(0,<span class="stringliteral">"System exception: "</span><<ex._name()<<<span class="stringliteral">" ("</span><<<a class="code" href="a00116.html#a3">NP_MINORSTRING</a>(ex)<<<span class="stringliteral">")"</span>)
<a name="l00296"></a>00296 }
<a name="l00297"></a>00297 <span class="keywordflow">catch</span> (CORBA::Exception& ex) {
<a name="l00298"></a>00298 <a class="code" href="a00116.html#a2">DB</a>(0,<span class="stringliteral">"CORBA exception: "</span><<ex._name())
<a name="l00299"></a>00299 }
<a name="l00300"></a>00300 <span class="keywordflow">return</span> 1;
<a name="l00301"></a>00301 <span class="preprocessor">#endif</span>
<a name="l00302"></a>00302 <span class="preprocessor"></span>} <span class="comment">// end main()</span>
<a name="l00303"></a>00303
<a name="l00304"></a>00304
<a name="l00305"></a>00305 <span class="comment">//</span>
<a name="l00306"></a>00306 <span class="comment">// Signal handlers.</span>
<a name="l00307"></a>00307 <span class="comment">//</span>
<a name="l00308"></a>00308
<a name="l00309"></a>00309 <span class="keyword">extern</span> <span class="stringliteral">"C"</span>
<a name="l00310"></a>00310 {
<a name="l00311"></a><a class="code" href="a00107.html#a1">00311</a> <span class="keywordtype">void</span> <a class="code" href="a00106.html#a1">OmniEvents_Orb_shutdown</a>(<span class="keywordtype">int</span> signum)
<a name="l00312"></a>00312 {
<a name="l00313"></a>00313 <a class="code" href="a00059.html#e0">OmniEvents::Orb::inst</a>().shutdown(signum);
<a name="l00314"></a>00314 }
<a name="l00315"></a>00315
<a name="l00316"></a><a class="code" href="a00107.html#a2">00316</a> <span class="keywordtype">void</span> <a class="code" href="a00106.html#a2">OmniEvents_Orb_bumpTraceLevel</a>(<span class="keywordtype">int</span> signum)
<a name="l00317"></a>00317 {
<a name="l00318"></a>00318 omniORB::traceLevel=(omniORB::traceLevel+5)%45;
<a name="l00319"></a>00319 <a class="code" href="a00116.html#a2">DB</a>(0,<span class="stringliteral">"TRACE LEVEL BUMPED TO "</span><<omniORB::traceLevel<<<span class="stringliteral">" BY SIGNAL "</span><<signum)
<a name="l00320"></a>00320 }
<a name="l00321"></a>00321 }
</pre></div><hr size="1"><address style="align: right;"><small>Generated on Fri Aug 26 20:56:14 2005 for OmniEvents by
<a href="http://www.doxygen.org/index.html">
<img src="doxygen.png" alt="doxygen" align="middle" border="0"></a> 1.4.3-20050530 </small></address>
</body>
</html>
|
