|
version 1.13, 2003/11/05 06:29:37
|
version 1.14, 2004/01/29 20:45:58
|
|
|
|
| // | // |
| // Author: Dong Xiang, EMC Corporation (xiang_dong@emc.com) | // Author: Dong Xiang, EMC Corporation (xiang_dong@emc.com) |
| // | // |
| // Modified By: |
// Modified By: Dan Gorey (djgorey@us.ibm.com) |
| // | // |
| //%///////////////////////////////////////////////////////////////////////////// | //%///////////////////////////////////////////////////////////////////////////// |
| | |
|
|
|
| private: | private: |
| Uint32 _portNumber; | Uint32 _portNumber; |
| SSLContext* _sslContext; | SSLContext* _sslContext; |
| |
#ifdef PEGASUS_USE_23HTTPMONITOR |
| Monitor* _monitor; | Monitor* _monitor; |
| HTTPAcceptor* _acceptor; | HTTPAcceptor* _acceptor; |
| |
#else |
| |
monitor_2* _monitor; |
| |
pegasus_acceptor* _acceptor; |
| |
#endif |
| |
|
| Boolean _dieNow; | Boolean _dieNow; |
| | |
| CIMListenerIndicationDispatcher* _dispatcher; | CIMListenerIndicationDispatcher* _dispatcher; |
|
|
|
| { | { |
| PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::init"); | PEG_METHOD_ENTER(TRC_LISTENER, "CIMListenerService::init"); |
| | |
| |
#ifdef PEGASUS_USE_23HTTPMONITOR |
| _monitor = new Monitor(true); | _monitor = new Monitor(true); |
| |
#else |
| |
_monitor = new monitor_2(); |
| |
#endif |
| |
|
| //_dispatcher = new CIMListenerIndicationDispatcher(); | //_dispatcher = new CIMListenerIndicationDispatcher(); |
| | |
| _responseEncoder = new CIMExportResponseEncoder(); | _responseEncoder = new CIMExportResponseEncoder(); |
|
|
|
| _dispatcher, | _dispatcher, |
| _responseEncoder->getQueueId()); | _responseEncoder->getQueueId()); |
| | |
| |
#ifdef PEGASUS_USE_23HTTPMONITOR |
| _acceptor = new HTTPAcceptor( | _acceptor = new HTTPAcceptor( |
| _monitor, | _monitor, |
| _requestDecoder, | _requestDecoder, |
| false, | false, |
| _portNumber, | _portNumber, |
| _sslContext); | _sslContext); |
| |
#else |
| |
_acceptor = new pegasus_acceptor(_monitor, |
| |
_requestDecoder, |
| |
false, |
| |
_portNumber, |
| |
_sslContext); |
| |
#endif |
| | |
| bind(); | bind(); |
| | |
|
|
|
| | |
| if(!_dieNow) | if(!_dieNow) |
| { | { |
| |
#ifdef PEGASUS_USE_23HTTPMONITOR |
| if(false == _monitor->run(100)) | if(false == _monitor->run(100)) |
| { | { |
| modulator++; | modulator++; |
|
|
|
| handleShutdownSignal = false; | handleShutdownSignal = false; |
| } | } |
| */ | */ |
| |
#else |
| |
_monitor->run(); |
| |
#endif |
| } | } |
| } | } |
| | |
|
|
|
| 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 |
| _monitor->stopListeningForConnections(); | _monitor->stopListeningForConnections(); |
| |
#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