version 1.45.2.1, 2004/01/16 16:57:31
|
version 1.48, 2004/05/12 14:32:54
|
|
|
| |
// Create a new conection and add it to the connection list: | // Create a new conection and add it to the connection list: |
| |
MP_Socket * mp_socket = new MP_Socket(socket, _sslcontext); |
AutoPtr<MP_Socket> mp_socket(new MP_Socket(socket, _sslcontext)); |
if (mp_socket->accept() < 0) | if (mp_socket->accept() < 0) |
{ | { |
PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2, | PEG_TRACE_STRING(TRC_DISCARDED_DATA, Tracer::LEVEL2, |
|
|
return; | return; |
} | } |
| |
|
mp_socket.release(); |
|
|
// Save the socket for cleanup later: | // Save the socket for cleanup later: |
connection->_entry_index = index; | connection->_entry_index = index; |
_rep->_connection_mut.lock(pegasus_thread_self()); | _rep->_connection_mut.lock(pegasus_thread_self()); |
|
|
else if( _sslcontext != 0 ) { | else if( _sslcontext != 0 ) { |
#ifdef PEGASUS_HAS_SSL | #ifdef PEGASUS_HAS_SSL |
ssl_socket_factory sf; | ssl_socket_factory sf; |
|
pegasus_socket temp(&sf, _sslcontext); |
#else | #else |
bsd_socket_factory sf; | bsd_socket_factory sf; |
|
pegasus_socket temp(&sf); |
#endif | #endif |
pegasus_socket temp(&sf, _sslcontext); |
|
_listener = temp; | _listener = temp; |
_listener.socket(PF_INET, SOCK_STREAM, 0); | _listener.socket(PF_INET, SOCK_STREAM, 0); |
} | } |