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