diff options
Diffstat (limited to 'ace/TLI_Connector.cpp')
| -rw-r--r-- | ace/TLI_Connector.cpp | 211 |
1 files changed, 211 insertions, 0 deletions
diff --git a/ace/TLI_Connector.cpp b/ace/TLI_Connector.cpp new file mode 100644 index 00000000000..2a03693b5d9 --- /dev/null +++ b/ace/TLI_Connector.cpp @@ -0,0 +1,211 @@ +// 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 */ |