|
version 1.25, 2004/10/17 20:39:56
|
version 1.27, 2005/01/27 22:24:22
|
|
|
|
| // | // |
| // Modified By: Dan Gorey (djgorey@us.ibm.com) | // Modified By: Dan Gorey (djgorey@us.ibm.com) |
| // Amit K Arora, IBM (amita@in.ibm.com) for PEP#183 | // Amit K Arora, IBM (amita@in.ibm.com) for PEP#183 |
| |
// Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com) |
| // | // |
| //%///////////////////////////////////////////////////////////////////////////// | //%///////////////////////////////////////////////////////////////////////////// |
| | |
|
|
|
| private: | private: |
| Uint32 _portNumber; | Uint32 _portNumber; |
| SSLContext* _sslContext; | SSLContext* _sslContext; |
| #ifdef PEGASUS_USE_23HTTPMONITOR_CLIENT |
|
| Monitor* _monitor; | Monitor* _monitor; |
| HTTPAcceptor* _acceptor; | HTTPAcceptor* _acceptor; |
| #else |
|
| monitor_2* _monitor; |
|
| pegasus_acceptor* _acceptor; |
|
| #endif |
|
| | |
| Boolean _dieNow; | Boolean _dieNow; |
| | |
|
|
|
| { | { |
| PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::init"); | PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::init"); |
| | |
| #ifdef PEGASUS_USE_23HTTPMONITOR_CLIENT |
_monitor = new Monitor(); |
| _monitor = new Monitor(true); |
|
| #else |
|
| _monitor = new monitor_2(); |
|
| #endif |
|
| | |
| //_dispatcher = new CIMListenerIndicationDispatcher(); | //_dispatcher = new CIMListenerIndicationDispatcher(); |
| | |
|
|
|
| _dispatcher, | _dispatcher, |
| _responseEncoder->getQueueId()); | _responseEncoder->getQueueId()); |
| | |
| #ifdef PEGASUS_USE_23HTTPMONITOR_CLIENT |
|
| _acceptor = new HTTPAcceptor( | _acceptor = new HTTPAcceptor( |
| _monitor, | _monitor, |
| _requestDecoder, | _requestDecoder, |
|
|
|
| _portNumber, | _portNumber, |
| _sslContext, | _sslContext, |
| false); | false); |
| #else |
|
| _acceptor = new pegasus_acceptor(_monitor, |
|
| _requestDecoder, |
|
| false, |
|
| _portNumber, |
|
| _sslContext); |
|
| #endif |
|
| | |
| bind(); | bind(); |
| | |
|
|
|
| | |
| if(!_dieNow) | if(!_dieNow) |
| { | { |
| #ifdef PEGASUS_USE_23HTTPMONITOR_CLIENT |
|
| if(false == _monitor->run(500000)) | if(false == _monitor->run(500000)) |
| { | { |
| modulator++; | modulator++; |
|
|
|
| handleShutdownSignal = false; | handleShutdownSignal = false; |
| } | } |
| */ | */ |
| #else |
|
| _monitor->run(); |
|
| #endif |
|
| } | } |
| } | } |
| | |
|
|
|
| PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::shutdown()"); | PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::shutdown()"); |
| | |
| _dieNow = true; | _dieNow = true; |
| #ifdef PEGASUS_USE_23HTTPMONITOR_CLIENT |
|
| _monitor->tickle(); | _monitor->tickle(); |
| #endif |
|
| | |
| PEG_METHOD_EXIT(); | PEG_METHOD_EXIT(); |
| } | } |
|
|
|
| PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::stopClientConnection()"); | PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::stopClientConnection()"); |
| | |
| // tell Monitor to stop listening for client connections | // tell Monitor to stop listening for client connections |
| #ifdef PEGASUS_USE_23HTTPMONITOR_CLIENT |
|
| _monitor->stopListeningForConnections(true); | _monitor->stopListeningForConnections(true); |
| #else |
|
| _monitor->stop(); |
|
| #endif |
|
| | |
| // | // |
| // Wait 150 milliseconds to allow time for the Monitor to stop | // Wait 150 milliseconds to allow time for the Monitor to stop |
Return to
CIMListener.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Listener