summaryrefslogtreecommitdiff
path: root/ace/TLI_Connector.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ace/TLI_Connector.cpp')
-rw-r--r--ace/TLI_Connector.cpp210
1 files changed, 0 insertions, 210 deletions
diff --git a/ace/TLI_Connector.cpp b/ace/TLI_Connector.cpp
deleted file mode 100644
index defa11762c5..00000000000
--- a/ace/TLI_Connector.cpp
+++ /dev/null
@@ -1,210 +0,0 @@
-// TLI_Connector.cpp
-// $Id$
-
-#define ACE_BUILD_DLL
-#include "ace/Handle_Set.h"
-#include "ace/TLI_Connector.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 == ETIME))
- {
- // 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, 1);
-
- 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 */