version 1.131, 2008/12/16 18:56:00
|
version 1.132, 2012/07/03 11:53:22
|
|
|
Uint16 connectionType, | Uint16 connectionType, |
Uint32 portNumber, | Uint32 portNumber, |
SSLContext * sslcontext, | SSLContext * sslcontext, |
ReadWriteSem* sslContextObjectLock) |
ReadWriteSem* sslContextObjectLock, |
|
HostAddress *listenOn) |
: Base(PEGASUS_QUEUENAME_HTTPACCEPTOR), // ATTN: Need unique names? | : Base(PEGASUS_QUEUENAME_HTTPACCEPTOR), // ATTN: Need unique names? |
_monitor(monitor), | _monitor(monitor), |
_outputMessageQueue(outputMessageQueue), | _outputMessageQueue(outputMessageQueue), |
|
|
_connectionType(connectionType), | _connectionType(connectionType), |
_portNumber(portNumber), | _portNumber(portNumber), |
_sslcontext(sslcontext), | _sslcontext(sslcontext), |
_sslContextObjectLock(sslContextObjectLock) |
_sslContextObjectLock(sslContextObjectLock), |
|
_listenAddress(listenOn) |
{ | { |
PEGASUS_ASSERT(!_sslcontext == !_sslContextObjectLock); | PEGASUS_ASSERT(!_sslcontext == !_sslContextObjectLock); |
Socket::initializeInterface(); | Socket::initializeInterface(); |
|
|
_bind(); | _bind(); |
} | } |
| |
|
|
/** | /** |
_bind - creates a new server socket and bind socket to the port address. | _bind - creates a new server socket and bind socket to the port address. |
If PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET is not defined, the port number is | If PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET is not defined, the port number is |
|
|
#ifdef PEGASUS_ENABLE_IPV6 | #ifdef PEGASUS_ENABLE_IPV6 |
else if (_connectionType == IPV6_CONNECTION) | else if (_connectionType == IPV6_CONNECTION) |
{ | { |
|
if(_listenAddress) |
|
{ |
|
String hostAdd = _listenAddress->getHost(); |
|
CString ip = hostAdd.getCString(); |
|
|
|
struct sockaddr_in6 in6addr; |
|
memset(&in6addr, 0, sizeof(sockaddr_in6)); |
|
if(_listenAddress ->isHostAddLinkLocal()) |
|
{ |
|
::inet_pton(AF_INET6, |
|
(const char*)ip, |
|
&in6addr.sin6_addr); |
|
reinterpret_cast<struct sockaddr_in6*>( |
|
_rep->address)->sin6_addr = in6addr.sin6_addr; |
|
reinterpret_cast<struct sockaddr_in6*>( |
|
_rep->address)->sin6_scope_id = |
|
_listenAddress->getScopeID(); |
|
} |
|
else |
|
{ |
|
::inet_pton(AF_INET6, |
|
(const char*)ip, |
|
&in6addr.sin6_addr); |
|
reinterpret_cast<struct sockaddr_in6*>( |
|
_rep->address)->sin6_addr = in6addr.sin6_addr; |
|
} |
|
} |
|
else |
|
{ |
reinterpret_cast<struct sockaddr_in6*>(_rep->address)->sin6_addr = | reinterpret_cast<struct sockaddr_in6*>(_rep->address)->sin6_addr = |
in6addr_any; | in6addr_any; |
|
} |
reinterpret_cast<struct sockaddr_in6*>(_rep->address)->sin6_family = | reinterpret_cast<struct sockaddr_in6*>(_rep->address)->sin6_family = |
AF_INET6; | AF_INET6; |
reinterpret_cast<struct sockaddr_in6*>(_rep->address)->sin6_port = | reinterpret_cast<struct sockaddr_in6*>(_rep->address)->sin6_port = |
|
|
#endif | #endif |
else if(_connectionType == IPV4_CONNECTION) | else if(_connectionType == IPV4_CONNECTION) |
{ | { |
reinterpret_cast<struct sockaddr_in*>(_rep->address)->sin_addr.s_addr = |
if(_listenAddress) |
INADDR_ANY; |
{ |
|
String hostAdd = _listenAddress->getHost(); |
|
CString ip = hostAdd.getCString(); |
|
struct sockaddr_in addrs; |
|
::inet_pton( |
|
AF_INET, |
|
(const char*)ip, |
|
&addrs.sin_addr); |
|
reinterpret_cast<struct sockaddr_in*>( |
|
_rep->address)->sin_addr.s_addr = addrs.sin_addr.s_addr; |
|
} |
|
else |
|
{ |
|
reinterpret_cast<struct sockaddr_in*>( |
|
_rep->address)->sin_addr.s_addr = INADDR_ANY; |
|
} |
reinterpret_cast<struct sockaddr_in*>(_rep->address)->sin_family = | reinterpret_cast<struct sockaddr_in*>(_rep->address)->sin_family = |
AF_INET; | AF_INET; |
reinterpret_cast<struct sockaddr_in*>(_rep->address)->sin_port = | reinterpret_cast<struct sockaddr_in*>(_rep->address)->sin_port = |
|
|
{ | { |
MessageLoaderParms parms( | MessageLoaderParms parms( |
"Common.HTTPAcceptor.FAILED_SET_LDS_FILE_OPTION", | "Common.HTTPAcceptor.FAILED_SET_LDS_FILE_OPTION", |
"Failed to set permission on local domain socket {0}: {1}.", |
"Failed to set permission on local domain socket $0: $1.", |
PEGASUS_LOCAL_DOMAIN_SOCKET_PATH, | PEGASUS_LOCAL_DOMAIN_SOCKET_PATH, |
PEGASUS_SYSTEM_ERRORMSG_NLS ); | PEGASUS_SYSTEM_ERRORMSG_NLS ); |
| |
|
|
{ | { |
MessageLoaderParms parms( | MessageLoaderParms parms( |
"Common.HTTPAcceptor.FAILED_LISTEN_SOCKET", | "Common.HTTPAcceptor.FAILED_LISTEN_SOCKET", |
"Failed to listen on socket {0}: {1}.", |
"Failed to listen on socket $0: $1.", |
(int)_rep->socket,PEGASUS_SYSTEM_NETWORK_ERRORMSG_NLS ); | (int)_rep->socket,PEGASUS_SYSTEM_NETWORK_ERRORMSG_NLS ); |
| |
delete _rep; | delete _rep; |
|
|
"HTTPAcceptor::closeConnectionSocket Unlinking local " | "HTTPAcceptor::closeConnectionSocket Unlinking local " |
"connection."); | "connection."); |
::unlink( | ::unlink( |
reinterpret_cast<struct sockaddr_un*>(_rep->address)->sun_path); |
reinterpret_cast<struct sockaddr_un*> |
|
(_rep->address)->sun_path); |
#else | #else |
PEGASUS_ASSERT(false); | PEGASUS_ASSERT(false); |
#endif | #endif |
|
|
"HTTPAcceptor::reconnectConnectionSocket Unlinking local " | "HTTPAcceptor::reconnectConnectionSocket Unlinking local " |
"connection." ); | "connection." ); |
::unlink( | ::unlink( |
reinterpret_cast<struct sockaddr_un*>(_rep->address)->sun_path); |
reinterpret_cast<struct sockaddr_un*>( |
|
_rep->address)->sun_path); |
#else | #else |
PEGASUS_ASSERT(false); | PEGASUS_ASSERT(false); |
#endif | #endif |
|
|
{ | { |
#ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET | #ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET |
::unlink( | ::unlink( |
reinterpret_cast<struct sockaddr_un*>(_rep->address)->sun_path); |
reinterpret_cast<struct sockaddr_un*> |
|
(_rep->address)->sun_path); |
#else | #else |
PEGASUS_ASSERT(false); | PEGASUS_ASSERT(false); |
#endif | #endif |