diff options
Diffstat (limited to 'ace/SOCK_Acceptor.cpp')
| -rw-r--r-- | ace/SOCK_Acceptor.cpp | 192 |
1 files changed, 0 insertions, 192 deletions
diff --git a/ace/SOCK_Acceptor.cpp b/ace/SOCK_Acceptor.cpp deleted file mode 100644 index b2e0f097117..00000000000 --- a/ace/SOCK_Acceptor.cpp +++ /dev/null @@ -1,192 +0,0 @@ -// SOCK_Acceptor.cpp -// $Id$ - -#define ACE_BUILD_DLL -#include "ace/SOCK_Acceptor.h" - -#if defined (ACE_LACKS_INLINE_FUNCTIONS) -#include "ace/SOCK_Acceptor.i" -#endif /* ACE_LACKS_INLINE_FUNCTIONS */ - -#include "ace/Synch.h" - -ACE_ALLOC_HOOK_DEFINE(ACE_SOCK_Acceptor) - -// Do nothing routine for constructor. - -ACE_SOCK_Acceptor::ACE_SOCK_Acceptor (void) -{ - ACE_TRACE ("ACE_SOCK_Acceptor::ACE_SOCK_Acceptor"); -} - -// General purpose routine for accepting new connections. - -int -ACE_SOCK_Acceptor::accept (ACE_SOCK_Stream &new_stream, - ACE_Addr *remote_addr, - ACE_Time_Value *timeout, - int restart, - int reset_new_handle) const -{ - ACE_TRACE ("ACE_SOCK_Acceptor::accept"); - - ACE_HANDLE new_handle = - this->shared_accept (remote_addr, - timeout, - restart, - reset_new_handle); - new_stream.set_handle (new_handle); - return new_handle == ACE_INVALID_HANDLE ? -1 : 0; -} - -// General purpose routine for performing server ACE_SOCK creation. - -ACE_SOCK_Acceptor::ACE_SOCK_Acceptor (const ACE_Addr &local_sap, - int reuse_addr, - int protocol_family, - int backlog, - int protocol) -{ - ACE_TRACE ("ACE_SOCK_Acceptor::ACE_SOCK_Acceptor"); - if (this->open (local_sap, reuse_addr, protocol_family, - backlog, protocol) == -1) - ACE_ERROR ((LM_ERROR, ASYS_TEXT ("%p\n"), ASYS_TEXT ("ACE_SOCK_Acceptor"))); -} - -void -ACE_SOCK_Acceptor::dump (void) const -{ - ACE_TRACE ("ACE_SOCK_Acceptor::dump"); -} - -// General purpose routine for performing server ACE_SOCK creation. - -int -ACE_SOCK_Acceptor::open (const ACE_Addr &local_sap, - int reuse_addr, - int protocol_family, - int backlog, - int protocol) -{ - ACE_TRACE ("ACE_SOCK_Acceptor::open"); - int error = 0; - - if (ACE_SOCK::open (SOCK_STREAM, protocol_family, - protocol, reuse_addr) == -1) - error = 1; - - else if (protocol_family == PF_INET) - { - sockaddr_in local_inet_addr; - ACE_OS::memset ((void *) &local_inet_addr, - 0, - sizeof local_inet_addr); - - if (local_sap == ACE_Addr::sap_any) - { - local_inet_addr.sin_port = 0; - local_inet_addr.sin_addr.s_addr = htonl (INADDR_ANY); - } - else - local_inet_addr = *(sockaddr_in *) local_sap.get_addr (); - - if (local_inet_addr.sin_port == 0) - { - if (ACE::bind_port (this->get_handle (), - local_inet_addr.sin_addr.s_addr) == -1) - error = 1; - } - else - { - if (ACE_OS::bind (this->get_handle (), - (sockaddr *) &local_inet_addr, - sizeof local_inet_addr) == -1) - error = 1; - } - } - else if (ACE_OS::bind (this->get_handle (), (sockaddr *) local_sap.get_addr (), - local_sap.get_size ()) == -1) - error = 1; - - if (error || ACE_OS::listen (this->get_handle (), backlog) == -1) - this->close (); - - return error ? -1 : 0; -} - -// Performs the timed accept operation. - -ACE_HANDLE -ACE_SOCK_Acceptor::shared_accept (ACE_Addr *remote_addr, - ACE_Time_Value *timeout, - int restart, - int reset_new_handle) const -{ - ACE_TRACE ("ACE_SOCK_Acceptor::shared_accept"); - ACE_UNUSED_ARG (reset_new_handle); - - sockaddr *addr = 0; - int *len_ptr = 0; - int len; - ACE_HANDLE new_handle; - ACE_HANDLE handle = this->get_handle (); - - if (remote_addr != 0) - { - len = remote_addr->get_size (); - len_ptr = &len; - addr = (sockaddr *) remote_addr->get_addr (); - } - - // Handle the timeout case. - if (timeout != 0) - { - if (ACE::handle_timed_accept (handle, timeout, restart) == -1) - return ACE_INVALID_HANDLE; - else - { - int val = ACE::get_flags (handle); - - // Set the handle into non-blocking mode if it's not - // already in it. - if (ACE_BIT_DISABLED (val, ACE_NONBLOCK) - && ACE::set_flags (handle, ACE_NONBLOCK) == -1) - return ACE_INVALID_HANDLE; - - new_handle = ACE_OS::accept (handle, addr, len_ptr); - - if (ACE_BIT_DISABLED (val, ACE_NONBLOCK)) - { - // We need to stash errno here because ACE::clr_flags() may - // reset it. - int error = errno; - - // Only disable ACE_NONBLOCK if we weren't in non-blocking mode - // originally. - ACE::clr_flags (handle, ACE_NONBLOCK); - errno = error; - } - } - } - else - { - // Perform a blocking accept. - - do - new_handle = ACE_OS::accept (handle, addr, len_ptr); - while (new_handle == ACE_INVALID_HANDLE && restart && errno == EINTR); - } - -#if defined (ACE_HAS_WINSOCK2) && (ACE_HAS_WINSOCK2 != 0) - if (reset_new_handle) - // Reset the event association inherited by the new handle. - ::WSAEventSelect ((SOCKET) new_handle, NULL, 0); -#endif /* ACE_WIN32 */ - - // Reset the size of the addr (really only necessary for the - // UNIX domain sockets). - if (new_handle != ACE_INVALID_HANDLE && remote_addr != 0) - remote_addr->set_size (*len_ptr); - - return new_handle; -} |