version 1.33, 2005/05/01 04:28:55
|
version 1.34, 2005/05/03 13:10:46
|
|
|
| |
/** Return true if the server has shutdown, false otherwise. | /** Return true if the server has shutdown, false otherwise. |
*/ | */ |
Boolean terminated() { return _dieNow; }; |
Boolean terminated() const { return _dieNow; }; |
| |
/** Call to resume the sever. | /** Call to resume the sever. |
*/ | */ |
|
|
*/ | */ |
void setIndicationDispatcher(CIMListenerIndicationDispatcher* dispatcher); | void setIndicationDispatcher(CIMListenerIndicationDispatcher* dispatcher); |
| |
|
/** Returns the port number being used. |
|
*/ |
|
Uint32 getPortNumber() const; |
|
|
static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _listener_routine(void *param); | static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _listener_routine(void *param); |
| |
private: | private: |
|
|
| |
PEG_METHOD_EXIT(); | PEG_METHOD_EXIT(); |
} | } |
|
|
void CIMListenerService::bind() | void CIMListenerService::bind() |
{ | { |
if(_acceptor!=NULL) | if(_acceptor!=NULL) |
|
|
{ | { |
return _dispatcher; | return _dispatcher; |
} | } |
|
|
void CIMListenerService::setIndicationDispatcher(CIMListenerIndicationDispatcher* dispatcher) | void CIMListenerService::setIndicationDispatcher(CIMListenerIndicationDispatcher* dispatcher) |
{ | { |
_dispatcher = dispatcher; | _dispatcher = dispatcher; |
} | } |
| |
|
Uint32 CIMListenerService::getPortNumber() const |
|
{ |
|
|
|
Uint32 portNumber = _portNumber; |
|
|
|
if (( portNumber == 0 ) && ( _acceptor != 0 )) |
|
{ |
|
portNumber = _acceptor->getPortNumber(); |
|
} |
|
|
|
return(portNumber); |
|
} |
|
|
PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL CIMListenerService::_listener_routine(void *param) | PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL CIMListenerService::_listener_routine(void *param) |
{ | { |
AutoPtr<CIMListenerService> svc(reinterpret_cast<CIMListenerService *>(param)); | AutoPtr<CIMListenerService> svc(reinterpret_cast<CIMListenerService *>(param)); |
|
|
| |
Uint32 CIMListenerRep::getPortNumber() const | Uint32 CIMListenerRep::getPortNumber() const |
{ | { |
return _portNumber; |
Uint32 portNumber; |
|
|
|
if ( _svc == 0 ) |
|
{ |
|
portNumber = _portNumber; |
|
} |
|
else portNumber = _svc->getPortNumber(); |
|
|
|
return portNumber; |
} | } |
| |
SSLContext* CIMListenerRep::getSSLContext() const | SSLContext* CIMListenerRep::getSSLContext() const |
|
|
{ | { |
_listener_sem->time_wait(3000); | _listener_sem->time_wait(3000); |
} | } |
catch (TimeOut &) |
catch (const TimeOut &) |
{ | { |
// No need to do anything, the thread pool will be deleted below | // No need to do anything, the thread pool will be deleted below |
// to cancel the _listener_routine thread if it is still running. | // to cancel the _listener_routine thread if it is still running. |