ACE_TLI_Connector class Reference

Actively connect and produce a <new_stream> if things go well. The <remote_sap> is the address that we are trying to connect with. The <timeout> is the amount of time to wait to connect. If it's 0 then we block indefinitely. If *timeout == {0, 0} then the connection is done using non-blocking mode. In this case, if the connection can't be made immediately the value of -1 is returned with <errno == EWOULDBLOCK>. If *timeout > {0, 0} then this is the maximum amount of time to wait before timing out. If the time expires before the connection is made <errno == ETIME>. The <local_sap> is the value of local address to bind to. If it's the default value of <ACE_Addr::sap_any> then the user is letting the OS do the binding. If <reuse_addr> == 1 then the <local_addr> is reused, even if it hasn't been cleanedup yet.

00047 {
00048   ACE_TRACE ("ACE_TLI_Connector::connect");
00049   int result = 0;
00050 
00051   // Only open a new endpoint if we don't already have a valid handle.
00052 
00053   if (new_stream.get_handle () == ACE_INVALID_HANDLE
00054       && new_stream.open (device, flags, info) == ACE_INVALID_HANDLE)
00055     return -1;
00056 
00057   if (local_sap != ACE_Addr::sap_any)
00058     {
00059       // Bind the local endpoint to a specific addr.
00060 
00061       struct t_bind *localaddr;
00062 
00063       localaddr = (struct t_bind *)
00064         ACE_OS::t_alloc (new_stream.get_handle (), T_BIND, T_ADDR);
00065 
00066       if (localaddr == 0)
00067         result = -1;
00068       else
00069         {
00070           int one = 1;
00071 #if !defined (ACE_HAS_FORE_ATM_XTI)
00072           // Reusing the address causes problems with FORE's API. The
00073           // issue may be that t_optmgmt isn't fully supported by
00074           // FORE. t_errno is TBADOPT after the t_optmgmt call so
00075           // maybe options are configured differently for XTI than for
00076           // TLI (at least for FORE's implementation - XTI is supposed
00077           // to be a superset of TLI).
00078           if (reuse_addr
00079               && new_stream.set_option (SOL_SOCKET,
00080                                         SO_REUSEADDR,
00081                                         &one,
00082                                         sizeof one) == -1)
00083             result = -1;
00084           else
00085 #endif /* ACE_HAS_FORE_ATM_XTI */
00086             {
00087               void *addr_buf = local_sap.get_addr ();
00088               localaddr->addr.len = local_sap.get_size ();
00089               ACE_OS::memcpy(localaddr->addr.buf,
00090                              addr_buf,
00091                              localaddr->addr.len);
00092 
00093               if (ACE_OS::t_bind (new_stream.get_handle (),
00094                                   localaddr,
00095                                   localaddr) == -1)
00096                 result = -1;
00097 
00098               ACE_OS::t_free ((char *) localaddr,
00099                               T_BIND);
00100             }
00101         }
00102 
00103       if (result == -1)
00104         {
00105           new_stream.close ();
00106           return -1;
00107         }
00108     }
00109   // Let TLI select the local endpoint addr.
00110   else if (ACE_OS::t_bind (new_stream.get_handle (), 0, 0) == -1)
00111     return -1;
00112 
00113   struct t_call *callptr = 0;
00114 
00115   callptr = (struct t_call *)
00116     ACE_OS::t_alloc (new_stream.get_handle (), T_CALL, T_ADDR);
00117 
00118   if (callptr == 0)
00119     {
00120       new_stream.close ();
00121       return -1;
00122     }
00123 
00124   void *addr_buf = remote_sap.get_addr ();
00125   callptr->addr.len = remote_sap.get_size ();
00126   ACE_OS::memcpy (callptr->addr.buf,
00127                   addr_buf,
00128                   callptr->addr.len);
00129   //callptr->addr.buf = (char *) remote_sap.get_addr ();
00130 
00131   if (udata != 0)
00132     ACE_OS::memcpy ((void *) &callptr->udata, (void *) udata, sizeof *udata);
00133   if (opt != 0)
00134     ACE_OS::memcpy ((void *) &callptr->opt, (void *) opt, sizeof *opt);
00135 
00136   // Connect to remote endpoint.
00137 #if defined (ACE_HAS_FORE_ATM_XTI)
00138   // FORE's XTI/ATM driver has problems with ioctl/fcntl calls so (at least
00139   // for now) always have blocking calls.
00140   timeout = 0;
00141 #endif /* ACE_HAS_FORE_ATM_XTI */
00142 
00143   if (timeout != 0)   // Enable non-blocking, if required.
00144     {
00145       if (new_stream.enable (ACE_NONBLOCK) == -1)
00146         result = -1;
00147 
00148       // Do a non-blocking connect.
00149       if (ACE_OS::t_connect (new_stream.get_handle (), callptr, 0) == -1)
00150         {
00151           result = -1;
00152 
00153           // Check to see if we simply haven't connected yet on a
00154           // non-blocking handle or whether there's really an error.
00155           if (t_errno == TNODATA)
00156             {
00157               if (timeout->sec () == 0 && timeout->usec () == 0)
00158                 errno = EWOULDBLOCK;
00159               else
00160                 result = this->complete (new_stream, 0, timeout);
00161             }
00162           else if (t_errno == TLOOK && new_stream.look () == T_DISCONNECT)
00163             new_stream.rcvdis ();
00164         }
00165     }
00166   // Do a blocking connect to the server.
00167   else if (ACE_OS::t_connect (new_stream.get_handle (), callptr, 0) == -1)
00168     result = -1;
00169 
00170   if (result != -1)
00171     {
00172       new_stream.set_rwflag (rwf);
00173 #if defined (I_PUSH) && !defined (ACE_HAS_FORE_ATM_XTI)
00174       if (new_stream.get_rwflag ())
00175         result = ACE_OS::ioctl (new_stream.get_handle (),
00176                                 I_PUSH,
00177                                 ACE_const_cast (char *, "tirdwr"));
00178 #endif /* I_PUSH */
00179     }
00180   else if (!(errno == EWOULDBLOCK || errno == ETIME))
00181     {
00182       // If things have gone wrong, close down and return an error.
00183       new_stream.close ();
00184       new_stream.set_handle (ACE_INVALID_HANDLE);
00185     }
00186 
00187   if (ACE_OS::t_free ((char *) callptr, T_CALL) == -1)
00188     return -1;
00189   return result;
00190 }

