1 karl 1.28 //%2005////////////////////////////////////////////////////////////////////////
|
2 kumpf 1.1 //
|
3 karl 1.25 // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
4 // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
5 // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;
|
6 karl 1.12 // IBM Corp.; EMC Corporation, The Open Group.
|
7 karl 1.25 // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
8 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
|
9 karl 1.28 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
10 // EMC Corporation; VERITAS Software Corporation; The Open Group.
|
11 kumpf 1.1 //
12 // Permission is hereby granted, free of charge, to any person obtaining a copy
13 // of this software and associated documentation files (the "Software"), to
14 // deal in the Software without restriction, including without limitation the
15 // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
16 // sell copies of the Software, and to permit persons to whom the Software is
17 // furnished to do so, subject to the following conditions:
|
18 david.dillard 1.31 //
|
19 kumpf 1.1 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
20 // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
21 // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
22 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
23 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
24 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
25 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
26 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
27 //
28 //==============================================================================
29 //
|
30 tony 1.8 // Author: Dong Xiang, EMC Corporation (xiang_dong@emc.com)
|
31 kumpf 1.1 //
|
32 dj.gorey 1.14 // Modified By: Dan Gorey (djgorey@us.ibm.com)
|
33 a.arora 1.21 // Amit K Arora, IBM (amita@in.ibm.com) for PEP#183
|
34 kumpf 1.26 // Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com)
|
35 david.dillard 1.31 // David Dillard, VERITAS Software Corp.
36 // (david.dillard@veritas.com)
|
37 vijay.eli 1.33 // Vijay Eli, IBM (vijay.eli@in.ibm.com) for bug#3425
|
38 aruran.ms 1.35 // Aruran, IBM (ashanmug@in.ibm.com) for Bug# 3604
|
39 kumpf 1.1 //
40 //%/////////////////////////////////////////////////////////////////////////////
41
|
42 tony 1.8 #include "CIMListener.h"
|
43 kumpf 1.1
|
44 tony 1.8 #include <Pegasus/Common/Exception.h>
45 #include <Pegasus/Common/SSLContext.h>
46 #include <Pegasus/Common/Monitor.h>
|
47 kumpf 1.1 #include <Pegasus/Common/HTTPAcceptor.h>
|
48 kumpf 1.11 #include <Pegasus/Common/PegasusVersion.h>
|
49 kumpf 1.2
|
50 kumpf 1.1 #include <Pegasus/ExportServer/CIMExportResponseEncoder.h>
51 #include <Pegasus/ExportServer/CIMExportRequestDecoder.h>
52
|
53 tony 1.8 #include <Pegasus/Consumer/CIMIndicationConsumer.h>
54 #include <Pegasus/Listener/CIMListenerIndicationDispatcher.h>
55
56 PEGASUS_NAMESPACE_BEGIN
57 /////////////////////////////////////////////////////////////////////////////
58 // CIMListenerService
59 /////////////////////////////////////////////////////////////////////////////
60 class CIMListenerService
61 {
62 public:
63 CIMListenerService(Uint32 portNumber, SSLContext* sslContext=NULL);
64 CIMListenerService(CIMListenerService& svc);
65 ~CIMListenerService();
66
67 void init();
68 /** bind to the port
69 */
70 void bind();
71 /** runForever Main runloop for the server.
72 */
73 void runForever();
|
74 david.dillard 1.31
|
75 tony 1.8 /** Call to gracefully shutdown the server. The server connection socket
76 will be closed to disable new connections from clients.
77 */
78 void stopClientConnection();
|
79 david.dillard 1.31
|
80 tony 1.8 /** Call to gracefully shutdown the server. It is called when the server
81 has been stopped and is ready to be shutdown. Next time runForever()
82 is called, the server shuts down.
83 */
84 void shutdown();
|
85 david.dillard 1.31
|
86 tony 1.8 /** Return true if the server has shutdown, false otherwise.
87 */
|
88 david.dillard 1.34 Boolean terminated() const { return _dieNow; };
|
89 david.dillard 1.31
|
90 tony 1.8 /** Call to resume the sever.
91 */
92 void resume();
|
93 david.dillard 1.31
|
94 tony 1.8 /** Call to set the CIMServer state. Also inform the appropriate
95 message queues about the current state of the CIMServer.
96 */
97 void setState(Uint32 state);
|
98 david.dillard 1.31
|
99 tony 1.8 Uint32 getOutstandingRequestCount();
100
101 /** Returns the indication listener dispatcher
102 */
103 CIMListenerIndicationDispatcher* getIndicationDispatcher() const;
104
|
105 david.dillard 1.34 /** Returns the indication listener dispatcher
|
106 tony 1.8 */
107 void setIndicationDispatcher(CIMListenerIndicationDispatcher* dispatcher);
108
|
109 david.dillard 1.34 /** Returns the port number being used.
110 */
111 Uint32 getPortNumber() const;
112
|
113 tony 1.8 static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _listener_routine(void *param);
114
115 private:
|
116 david.dillard 1.34 Uint32 _portNumber;
|
117 tony 1.8 SSLContext* _sslContext;
|
118 david.dillard 1.34 Monitor* _monitor;
119 HTTPAcceptor* _acceptor;
|
120 dj.gorey 1.14
121 Boolean _dieNow;
|
122 tony 1.8
123 CIMListenerIndicationDispatcher* _dispatcher;
124
125 CIMExportResponseEncoder* _responseEncoder;
126 CIMExportRequestDecoder* _requestDecoder;
127
128 };
129
130 CIMListenerService::CIMListenerService(Uint32 portNumber, SSLContext* sslContext)
131 :_portNumber(portNumber)
132 ,_sslContext(sslContext)
133 ,_monitor(NULL)
134 ,_acceptor(NULL)
135 ,_dieNow(false)
136 ,_dispatcher(NULL)
137 ,_responseEncoder(NULL)
138 ,_requestDecoder(NULL)
139 {
140 }
141
142 CIMListenerService::CIMListenerService(CIMListenerService& svc)
143 tony 1.8 :_portNumber(svc._portNumber)
144 ,_sslContext(svc._sslContext)
145 ,_monitor(NULL)
146 ,_acceptor(NULL)
147 ,_dieNow(svc._dieNow)
148 ,_dispatcher(NULL)
149 ,_responseEncoder(NULL)
150 ,_requestDecoder(NULL)
151 {
152 }
153 CIMListenerService::~CIMListenerService()
154 {
|
155 kumpf 1.36 // if port is alive, clean up the port
156 //delete _sslContext;
|
157 tony 1.8
|
158 kumpf 1.36 delete _responseEncoder;
|
159 tony 1.8
|
160 kumpf 1.36 delete _requestDecoder;
|
161 kumpf 1.1
|
162 kumpf 1.36 //delete _dispatcher;
|
163 kumpf 1.1
|
164 kumpf 1.36 delete _acceptor;
|
165 kumpf 1.1
|
166 kumpf 1.36 delete _monitor;
|
167 tony 1.8 }
|
168 kumpf 1.1
|
169 tony 1.8 void CIMListenerService::init()
|
170 kumpf 1.1 {
|
171 tony 1.8 PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::init");
|
172 kumpf 1.1
|
173 vijay.eli 1.33 if(NULL == _monitor) _monitor = new Monitor();
|
174 david.dillard 1.31
|
175 tony 1.8 //_dispatcher = new CIMListenerIndicationDispatcher();
|
176 kumpf 1.1
|
177 vijay.eli 1.33 if(NULL == _responseEncoder) _responseEncoder = new CIMExportResponseEncoder();
178 if(NULL == _requestDecoder) _requestDecoder = new CIMExportRequestDecoder(
179 _dispatcher,_responseEncoder->getQueueId());
|
180 tony 1.8
|
181 vijay.eli 1.33 if(NULL == _acceptor) _acceptor = new HTTPAcceptor(
|
182 david.dillard 1.31 _monitor,
183 _requestDecoder,
184 false,
185 _portNumber,
|
186 kumpf 1.19 _sslContext,
187 false);
|
188 kumpf 1.1
|
189 chuck 1.20 bind();
|
190 kumpf 1.1
|
191 chuck 1.20 PEG_METHOD_EXIT();
|
192 tony 1.8 }
|
193 david.dillard 1.34
|
194 tony 1.8 void CIMListenerService::bind()
195 {
|
196 chuck 1.20 if(_acceptor!=NULL)
197 { // Bind to the port
198 _acceptor->bind();
|
199 tony 1.8
|
200 chuck 1.20 PEGASUS_STD(cout) << "Listening on HTTP port " << _portNumber << PEGASUS_STD(endl);
|
201 david.dillard 1.31
|
202 chuck 1.20 //listener.addAcceptor(false, portNumberHttp, false);
203 Logger::put(Logger::STANDARD_LOG, System::CIMLISTENER, Logger::INFORMATION,
|
204 tony 1.8 "Listening on HTTP port $0.", _portNumber);
|
205 kumpf 1.1
|
206 chuck 1.20 }
|
207 tony 1.8 }
|
208 chuck 1.20
|
209 tony 1.8 void CIMListenerService::runForever()
210 {
|
211 chuck 1.20 static int modulator = 0;
|
212 kumpf 1.1
|
213 chuck 1.20 if(!_dieNow)
|
214 dj.gorey 1.14 {
|
215 david.dillard 1.31 if(false == _monitor->run(500000))
216 {
|
217 chuck 1.20 modulator++;
|
218 david.dillard 1.31 try
|
219 a.arora 1.21 {
220 //MessageQueueService::_check_idle_flag = 1;
221 //MessageQueueService::_polling_sem.signal();
|
222 kumpf 1.30 MessageQueueService::get_thread_pool()->cleanupIdleThreads();
|
223 a.arora 1.21 }
224 catch(...)
225 {
226 }
|
227 chuck 1.20 }
228 /*
229 if (handleShutdownSignal)
230 {
231 Tracer::trace(TRC_SERVER, Tracer::LEVEL3,
232 "CIMServer::runForever - signal received. Shutting down.");
233
234 ShutdownService::getInstance(this)->shutdown(true, 10, false);
235 handleShutdownSignal = false;
236 }
|
237 tony 1.8 */
|
238 chuck 1.20 }
|
239 tony 1.8 }
|
240 kumpf 1.1
|
241 tony 1.8 void CIMListenerService::shutdown()
242 {
243 PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::shutdown()");
|
244 kumpf 1.1
|
245 tony 1.8 _dieNow = true;
|
246 a.arora 1.21 _monitor->tickle();
|
247 kumpf 1.1
|
248 kumpf 1.4 PEG_METHOD_EXIT();
|
249 kumpf 1.1 }
250
|
251 tony 1.8 void CIMListenerService::resume()
|
252 kumpf 1.1 {
|
253 tony 1.8 PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::resume()");
|
254 kumpf 1.1
|
255 tony 1.8 if(_acceptor!=NULL)
256 _acceptor->reopenConnectionSocket();
|
257 kumpf 1.1
|
258 kumpf 1.4 PEG_METHOD_EXIT();
|
259 kumpf 1.1 }
260
|
261 tony 1.8 void CIMListenerService::stopClientConnection()
|
262 kumpf 1.1 {
|
263 tony 1.8 PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::stopClientConnection()");
|
264 kumpf 1.1
|
265 kumpf 1.10 // tell Monitor to stop listening for client connections
|
266 chuck 1.22 _monitor->stopListeningForConnections(true);
|
267 kumpf 1.10
268 //
269 // Wait 150 milliseconds to allow time for the Monitor to stop
270 // listening for client connections.
271 //
272 // This wait time is the timeout value for the select() call
273 // in the Monitor's run() method (currently set to 100
274 // milliseconds) plus a delta of 50 milliseconds. The reason
275 // for the wait here is to make sure that the Monitor entries
276 // are updated before closing the connection sockets.
277 //
|
278 a.arora 1.21 // pegasus_sleep(150); Not needed now due to the semaphore in the Monitor
|
279 david.dillard 1.31
|
280 tony 1.8 if(_acceptor!=NULL)
281 _acceptor->closeConnectionSocket();
|
282 kumpf 1.1
|
283 kumpf 1.4 PEG_METHOD_EXIT();
|
284 kumpf 1.1 }
285
|
286 chuck 1.23 Uint32 CIMListenerService::getOutstandingRequestCount()
287 {
288 return _acceptor->getOutstandingRequestCount();
289 }
|
290 tony 1.8
291 CIMListenerIndicationDispatcher* CIMListenerService::getIndicationDispatcher() const
|
292 kumpf 1.1 {
|
293 david.dillard 1.32 return _dispatcher;
|
294 tony 1.8 }
|
295 david.dillard 1.34
|
296 tony 1.8 void CIMListenerService::setIndicationDispatcher(CIMListenerIndicationDispatcher* dispatcher)
297 {
|
298 david.dillard 1.32 _dispatcher = dispatcher;
|
299 kumpf 1.1 }
300
|
301 david.dillard 1.34 Uint32 CIMListenerService::getPortNumber() const
302 {
303
304 Uint32 portNumber = _portNumber;
305
306 if (( portNumber == 0 ) && ( _acceptor != 0 ))
307 {
308 portNumber = _acceptor->getPortNumber();
309 }
310
311 return(portNumber);
312 }
313
|
314 tony 1.8 PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL CIMListenerService::_listener_routine(void *param)
|
315 kumpf 1.1 {
|
316 konrad.r 1.37 try {
|
317 david.dillard 1.32 AutoPtr<CIMListenerService> svc(reinterpret_cast<CIMListenerService *>(param));
|
318 kumpf 1.1
|
319 david.dillard 1.32 //svc->init(); bug 1394
320 while(!svc->terminated())
321 {
|
322 chuck 1.20 #if defined(PEGASUS_PLATFORM_DARWIN_PPC_GNU)
|
323 david.dillard 1.32 pthread_testcancel();
|
324 chuck 1.20 #endif
|
325 david.dillard 1.32 svc->runForever();
326 }
|
327 konrad.r 1.37 } catch (...)
328 {
329 Tracer::trace(TRC_SERVER, Tracer::LEVEL2,
330 "Unknown exception thrown in _listener_routine.");
331 }
|
332 david.dillard 1.32 return 0;
|
333 tony 1.8 }
334
335 /////////////////////////////////////////////////////////////////////////////
336 // CIMListenerRep
337 /////////////////////////////////////////////////////////////////////////////
338 class CIMListenerRep
339 {
340 public:
341 CIMListenerRep(Uint32 portNumber, SSLContext* sslContext=NULL);
342 ~CIMListenerRep();
343
344 Uint32 getPortNumber() const;
345
346 SSLContext* getSSLContext() const;
347 void setSSLContext(SSLContext* sslContext);
|
348 david.dillard 1.31
|
349 tony 1.8 void start();
350 void stop();
351
352 Boolean isAlive();
353
354 Boolean addConsumer(CIMIndicationConsumer* consumer);
355 Boolean removeConsumer(CIMIndicationConsumer* consumer);
356
357 private:
|
358 chuck 1.23 Boolean waitForPendingRequests(Uint32 shutdownTimeout);
359
360 Uint32 _portNumber;
361 SSLContext* _sslContext;
|
362 tony 1.8
363 CIMListenerIndicationDispatcher* _dispatcher;
|
364 chuck 1.23 ThreadPool* _thread_pool;
|
365 david.dillard 1.31 CIMListenerService* _svc;
|
366 chuck 1.20 Semaphore *_listener_sem;
|
367 tony 1.8 };
368
369 CIMListenerRep::CIMListenerRep(Uint32 portNumber, SSLContext* sslContext)
370 :_portNumber(portNumber)
371 ,_sslContext(sslContext)
372 ,_dispatcher(new CIMListenerIndicationDispatcher())
373 ,_thread_pool(NULL)
|
374 chuck 1.20 ,_svc(NULL)
375 ,_listener_sem(NULL)
|
376 tony 1.8 {
377 }
|
378 david.dillard 1.31
|
379 tony 1.8 CIMListenerRep::~CIMListenerRep()
380 {
|
381 david.dillard 1.31 // if port is alive, clean up the port
382 if (_thread_pool != 0)
383 {
384 // Block incoming export requests and unbind the port
385 _svc->stopClientConnection();
386
387 // Wait until pending export requests in the server are done.
388 waitForPendingRequests(10);
|
389 chuck 1.23
|
390 david.dillard 1.31 // Shutdown the CIMListenerService
391 _svc->shutdown();
392 }
|
393 chuck 1.20
394 delete _sslContext;
395 delete _dispatcher;
396 delete _thread_pool;
397 delete _listener_sem;
|
398 tony 1.8
|
399 chuck 1.20 // don't delete _svc, this is deleted by _listener_routine
|
400 tony 1.8 }
401
402 Uint32 CIMListenerRep::getPortNumber() const
403 {
|
404 david.dillard 1.34 Uint32 portNumber;
405
406 if ( _svc == 0 )
407 {
408 portNumber = _portNumber;
409 }
410 else portNumber = _svc->getPortNumber();
411
412 return portNumber;
|
413 tony 1.8 }
|
414 kumpf 1.1
|
415 tony 1.8 SSLContext* CIMListenerRep::getSSLContext() const
416 {
|
417 david.dillard 1.31 return _sslContext;
|
418 kumpf 1.1 }
|
419 david.dillard 1.31
|
420 tony 1.8 void CIMListenerRep::setSSLContext(SSLContext* sslContext)
421 {
|
422 david.dillard 1.31 delete _sslContext;
423 _sslContext = sslContext;
424 }
|
425 kumpf 1.1
|
426 tony 1.8 void CIMListenerRep::start()
|
427 kumpf 1.1 {
|
428 david.dillard 1.31 // spawn a thread to do this
429 if(_thread_pool==0)
|
430 chuck 1.20 {
|
431 david.dillard 1.31 AutoPtr<CIMListenerService> svc(new CIMListenerService(_portNumber,_sslContext));
|
432 chuck 1.20
|
433 david.dillard 1.31 svc->setIndicationDispatcher(_dispatcher);
434 svc->init();
|
435 chuck 1.20
|
436 david.dillard 1.31 struct timeval deallocateWait = {15, 0};
437 AutoPtr<ThreadPool> threadPool(new ThreadPool(0, "Listener", 0, 1, deallocateWait));
438 AutoPtr<Semaphore> sem(new Semaphore(0));
439 threadPool->allocate_and_awaken(svc.get(), CIMListenerService::_listener_routine, sem.get());
440 Logger::put(Logger::STANDARD_LOG,System::CIMLISTENER, Logger::INFORMATION,
441 "CIMListener started");
442
443 PEGASUS_STD(cerr) << "CIMlistener started" << PEGASUS_STD(endl);
444
445 _svc = svc.release();
446 _thread_pool = threadPool.release();
447 _listener_sem = sem.release();
448 }
|
449 tony 1.8 }
|
450 kumpf 1.1
|
451 tony 1.8 void CIMListenerRep::stop()
452 {
|
453 chuck 1.20 if(_thread_pool!=NULL)
|
454 david.dillard 1.31 {
|
455 chuck 1.20 //
456 // Graceful shutdown of the listener service
457 //
458
459 // Block incoming export requests and unbind the port
460 _svc->stopClientConnection();
|
461 chuck 1.23
462 // Wait until pending export requests in the server are done.
|
463 chuck 1.24 waitForPendingRequests(10);
|
464 david.dillard 1.31
|
465 chuck 1.20 // Shutdown the CIMListenerService
466 _svc->shutdown();
467
468 // Wait for the _listener_routine thread to exit.
469 // The thread could be delivering an export, so give it 3sec.
470 // Note that _listener_routine deletes the CIMListenerService,
471 // so no need to delete _svc.
472 try
473 {
|
474 david.dillard 1.31 _listener_sem->time_wait(3000);
|
475 chuck 1.20 }
|
476 david.dillard 1.34 catch (const TimeOut &)
|
477 chuck 1.20 {
478 // No need to do anything, the thread pool will be deleted below
479 // to cancel the _listener_routine thread if it is still running.
480 }
481
482 delete _listener_sem;
483 _listener_sem = NULL;
|
484 david.dillard 1.31
|
485 chuck 1.20 // Delete the thread pool. This cancels the listener thread if it is still
486 // running.
487 delete _thread_pool;
488 _thread_pool = NULL;
489
490 Logger::put(Logger::STANDARD_LOG,System::CIMLISTENER,
491 Logger::INFORMATION,
492 "CIMListener stopped");
493 }
|
494 kumpf 1.1 }
495
|
496 tony 1.8 Boolean CIMListenerRep::isAlive()
|
497 kumpf 1.1 {
|
498 tony 1.8 return (_thread_pool!=NULL)?true:false;
499 }
|
500 kumpf 1.1
|
501 tony 1.8 Boolean CIMListenerRep::addConsumer(CIMIndicationConsumer* consumer)
502 {
503 return _dispatcher->addConsumer(consumer);
504 }
505 Boolean CIMListenerRep::removeConsumer(CIMIndicationConsumer* consumer)
506 {
507 return _dispatcher->removeConsumer(consumer);
508 }
|
509 kumpf 1.1
|
510 chuck 1.23 Boolean CIMListenerRep::waitForPendingRequests(Uint32 shutdownTimeout)
511 {
512 // Wait for 10 sec max
513 Uint32 reqCount;
514 Uint32 countDown = shutdownTimeout * 10;
515 for (; countDown > 0; countDown--)
516 {
517 reqCount = _svc->getOutstandingRequestCount();
518 if (reqCount > 0)
519 pegasus_sleep(100);
520 else
521 return true;
522 }
|
523 david.dillard 1.31
|
524 chuck 1.23 return false;
|
525 david.dillard 1.31 }
|
526 chuck 1.23
|
527 tony 1.8 /////////////////////////////////////////////////////////////////////////////
528 // CIMListener
529 /////////////////////////////////////////////////////////////////////////////
530 CIMListener::CIMListener(Uint32 portNumber, SSLContext* sslContext)
531 :_rep(new CIMListenerRep(portNumber,sslContext))
532 {
533 }
534 CIMListener::~CIMListener()
535 {
536 if(_rep!=NULL)
|
537 tony 1.9 delete static_cast<CIMListenerRep*>(_rep);
|
538 tony 1.8 _rep=NULL;
539 }
|
540 david.dillard 1.31
|
541 tony 1.8 Uint32 CIMListener::getPortNumber() const
542 {
543 return static_cast<CIMListenerRep*>(_rep)->getPortNumber();
|
544 kumpf 1.1 }
545
|
546 tony 1.8 SSLContext* CIMListener::getSSLContext() const
547 {
548 return static_cast<CIMListenerRep*>(_rep)->getSSLContext();
549 }
550 void CIMListener::setSSLContext(SSLContext* sslContext)
551 {
552 static_cast<CIMListenerRep*>(_rep)->setSSLContext(sslContext);
553 }
554 void CIMListener::start()
|
555 kumpf 1.1 {
|
556 tony 1.8 static_cast<CIMListenerRep*>(_rep)->start();
557 }
558 void CIMListener::stop()
559 {
560 static_cast<CIMListenerRep*>(_rep)->stop();
561 }
|
562 kumpf 1.1
|
563 aruran.ms 1.35 Boolean CIMListener::isAlive() const
|
564 tony 1.8 {
565 return static_cast<CIMListenerRep*>(_rep)->isAlive();
566 }
|
567 kumpf 1.1
|
568 tony 1.8 Boolean CIMListener::addConsumer(CIMIndicationConsumer* consumer)
569 {
570 return static_cast<CIMListenerRep*>(_rep)->addConsumer(consumer);
571 }
572 Boolean CIMListener::removeConsumer(CIMIndicationConsumer* consumer)
573 {
574 return static_cast<CIMListenerRep*>(_rep)->removeConsumer(consumer);
|
575 kumpf 1.1 }
576
577 PEGASUS_NAMESPACE_END
|
Return to
CIMListener.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Listener