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
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
|
<!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: ProxyPushSupplier.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>ProxyPushSupplier.cc</h1><a href="a00127.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">// ProxyPushSupplier.cc Created : 2003/12/04</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) 2003,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
<a name="l00024"></a>00024 <span class="preprocessor">#include "<a class="code" href="a00128.html">ProxyPushSupplier.h</a>"</span>
<a name="l00025"></a>00025 <span class="preprocessor">#include "<a class="code" href="a00116.html">Orb.h</a>"</span>
<a name="l00026"></a>00026 <span class="preprocessor">#include "<a class="code" href="a00114.html">omniEventsLog.h</a>"</span>
<a name="l00027"></a>00027 <span class="preprocessor">#include "<a class="code" href="a00118.html">PersistNode.h</a>"</span>
<a name="l00028"></a>00028 <span class="preprocessor">#include <assert.h></span>
<a name="l00029"></a>00029
<a name="l00030"></a>00030 <span class="keyword">namespace </span>OmniEvents {
<a name="l00031"></a>00031
<a name="l00035"></a><a class="code" href="a00055.html">00035</a> <span class="keyword">class </span><a class="code" href="a00055.html">omni_mutex_kcol</a> {
<a name="l00036"></a><a class="code" href="a00055.html#r0">00036</a> omni_mutex& <a class="code" href="a00055.html#r0">mutex</a>;
<a name="l00037"></a>00037 <span class="keyword">public</span>:
<a name="l00038"></a><a class="code" href="a00055.html#a0">00038</a> <a class="code" href="a00055.html#a0">omni_mutex_kcol</a>(omni_mutex& m) : <a class="code" href="a00055.html#r0">mutex</a>(m) { <a class="code" href="a00055.html#r0">mutex</a>.unlock(); }
<a name="l00039"></a><a class="code" href="a00055.html#a1">00039</a> <a class="code" href="a00055.html#a1">~omni_mutex_kcol</a>(<span class="keywordtype">void</span>) { <a class="code" href="a00055.html#r0">mutex</a>.lock(); }
<a name="l00040"></a>00040 <span class="keyword">private</span>:
<a name="l00041"></a>00041 <span class="comment">// dummy copy constructor and operator= to prevent copying</span>
<a name="l00042"></a>00042 <a class="code" href="a00055.html#a0">omni_mutex_kcol</a>(<span class="keyword">const</span> <a class="code" href="a00055.html">omni_mutex_kcol</a>&);
<a name="l00043"></a>00043 <a class="code" href="a00055.html">omni_mutex_kcol</a>& <a class="code" href="a00055.html#d1">operator=</a>(<span class="keyword">const</span> <a class="code" href="a00055.html">omni_mutex_kcol</a>&);
<a name="l00044"></a>00044 };
<a name="l00045"></a>00045
<a name="l00046"></a>00046
<a name="l00047"></a>00047 <span class="comment">//</span>
<a name="l00048"></a>00048 <span class="comment">// ProxyPushSupplierManager</span>
<a name="l00049"></a>00049 <span class="comment">//</span>
<a name="l00050"></a>00050
<a name="l00051"></a>00051 PortableServer::Servant
<a name="l00052"></a><a class="code" href="a00070.html#a0">00052</a> <a class="code" href="a00070.html#a0">ProxyPushSupplierManager::incarnate</a>(
<a name="l00053"></a>00053 <span class="keyword">const</span> PortableServer::ObjectId& oid,
<a name="l00054"></a>00054 PortableServer::POA_ptr poa
<a name="l00055"></a>00055 )
<a name="l00056"></a>00056 {
<a name="l00057"></a>00057 <a class="code" href="a00069.html">ProxyPushSupplier_i</a>* result =<span class="keyword">new</span> <a class="code" href="a00069.html">ProxyPushSupplier_i</a>(<a class="code" href="a00062.html#p1">_managedPoa</a>,<a class="code" href="a00070.html#r0">_queue</a>);
<a name="l00058"></a>00058 <a class="code" href="a00071.html">PauseThenWake</a> p(<span class="keyword">this</span>);
<a name="l00059"></a>00059 <a class="code" href="a00062.html#p0">_servants</a>.insert(result);
<a name="l00060"></a>00060 <span class="keywordflow">return</span> result;
<a name="l00061"></a>00061 }
<a name="l00062"></a>00062
<a name="l00063"></a>00063 <span class="keywordtype">void</span>
<a name="l00064"></a><a class="code" href="a00070.html#a1">00064</a> <a class="code" href="a00070.html#a1">ProxyPushSupplierManager::etherealize</a>(
<a name="l00065"></a>00065 <span class="keyword">const</span> PortableServer::ObjectId& oid,
<a name="l00066"></a>00066 PortableServer::POA_ptr adapter,
<a name="l00067"></a>00067 PortableServer::Servant serv,
<a name="l00068"></a>00068 CORBA::Boolean cleanup_in_progress,
<a name="l00069"></a>00069 CORBA::Boolean remaining_activations
<a name="l00070"></a>00070 )
<a name="l00071"></a>00071 {
<a name="l00072"></a>00072 <span class="comment">// This etherealize method needs a special implementation because</span>
<a name="l00073"></a>00073 <span class="comment">// ProxyPushSupplier_i objects are freed with _remove_ref() rather than</span>
<a name="l00074"></a>00074 <span class="comment">// delete.</span>
<a name="l00075"></a>00075 <span class="comment">// Otherwise, this method strongly resembles ProxyManager::etherealize().</span>
<a name="l00076"></a>00076 omni_mutex_lock pause(<a class="code" href="a00070.html#o0">_lock</a>);
<a name="l00077"></a>00077 <a class="code" href="a00069.html">ProxyPushSupplier_i</a>* narrowed =dynamic_cast<ProxyPushSupplier_i*>(serv);
<a name="l00078"></a>00078 assert(narrowed!=NULL);
<a name="l00079"></a>00079 set<Proxy*>::iterator pos =<a class="code" href="a00062.html#p0">_servants</a>.find(narrowed);
<a name="l00080"></a>00080 <span class="keywordflow">if</span>(pos!=<a class="code" href="a00062.html#p0">_servants</a>.end())
<a name="l00081"></a>00081 {
<a name="l00082"></a>00082 <a class="code" href="a00062.html#p0">_servants</a>.erase(pos);
<a name="l00083"></a>00083 narrowed->_remove_ref();
<a name="l00084"></a>00084 }
<a name="l00085"></a>00085 <span class="keywordflow">else</span>
<a name="l00086"></a>00086 {
<a name="l00087"></a>00087 <a class="code" href="a00116.html#a2">DB</a>(1,<span class="stringliteral">"\t\teh? - POA attempted to etherealize unknown servant."</span>);
<a name="l00088"></a>00088 }
<a name="l00089"></a>00089 }
<a name="l00090"></a>00090
<a name="l00091"></a><a class="code" href="a00070.html#a2">00091</a> <a class="code" href="a00070.html#a2">ProxyPushSupplierManager::ProxyPushSupplierManager</a>(
<a name="l00092"></a>00092 PortableServer::POA_ptr parentPoa,
<a name="l00093"></a>00093 <a class="code" href="a00049.html">EventQueue</a>& q
<a name="l00094"></a>00094 )
<a name="l00095"></a>00095 : <a class="code" href="a00062.html">ProxyManager</a>(parentPoa),
<a name="l00096"></a>00096 omni_thread(NULL,PRIORITY_HIGH),
<a name="l00097"></a>00097 _queue(q),
<a name="l00098"></a>00098 _lock(),_condition(&_lock),
<a name="l00099"></a>00099 _refCount(1)
<a name="l00100"></a>00100 {
<a name="l00101"></a>00101 <a class="code" href="a00062.html#b2">ProxyManager::activate</a>(<span class="stringliteral">"ProxyPushSupplier"</span>);
<a name="l00102"></a>00102 start_undetached();
<a name="l00103"></a>00103 }
<a name="l00104"></a>00104
<a name="l00105"></a><a class="code" href="a00070.html#a3">00105</a> <a class="code" href="a00070.html#a3">ProxyPushSupplierManager::~ProxyPushSupplierManager</a>()
<a name="l00106"></a>00106 {
<a name="l00107"></a>00107 <a class="code" href="a00116.html#a2">DB</a>(20,<span class="stringliteral">"~ProxyPushSupplierManager()"</span>)
<a name="l00108"></a>00108 }
<a name="l00109"></a>00109
<a name="l00110"></a>00110 CosEventChannelAdmin::ProxyPushSupplier_ptr
<a name="l00111"></a><a class="code" href="a00070.html#a4">00111</a> <a class="code" href="a00070.html#a4">ProxyPushSupplierManager::createObject</a>()
<a name="l00112"></a>00112 {
<a name="l00113"></a>00113 <span class="keywordflow">return</span> createNarrowedReference<CosEventChannelAdmin::ProxyPushSupplier>(
<a name="l00114"></a>00114 <a class="code" href="a00062.html#p1">_managedPoa</a>.in(),
<a name="l00115"></a>00115 CosEventChannelAdmin::_tc_ProxyPushSupplier->id()
<a name="l00116"></a>00116 );
<a name="l00117"></a>00117 }
<a name="l00118"></a>00118
<a name="l00119"></a><a class="code" href="a00070.html#a5">00119</a> <span class="keywordtype">void</span> <a class="code" href="a00070.html#a5">ProxyPushSupplierManager::disconnect</a>()
<a name="l00120"></a>00120 {
<a name="l00121"></a>00121 <span class="keywordflow">for</span>(set<Proxy*>::iterator i =<a class="code" href="a00062.html#p0">_servants</a>.begin(); i!=<a class="code" href="a00062.html#p0">_servants</a>.end(); ++i)
<a name="l00122"></a>00122 {
<a name="l00123"></a>00123 <a class="code" href="a00061.html">Proxy</a>* p =*i; <span class="comment">// Sun's CC requires this temporary.</span>
<a name="l00124"></a>00124 <a class="code" href="a00069.html">ProxyPushSupplier_i</a>* pps =static_cast<ProxyPushSupplier_i*>(p);
<a name="l00125"></a>00125 <span class="comment">// We are in the EventChannel's thread.</span>
<a name="l00126"></a>00126 <span class="comment">// Make sure all calls go though the ProxyPushSupplier POA.</span>
<a name="l00127"></a>00127 CosEventChannelAdmin::ProxyPushSupplier_var ppsv =pps->_this();
<a name="l00128"></a>00128 ppsv-><a class="code" href="a00069.html#a1">disconnect_push_supplier</a>();
<a name="l00129"></a>00129 }
<a name="l00130"></a>00130 }
<a name="l00131"></a>00131
<a name="l00132"></a>00132 <span class="keywordtype">void</span>*
<a name="l00133"></a><a class="code" href="a00070.html#a6">00133</a> <a class="code" href="a00070.html#a6">ProxyPushSupplierManager::run_undetached</a>(<span class="keywordtype">void</span>*)
<a name="l00134"></a>00134 {
<a name="l00135"></a>00135 <span class="comment">// This loop repeatedly triggers all of the servants in turn. As long as</span>
<a name="l00136"></a>00136 <span class="comment">// something happens each time, then we loop as fast as we can.</span>
<a name="l00137"></a>00137 <span class="comment">// As soon as activity dries up, we start to wait longer and longer between</span>
<a name="l00138"></a>00138 <span class="comment">// loops (up to a maximum). When there is no work to do, just block until</span>
<a name="l00139"></a>00139 <span class="comment">// a new event arrives.</span>
<a name="l00140"></a>00140 <span class="comment">//</span>
<a name="l00141"></a>00141 <span class="comment">// Rationale: The faster we loop the more events we can deliver to each</span>
<a name="l00142"></a>00142 <span class="comment">// consumer per second. However, when nothing is happening, this busy loop</span>
<a name="l00143"></a>00143 <span class="comment">// just soaks up CPU and kills performance. The optimum sleep time varies</span>
<a name="l00144"></a>00144 <span class="comment">// wildly from platform to platform, and also depends upon the typical ping</span>
<a name="l00145"></a>00145 <span class="comment">// time to the consumers.</span>
<a name="l00146"></a>00146 <span class="comment">//</span>
<a name="l00147"></a>00147 <span class="comment">// This dynamic approach should deliver reasonable performance when things</span>
<a name="l00148"></a>00148 <span class="comment">// are hectic, but not soak up too much CPU when not much is happening.</span>
<a name="l00149"></a>00149 <span class="comment">//</span>
<a name="l00150"></a>00150 <span class="keyword">const</span> <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> sleepTimeNanosec0 =0x8000; <span class="comment">// 33us (doubled before use)</span>
<a name="l00151"></a>00151 <span class="keyword">const</span> <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> maxSleepNanosec =0x800000; <span class="comment">// 8.4ms</span>
<a name="l00152"></a>00152 <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> sleepTimeNanosec =sleepTimeNanosec0;
<a name="l00153"></a>00153
<a name="l00154"></a>00154 omni_mutex_lock conditionLock(<a class="code" href="a00070.html#o0">_lock</a>);
<a name="l00155"></a>00155 <span class="keywordflow">while</span>(<span class="keyword">true</span>)
<a name="l00156"></a>00156 {
<a name="l00157"></a>00157 <span class="keywordflow">try</span> {
<a name="l00158"></a>00158 <span class="keywordflow">if</span>(<a class="code" href="a00070.html#r1">_refCount</a><1)
<a name="l00159"></a>00159 <span class="keywordflow">break</span>;
<a name="l00160"></a>00160
<a name="l00161"></a>00161 <span class="keywordtype">bool</span> busy=<span class="keyword">false</span>;
<a name="l00162"></a>00162 <span class="keywordtype">bool</span> waiting=<span class="keyword">false</span>;
<a name="l00163"></a>00163
<a name="l00164"></a>00164 <span class="comment">// Trigger each servant in turn.</span>
<a name="l00165"></a>00165 <span class="keywordflow">for</span>(set<Proxy*>::iterator i =<a class="code" href="a00062.html#p0">_servants</a>.begin(); i!=<a class="code" href="a00062.html#p0">_servants</a>.end(); ++i)
<a name="l00166"></a>00166 {
<a name="l00167"></a>00167 <a class="code" href="a00061.html">Proxy</a>* p =*i; <span class="comment">// Sun's CC requires this temporary.</span>
<a name="l00168"></a>00168 <a class="code" href="a00069.html">ProxyPushSupplier_i</a>* pps =static_cast<ProxyPushSupplier_i*>(p);
<a name="l00169"></a>00169 pps-><a class="code" href="a00069.html#a4">trigger</a>(busy,waiting);
<a name="l00170"></a>00170 }
<a name="l00171"></a>00171
<a name="l00172"></a>00172 <span class="keywordflow">if</span>(busy)
<a name="l00173"></a>00173 {
<a name="l00174"></a>00174 <span class="comment">// Something happened last time round. So we'll be optimistic and</span>
<a name="l00175"></a>00175 <span class="comment">// immediately go round for another go. Briefly unlock the mutex first,</span>
<a name="l00176"></a>00176 <span class="comment">// just to let the other kids get in if they need to.</span>
<a name="l00177"></a>00177 <a class="code" href="a00055.html">omni_mutex_kcol</a> l(<a class="code" href="a00070.html#o0">_lock</a>); <span class="comment">// 'lock' reversed!</span>
<a name="l00178"></a>00178 <span class="comment">// Reset the sleep time.</span>
<a name="l00179"></a>00179 sleepTimeNanosec=sleepTimeNanosec0;
<a name="l00180"></a>00180 }
<a name="l00181"></a>00181 <span class="keywordflow">else</span> <span class="keywordflow">if</span>(waiting)
<a name="l00182"></a>00182 {
<a name="l00183"></a>00183 <span class="comment">// Nothing happened, so we'll wait for a bit and then give it another</span>
<a name="l00184"></a>00184 <span class="comment">// go. Each time we wait for twice as long, up to the maximum.</span>
<a name="l00185"></a>00185 <span class="keywordflow">if</span>(sleepTimeNanosec<maxSleepNanosec)
<a name="l00186"></a>00186 sleepTimeNanosec<<=1; <span class="comment">// (multiply by 2)</span>
<a name="l00187"></a>00187 <span class="keywordtype">unsigned</span> <span class="keywordtype">long</span> sec,nsec;
<a name="l00188"></a>00188 omni_thread::get_time(&sec,&nsec,0,sleepTimeNanosec);
<a name="l00189"></a>00189 <a class="code" href="a00070.html#o1">_condition</a>.timedwait(sec,nsec);
<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">// There is nothing to do, so block until a new event arrives.</span>
<a name="l00194"></a>00194 <a class="code" href="a00070.html#o1">_condition</a>.wait();
<a name="l00195"></a>00195 }
<a name="l00196"></a>00196
<a name="l00197"></a>00197 }
<a name="l00198"></a>00198 <span class="keywordflow">catch</span> (CORBA::SystemException& ex) {
<a name="l00199"></a>00199 <a class="code" href="a00116.html#a2">DB</a>(2,<span class="stringliteral">"ProxyPushSupplierManager ignoring CORBA system exception"</span>
<a name="l00200"></a>00200 <a class="code" href="a00116.html#a1">IF_OMNIORB4</a>(<span class="stringliteral">": "</span><<ex._name()<<<span class="stringliteral">" ("</span><<<a class="code" href="a00116.html#a3">NP_MINORSTRING</a>(ex)<<<span class="stringliteral">")"</span>) <span class="stringliteral">"."</span>)
<a name="l00201"></a>00201 }
<a name="l00202"></a>00202 <span class="keywordflow">catch</span> (CORBA::Exception& ex) {
<a name="l00203"></a>00203 <a class="code" href="a00116.html#a2">DB</a>(2,<span class="stringliteral">"ProxyPushSupplierManager ignoring CORBA exception"</span>
<a name="l00204"></a>00204 <a class="code" href="a00116.html#a1">IF_OMNIORB4</a>(<span class="stringliteral">": "</span><<ex._name()<<) <span class="stringliteral">"."</span>)
<a name="l00205"></a>00205 }
<a name="l00206"></a>00206 <span class="keywordflow">catch</span>(...) {
<a name="l00207"></a>00207 <a class="code" href="a00116.html#a2">DB</a>(2,<span class="stringliteral">"ProxyPushSupplierManager thread killed by unknown exception."</span>)
<a name="l00208"></a>00208 <span class="keywordflow">break</span>;
<a name="l00209"></a>00209 }
<a name="l00210"></a>00210 }
<a name="l00211"></a>00211 <span class="keywordflow">return</span> NULL;
<a name="l00212"></a>00212 }
<a name="l00213"></a>00213
<a name="l00214"></a><a class="code" href="a00070.html#a7">00214</a> <span class="keywordtype">void</span> <a class="code" href="a00070.html#a7">ProxyPushSupplierManager::_add_ref</a>()
<a name="l00215"></a>00215 {
<a name="l00216"></a>00216 <span class="preprocessor">#if OMNIEVENTS__DEBUG_REF_COUNTS</span>
<a name="l00217"></a>00217 <span class="preprocessor"></span> <a class="code" href="a00116.html#a2">DB</a>(20,<span class="stringliteral">"ProxyPushSupplierManager::_add_ref()"</span>)
<a name="l00218"></a>00218 #endif
<a name="l00219"></a>00219 omni_mutex_lock pause(<a class="code" href="a00070.html#o0">_lock</a>);
<a name="l00220"></a>00220 ++<a class="code" href="a00070.html#r1">_refCount</a>;
<a name="l00221"></a>00221 }
<a name="l00222"></a>00222
<a name="l00223"></a><a class="code" href="a00070.html#a8">00223</a> <span class="keywordtype">void</span> <a class="code" href="a00070.html#a8">ProxyPushSupplierManager::_remove_ref</a>()
<a name="l00224"></a>00224 {
<a name="l00225"></a>00225 <span class="preprocessor">#if OMNIEVENTS__DEBUG_REF_COUNTS</span>
<a name="l00226"></a>00226 <span class="preprocessor"></span> <a class="code" href="a00116.html#a2">DB</a>(20,<span class="stringliteral">"ProxyPushSupplierManager::_remove_ref()"</span>)
<a name="l00227"></a>00227 #endif
<a name="l00228"></a>00228 <span class="keywordtype">int</span> myref;
<a name="l00229"></a>00229 {
<a name="l00230"></a>00230 <a class="code" href="a00071.html">PauseThenWake</a> p(<span class="keyword">this</span>);
<a name="l00231"></a>00231 myref = --<a class="code" href="a00070.html#r1">_refCount</a>;
<a name="l00232"></a>00232 }
<a name="l00233"></a>00233 <span class="keywordflow">if</span>(myref<0)
<a name="l00234"></a>00234 {
<a name="l00235"></a>00235 <a class="code" href="a00116.html#a2">DB</a>(2,<span class="stringliteral">"ProxyPushSupplierManager has negative ref count! "</span><<myref)
<a name="l00236"></a>00236 }
<a name="l00237"></a>00237 <span class="keywordflow">else</span> <span class="keywordflow">if</span>(myref==0)
<a name="l00238"></a>00238 {
<a name="l00239"></a>00239 <a class="code" href="a00116.html#a2">DB</a>(15,<span class="stringliteral">"ProxyPushSupplierManager has zero ref count -- shutdown."</span>)
<a name="l00240"></a>00240 join(NULL);
<a name="l00241"></a>00241 }
<a name="l00242"></a>00242 }
<a name="l00243"></a>00243
<a name="l00244"></a>00244
<a name="l00245"></a>00245 <span class="comment">//</span>
<a name="l00246"></a>00246 <span class="comment">// ProxyPushSupplier_i</span>
<a name="l00247"></a>00247 <span class="comment">//</span>
<a name="l00248"></a>00248
<a name="l00249"></a><a class="code" href="a00069.html#a0">00249</a> <span class="keywordtype">void</span> <a class="code" href="a00069.html#a0">ProxyPushSupplier_i::connect_push_consumer</a>(
<a name="l00250"></a>00250 CosEventComm::PushConsumer_ptr pushConsumer)
<a name="l00251"></a>00251 {
<a name="l00252"></a>00252 <span class="keywordflow">if</span>(CORBA::is_nil(pushConsumer))
<a name="l00253"></a>00253 <span class="keywordflow">throw</span> CORBA::BAD_PARAM();
<a name="l00254"></a>00254 <span class="keywordflow">if</span>(!CORBA::is_nil(<a class="code" href="a00069.html#r0">_target</a>) || !CORBA::is_nil(<a class="code" href="a00061.html#p0">_req</a>))
<a name="l00255"></a>00255 <span class="keywordflow">throw</span> CosEventChannelAdmin::AlreadyConnected();
<a name="l00256"></a>00256 <a class="code" href="a00069.html#r0">_target</a>=CosEventComm::PushConsumer::_duplicate(pushConsumer);
<a name="l00257"></a>00257
<a name="l00258"></a>00258 <span class="comment">// Test to see whether pushSupplier is a ProxyPushSupplier.</span>
<a name="l00259"></a>00259 <span class="comment">// If so, then we will aggressively try to reconnect, when we are reincarnated</span>
<a name="l00260"></a>00260 CORBA::Request_var req =<a class="code" href="a00069.html#r0">_target</a>->_request(<span class="stringliteral">"_is_a"</span>);
<a name="l00261"></a>00261 req->add_in_arg() <<= CosEventChannelAdmin::_tc_ProxyPushConsumer->id();
<a name="l00262"></a>00262 req->set_return_type(CORBA::_tc_boolean);
<a name="l00263"></a>00263 req->send_deferred();
<a name="l00264"></a>00264 <a class="code" href="a00059.html#e0">Orb::inst</a>().<a class="code" href="a00059.html#a3">deferredRequest</a>(req._retn(),<span class="keyword">this</span>); <span class="comment">// Register for callback</span>
<a name="l00265"></a>00265
<a name="l00266"></a>00266 <span class="keywordflow">if</span>(<a class="code" href="a00056.html#e0">omniEventsLog::exists</a>())
<a name="l00267"></a>00267 {
<a name="l00268"></a>00268 <a class="code" href="a00080.html">WriteLock</a> log;
<a name="l00269"></a>00269 <a class="code" href="a00069.html#a7">output</a>(log.<a class="code" href="a00080.html#o0">os</a>);
<a name="l00270"></a>00270 }
<a name="l00271"></a>00271 }
<a name="l00272"></a>00272
<a name="l00273"></a>00273
<a name="l00274"></a><a class="code" href="a00069.html#a1">00274</a> <span class="keywordtype">void</span> <a class="code" href="a00069.html#a1">ProxyPushSupplier_i::disconnect_push_supplier</a>()
<a name="l00275"></a>00275 {
<a name="l00276"></a>00276 <a class="code" href="a00116.html#a2">DB</a>(5,<span class="stringliteral">"ProxyPushSupplier_i::disconnect_push_supplier()"</span>);
<a name="l00277"></a>00277 <a class="code" href="a00061.html#b2">eraseKey</a>(<span class="stringliteral">"ConsumerAdmin/ProxyPushSupplier"</span>);
<a name="l00278"></a>00278 <a class="code" href="a00073.html#b2">deactivateObject</a>();
<a name="l00279"></a>00279 <span class="keywordflow">if</span>(CORBA::is_nil(<a class="code" href="a00069.html#r0">_target</a>))
<a name="l00280"></a>00280 {
<a name="l00281"></a>00281 <span class="keywordflow">throw</span> CORBA::OBJECT_NOT_EXIST(
<a name="l00282"></a>00282 <a class="code" href="a00116.html#a0">IFELSE_OMNIORB4</a>(omni::OBJECT_NOT_EXIST_NoMatch,0),
<a name="l00283"></a>00283 CORBA::COMPLETED_NO
<a name="l00284"></a>00284 );
<a name="l00285"></a>00285 }
<a name="l00286"></a>00286 <span class="keywordflow">else</span>
<a name="l00287"></a>00287 {
<a name="l00288"></a>00288 CORBA::Request_var req=<a class="code" href="a00069.html#r0">_target</a>->_request(<span class="stringliteral">"disconnect_push_consumer"</span>);
<a name="l00289"></a>00289 <a class="code" href="a00069.html#r0">_target</a>=CosEventComm::PushConsumer::_nil();
<a name="l00290"></a>00290 req->send_deferred();
<a name="l00291"></a>00291 <a class="code" href="a00059.html#e0">Orb::inst</a>().<a class="code" href="a00059.html#a3">deferredRequest</a>(req._retn());
<a name="l00292"></a>00292 }
<a name="l00293"></a>00293 }
<a name="l00294"></a>00294
<a name="l00295"></a>00295
<a name="l00296"></a><a class="code" href="a00069.html#a2">00296</a> <a class="code" href="a00069.html#a2">ProxyPushSupplier_i::ProxyPushSupplier_i</a>(
<a name="l00297"></a>00297 PortableServer::POA_ptr poa,
<a name="l00298"></a>00298 <a class="code" href="a00049.html">EventQueue</a>& q
<a name="l00299"></a>00299 )
<a name="l00300"></a>00300 : <a class="code" href="a00061.html">Proxy</a>(poa),
<a name="l00301"></a>00301 <a class="code" href="a00049.html">EventQueue</a>::Reader(q),
<a name="l00302"></a>00302 _target(CosEventComm::PushConsumer::_nil()),
<a name="l00303"></a>00303 _targetIsProxy(false)
<a name="l00304"></a>00304 {
<a name="l00305"></a>00305 <span class="comment">// pass</span>
<a name="l00306"></a>00306 }
<a name="l00307"></a>00307
<a name="l00308"></a><a class="code" href="a00069.html#a3">00308</a> <a class="code" href="a00069.html#a3">ProxyPushSupplier_i::~ProxyPushSupplier_i</a>()
<a name="l00309"></a>00309 {
<a name="l00310"></a>00310 <a class="code" href="a00116.html#a2">DB</a>(20,<span class="stringliteral">"~ProxyPushSupplier_i()"</span>)
<a name="l00311"></a>00311 }
<a name="l00312"></a>00312
<a name="l00313"></a>00313 <a class="code" href="a00136.html#a3">OMNIEVENTS__DEBUG_REF_COUNTS__DEFN</a>(<a class="code" href="a00069.html">ProxyPushSupplier_i</a>)
<a name="l00314"></a>00314
<a name="l00315"></a><a class="code" href="a00069.html#a4">00315</a> inline <span class="keywordtype">void</span> <a class="code" href="a00069.html">ProxyPushSupplier_i</a>::trigger(<span class="keywordtype">bool</span>& busy, <span class="keywordtype">bool</span>& waiting)
<a name="l00316"></a>00316 {
<a name="l00317"></a>00317 <span class="keywordflow">if</span>(!CORBA::is_nil(_req) && _req->poll_response()) <span class="comment">// response has arrived</span>
<a name="l00318"></a>00318 {
<a name="l00319"></a>00319 CORBA::Environment_ptr env=_req->env(); <span class="comment">// No need to free environment.</span>
<a name="l00320"></a>00320 <span class="keywordflow">if</span>(!CORBA::is_nil(env) && env->exception())
<a name="l00321"></a>00321 {
<a name="l00322"></a>00322 <span class="comment">// Shut down the connection</span>
<a name="l00323"></a>00323 CORBA::Exception* ex =env->exception(); <span class="comment">// No need to free exception.</span>
<a name="l00324"></a>00324 <a class="code" href="a00116.html#a2">DB</a>(10,<span class="stringliteral">"ProxyPushSupplier got exception"</span> <a class="code" href="a00116.html#a1">IF_OMNIORB4</a>(<span class="stringliteral">": "</span><<ex->_name()) );
<a name="l00325"></a>00325 <a class="code" href="a00059.html#e0">Orb::inst</a>().<a class="code" href="a00059.html#a5">reportObjectFailure</a>(<a class="code" href="a00089.html#a3">HERE</a>,_target.in(),ex);
<a name="l00326"></a>00326 _req=CORBA::Request::_nil();
<a name="l00327"></a>00327
<a name="l00328"></a>00328 <span class="comment">// Try to notify the Consumer that the connection is closing.</span>
<a name="l00329"></a>00329 CORBA::Request_var req=_target->_request(<span class="stringliteral">"disconnect_push_consumer"</span>);
<a name="l00330"></a>00330 req->send_deferred();
<a name="l00331"></a>00331 <a class="code" href="a00059.html#e0">Orb::inst</a>().<a class="code" href="a00059.html#a3">deferredRequest</a>(req._retn());
<a name="l00332"></a>00332
<a name="l00333"></a>00333 _target=CosEventComm::PushConsumer::_nil(); <span class="comment">// disconnected.</span>
<a name="l00334"></a>00334 eraseKey(<span class="stringliteral">"ConsumerAdmin/ProxyPushSupplier"</span>);
<a name="l00335"></a>00335 deactivateObject();
<a name="l00336"></a>00336 <span class="keywordflow">return</span>; <span class="comment">// No more work to do</span>
<a name="l00337"></a>00337 }
<a name="l00338"></a>00338 _req=CORBA::Request::_nil();
<a name="l00339"></a>00339 busy=<span class="keyword">true</span>;
<a name="l00340"></a>00340 }
<a name="l00341"></a>00341 <span class="keywordflow">if</span>(CORBA::is_nil(_req) && !CORBA::is_nil(_target) && moreEvents())
<a name="l00342"></a>00342 {
<a name="l00343"></a>00343 _req=_target->_request(<span class="stringliteral">"push"</span>);
<a name="l00344"></a>00344 _req->add_in_arg() <<= *(nextEvent());
<a name="l00345"></a>00345 _req->send_deferred();
<a name="l00346"></a>00346 busy=<span class="keyword">true</span>;
<a name="l00347"></a>00347 }
<a name="l00348"></a>00348 <span class="keywordflow">if</span>(!CORBA::is_nil(_req)) <span class="comment">// More work to do, if _req NOT nil.</span>
<a name="l00349"></a>00349 waiting=<span class="keyword">true</span>;
<a name="l00350"></a>00350 }
<a name="l00351"></a>00351
<a name="l00352"></a>00352
<a name="l00353"></a><a class="code" href="a00069.html#a5">00353</a> <span class="keywordtype">void</span> <a class="code" href="a00069.html#a5">ProxyPushSupplier_i::callback</a>(CORBA::Request_ptr req)
<a name="l00354"></a>00354 {
<a name="l00355"></a>00355 <span class="keywordflow">if</span>(<a class="code" href="a00069.html#r1">_targetIsProxy</a>)
<a name="l00356"></a>00356 {
<a name="l00357"></a>00357 <span class="comment">// There should only ever be one of these callbacks per proxy,</span>
<a name="l00358"></a>00358 <span class="comment">// because each proxy should only be connected once.</span>
<a name="l00359"></a>00359 <a class="code" href="a00116.html#a2">DB</a>(2,<span class="stringliteral">"WARNING: Multiple connections to ProxyPushSupplier."</span>);
<a name="l00360"></a>00360 }
<a name="l00361"></a>00361 <span class="keywordflow">else</span> <span class="keywordflow">if</span>(req->return_value()>>=CORBA::Any::to_boolean(<a class="code" href="a00069.html#r1">_targetIsProxy</a>))
<a name="l00362"></a>00362 {
<a name="l00363"></a>00363 <span class="keywordflow">if</span>(<a class="code" href="a00069.html#r1">_targetIsProxy</a> && <a class="code" href="a00056.html#e0">omniEventsLog::exists</a>())
<a name="l00364"></a>00364 {
<a name="l00365"></a>00365 <a class="code" href="a00080.html">WriteLock</a> log;
<a name="l00366"></a>00366 <a class="code" href="a00069.html#a7">output</a>(log.<a class="code" href="a00080.html#o0">os</a>);
<a name="l00367"></a>00367 <a class="code" href="a00116.html#a2">DB</a>(15,<span class="stringliteral">"ProxyPushSupplier is federated."</span>);
<a name="l00368"></a>00368 }
<a name="l00369"></a>00369 }
<a name="l00370"></a>00370 <span class="keywordflow">else</span>
<a name="l00371"></a>00371 {
<a name="l00372"></a>00372 <a class="code" href="a00116.html#a2">DB</a>(2,<span class="stringliteral">"ProxyPushSupplier got unexpected callback."</span>);
<a name="l00373"></a>00373 <a class="code" href="a00069.html#r1">_targetIsProxy</a>=<span class="keyword">false</span>; <span class="comment">// Reset it just to be sure.</span>
<a name="l00374"></a>00374 }
<a name="l00375"></a>00375 }
<a name="l00376"></a>00376
<a name="l00377"></a>00377
<a name="l00378"></a><a class="code" href="a00069.html#a6">00378</a> <span class="keywordtype">void</span> <a class="code" href="a00069.html#a6">ProxyPushSupplier_i::reincarnate</a>(
<a name="l00379"></a>00379 <span class="keyword">const</span> string& oid,
<a name="l00380"></a>00380 <span class="keyword">const</span> <a class="code" href="a00060.html">PersistNode</a>& node
<a name="l00381"></a>00381 )
<a name="l00382"></a>00382 {
<a name="l00383"></a>00383 <span class="keywordflow">try</span>
<a name="l00384"></a>00384 {
<a name="l00385"></a>00385 <span class="keyword">using</span> <span class="keyword">namespace </span>CosEventChannelAdmin;
<a name="l00386"></a>00386
<a name="l00387"></a>00387 string ior( node.<a class="code" href="a00060.html#a11">attrString</a>(<span class="stringliteral">"IOR"</span>).c_str() );
<a name="l00388"></a>00388 CosEventComm::PushConsumer_var pushConsumer =
<a name="l00389"></a>00389 string_to_<CosEventComm::PushConsumer>(ior.c_str());
<a name="l00390"></a>00390 <span class="comment">// Do not activate until we know that we have read a valid target.</span>
<a name="l00391"></a>00391 <a class="code" href="a00073.html#b1">activateObjectWithId</a>(oid.c_str());
<a name="l00392"></a>00392 _remove_ref();
<a name="l00393"></a>00393 <a class="code" href="a00069.html#r0">_target</a>=pushConsumer._retn();
<a name="l00394"></a>00394 <a class="code" href="a00069.html#r1">_targetIsProxy</a>=bool(node.<a class="code" href="a00060.html#a12">attrLong</a>(<span class="stringliteral">"proxy"</span>));
<a name="l00395"></a>00395
<a name="l00396"></a>00396 <span class="comment">// If pushConsumer is a proxy, then try to reconnect.</span>
<a name="l00397"></a>00397 <span class="keywordflow">if</span>(<a class="code" href="a00069.html#r1">_targetIsProxy</a>)
<a name="l00398"></a>00398 {
<a name="l00399"></a>00399 <a class="code" href="a00116.html#a2">DB</a>(15,<span class="stringliteral">"Attempting to reconnect ProxyPushSupplier: "</span><<oid.c_str())
<a name="l00400"></a>00400 <span class="comment">// This will only work if the proxy is implemented in the same way as</span>
<a name="l00401"></a>00401 <span class="comment">// omniEvents, so connect_() automatically creates a proxy.</span>
<a name="l00402"></a>00402 ProxyPushConsumer_var proxyCons =
<a name="l00403"></a>00403 string_to_<ProxyPushConsumer>(ior.c_str());
<a name="l00404"></a>00404 CosEventComm::PushSupplier_var thisSupp =_this();
<a name="l00405"></a>00405 proxyCons->connect_push_supplier(thisSupp);
<a name="l00406"></a>00406 <a class="code" href="a00116.html#a2">DB</a>(7,<span class="stringliteral">"Reconnected ProxyPushSupplier: "</span><<oid.c_str())
<a name="l00407"></a>00407 }
<a name="l00408"></a>00408 }
<a name="l00409"></a>00409 <span class="keywordflow">catch</span>(CosEventChannelAdmin::AlreadyConnected&){ <span class="comment">// connect_push_supplier()</span>
<a name="l00410"></a>00410 <span class="comment">// The supplier doesn't need to be reconnected.</span>
<a name="l00411"></a>00411 <a class="code" href="a00116.html#a2">DB</a>(7,<span class="stringliteral">"Remote ProxyPushConsumer already connected: "</span><<oid.c_str())
<a name="l00412"></a>00412 }
<a name="l00413"></a>00413 <span class="keywordflow">catch</span>(CosEventChannelAdmin::TypeError&){ <span class="comment">// connect_push_supplier()</span>
<a name="l00414"></a>00414 <span class="comment">// Don't know what to make of this...</span>
<a name="l00415"></a>00415 <a class="code" href="a00116.html#a2">DB</a>(2,<span class="stringliteral">"Remote ProxyPushConsumer threw TypeError: "</span><<oid.c_str())
<a name="l00416"></a>00416 }
<a name="l00417"></a>00417 <span class="keywordflow">catch</span>(CORBA::OBJECT_NOT_EXIST&) {} <span class="comment">// object 'pushConsumer' not responding.</span>
<a name="l00418"></a>00418 <span class="keywordflow">catch</span>(CORBA::TRANSIENT& ) {} <span class="comment">// object 'pushConsumer' not responding.</span>
<a name="l00419"></a>00419 <span class="keywordflow">catch</span>(CORBA::COMM_FAILURE& ) {} <span class="comment">// object 'pushConsumer' not responding.</span>
<a name="l00420"></a>00420 }
<a name="l00421"></a>00421
<a name="l00422"></a>00422
<a name="l00423"></a><a class="code" href="a00069.html#a7">00423</a> <span class="keywordtype">void</span> <a class="code" href="a00069.html#a7">ProxyPushSupplier_i::output</a>(ostream &os)
<a name="l00424"></a>00424 {
<a name="l00425"></a>00425 <a class="code" href="a00061.html#b3">basicOutput</a>(
<a name="l00426"></a>00426 os,<span class="stringliteral">"ConsumerAdmin/ProxyPushSupplier"</span>,
<a name="l00427"></a>00427 <a class="code" href="a00069.html#r0">_target</a>.in(),
<a name="l00428"></a>00428 <a class="code" href="a00069.html#r1">_targetIsProxy</a>? <span class="stringliteral">" proxy=1"</span>: NULL
<a name="l00429"></a>00429 );
<a name="l00430"></a>00430 }
<a name="l00431"></a>00431
<a name="l00432"></a>00432
<a name="l00433"></a>00433 }; <span class="comment">// end namespace OmniEvents</span>
</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>
|