Public Types
typedef ACE_INET_Addr	PEER_ADDR
typedef ACE_TLI_Stream	PEER_STREAM
Public Methods
	ACE_TLI_Connector (void)
	Default constructor. More...
	ACE_TLI_Connector (ACE_TLI_Stream &new_stream, const ACE_Addr &remote_sap, ACE_Time_Value timeout=0, const ACE_Addr &local_sap=ACE_Addr::sap_any, int reuse_addr=0, int flags=O_RDWR, int perms=0, const char device[]=ACE_TLI_TCP_DEVICE, struct t_info info=0, int rw_flag=1, struct netbuf udata=0, struct netbuf opt=0)
int	connect (ACE_TLI_Stream &new_stream, const ACE_Addr &remote_sap, ACE_Time_Value timeout=0, const ACE_Addr &local_sap=ACE_Addr::sap_any, int reuse_addr=0, int flags=O_RDWR, int perms=0, const char device[]=ACE_TLI_TCP_DEVICE, struct t_info info=0, int rw_flag=1, struct netbuf udata=0, struct netbuf opt=0)
int	complete (ACE_TLI_Stream &new_stream, ACE_Addr remote_sap, ACE_Time_Value tv)
int	reset_new_handle (ACE_HANDLE handle)
	Resets any event associations on this handle. More...
void	dump (void) const
	Dump the state of an object. More...
Public Attributes
	ACE_ALLOC_HOOK_DECLARE
	Declare the dynamic allocation hooks. More...

ACE_TLI_Connector Class Reference

Public Types

Public Methods

Public Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation