diff options
Diffstat (limited to 'ace/TLI_Connector.cpp')
| -rw-r--r-- | ace/TLI_Connector.cpp | 211 |
1 files changed, 0 insertions, 211 deletions
diff --git a/ace/TLI_Connector.cpp b/ace/TLI_Connector.cpp deleted file mode 100644 index f39c6b7c6de..00000000000 --- a/ace/TLI_Connector.cpp +++ /dev/null @@ -1,211 +0,0 @@ -// TLI_Connector.cpp -// $Id$ - -#define ACE_BUILD_DLL -#include "ace/Handle_Set.h" -#include "ace/TLI_Connector.h" -#include "ace/Time_Value.h" - -#if defined (ACE_HAS_TLI) - -ACE_ALLOC_HOOK_DEFINE(ACE_TLI_Connector) - -void -ACE_TLI_Connector::dump (void) const -{ - ACE_TRACE ("ACE_TLI_Connector::dump"); -} - -ACE_TLI_Connector::ACE_TLI_Connector (void) -{ - ACE_TRACE ("ACE_TLI_Connector::ACE_TLI_Connector"); -} - -// Connect the <new_stream> to the <remote_sap>, waiting up to -// <timeout> amount of time if necessary. It's amazing how -// complicated this is to do in TLI... - -int -ACE_TLI_Connector::connect (ACE_TLI_Stream &new_stream, - const ACE_Addr &remote_sap, - ACE_Time_Value *timeout, - const ACE_Addr &local_sap, - int reuse_addr, - int flags, - int /* perms */, - const char device[], - struct t_info *info, - int rwf, - netbuf *udata, - netbuf *opt) -{ - ACE_TRACE ("ACE_TLI_Connector::connect"); - int result = 0; - - // Only open a new endpoint if we don't already have a valid handle. - - if (new_stream.get_handle () == ACE_INVALID_HANDLE) - { - if (ACE_TLI::open (device, flags, info) == -1) - return -1; - } - else // Borrow the handle from the NEW_STREAM. - this->set_handle (new_stream.get_handle ()); - - if (&local_sap != &ACE_Addr::sap_any) - { - // Bind the local endpoint to a specific addr. - - struct t_bind *localaddr; - - localaddr = (struct t_bind *) - ::t_alloc (this->get_handle (), T_BIND, T_ADDR); - - if (localaddr == 0) - result = -1; - else - { - int one = 1; - if (reuse_addr && this->set_option (SOL_SOCKET, SO_REUSEADDR, - &one, sizeof one) == -1) - result = -1; - else - { - // localaddr->glen = 0; - localaddr->addr.maxlen = local_sap.get_size (); - localaddr->addr.len = local_sap.get_size (); - localaddr->addr.buf = (char *) local_sap.get_addr (); - - if (ACE_OS::t_bind (this->get_handle (), localaddr, localaddr) == -1) - result = -1; - - ACE_OS::t_free ((char *) localaddr, T_BIND); - } - } - - if (result == -1) - { - this->close (); - return -1; - } - } - // Let TLI select the local endpoint addr. - else if (ACE_OS::t_bind (this->get_handle (), 0, 0) == -1) - return -1; - - struct t_call *callptr = 0; - - callptr = (struct t_call *) - ACE_OS::t_alloc (this->get_handle (), T_CALL, T_ADDR); - - if (callptr == 0) - { - this->close (); - return -1; - } - callptr->addr.maxlen = remote_sap.get_size (); - callptr->addr.len = remote_sap.get_size (); - callptr->addr.buf = (char *) remote_sap.get_addr (); - - if (udata != 0) - ACE_OS::memcpy ((void *) &callptr->udata, (void *) udata, sizeof *udata); - if (opt != 0) - ACE_OS::memcpy ((void *) &callptr->opt, (void *) opt, sizeof *opt); - - // Connect to remote endpoint. - - if (timeout != 0) // Enable non-blocking, if required. - { - if (this->enable (ACE_NONBLOCK) == -1) - result = -1; - - // Do a non-blocking connect. - if (ACE_OS::t_connect (this->get_handle (), callptr, 0) == -1) - { - result = -1; - - // Check to see if we simply haven't connected yet on a - // non-blocking handle or whether there's really an error. - if (t_errno == TNODATA) - { - if (timeout->sec () == 0 && timeout->usec () == 0) - errno = EWOULDBLOCK; - else - result = this->complete (new_stream, 0, timeout); - } - else if (t_errno == TLOOK && this->look () == T_DISCONNECT) - this->rcvdis (); - } - } - // Do a blocking connect to the server. - else if (ACE_OS::t_connect (this->get_handle (), callptr, 0) == -1) - result = -1; - - if (result != -1) - { - // If everything succeeded transfer ownership to <new_stream>. - new_stream.set_handle (this->get_handle ()); - this->set_handle (ACE_INVALID_HANDLE); - new_stream.set_rwflag (rwf); -#if defined (I_PUSH) - if (new_stream.get_rwflag ()) - result = ACE_OS::ioctl (new_stream.get_handle (), I_PUSH, "tirdwr"); -#endif /* I_PUSH */ - } - else if (!(errno == EWOULDBLOCK || errno == ETIMEDOUT)) - { - // If things have gone wrong, close down and return an error. - this->close (); - new_stream.set_handle (ACE_INVALID_HANDLE); - } - - if (ACE_OS::t_free ((char *) callptr, T_CALL) == -1) - return -1; - return result; -} - -// Try to complete a non-blocking connection. - -int -ACE_TLI_Connector::complete (ACE_TLI_Stream &new_stream, - ACE_Addr *remote_sap, - ACE_Time_Value *tv) -{ - ACE_TRACE ("ACE_TLI_Connector::complete"); - ACE_HANDLE h = ACE::handle_timed_complete (this->get_handle (), tv); - - if (h == ACE_INVALID_HANDLE) - { - this->close (); - return -1; - } - else // We've successfully connected! - { - if (remote_sap != 0) - { -#if defined (ACE_HAS_SVR4_TLI) - struct netbuf name; - - name.maxlen = remote_sap->get_size (); - name.buf = (char *) remote_sap->get_addr (); - - if (ACE_OS::ioctl (this->get_handle (), TI_GETPEERNAME, &name) == -1) -#else /* SunOS4 sucks... */ - if (0) -#endif /* ACE_HAS_SVR4_TLI */ - { - this->close (); - return -1; - } - } - new_stream.set_handle (this->get_handle ()); - - // Start out with non-blocking disabled on the <new_stream>. - new_stream.disable (ACE_NONBLOCK); - - this->set_handle (ACE_INVALID_HANDLE); - return 0; - } -} - -#endif /* ACE_HAS_TLI */ |