ACE/ace/XTI_ATM_Mcast.cpp

   1 #include "ace/XTI_ATM_Mcast.h"
   2
   3
   4
   5 #if defined (ACE_HAS_XTI_ATM)
   6
   7 #if !defined (__ACE_INLINE__)
   8 #include "ace/XTI_ATM_Mcast.inl"
   9 #endif /* __ACE_INLINE__ */
  10
  11 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  12
  13 ACE_ALLOC_HOOK_DEFINE(ACE_XTI_ATM_Mcast)
  14
  15 void
  16 ACE_XTI_ATM_Mcast::dump (void) const
  17 {
  18 #if defined (ACE_HAS_DUMP)
  19   ACE_TRACE ("ACE_XTI_ATM_Mcast::dump");
  20 #endif /* ACE_HAS_DUMP */
  21 }
  22
  23 ACE_XTI_ATM_Mcast::ACE_XTI_ATM_Mcast (void)
  24 {
  25   ACE_TRACE ("ACE_XTI_ATM_Mcast::ACE_XTI_ATM_Mcast");
  26 }
  27
  28 // Add a leaf to the current connection (i.e., multicast).
  29
  30 int
  31 ACE_XTI_ATM_Mcast::add_leaf (ACE_TLI_Stream &current_stream,
  32                              const ACE_Addr &remote_sap,
  33                              ACE_INT32 leaf_id,
  34                              ACE_Time_Value *timeout)
  35 {
  36   ACE_TRACE ("ACE_XTI_ATM_Mcast::add_leaf");
  37
  38   struct netbuf call_req;
  39   memset(&call_req, 0, sizeof(call_req));
  40   call_req.len = remote_sap.get_size ();
  41   call_req.buf = (char *)remote_sap.get_addr ();
  42
  43   if (::t_addleaf(current_stream.get_handle(),
  44                   leaf_id,
  45                   &call_req) < 0)
  46     {
  47       // Check for asynchronous event
  48       if (t_errno == TLOOK)
  49         {
  50           int const event = ACE_OS::t_look(current_stream.get_handle());
  51           if (event != TNODATA && event != T_DATA)
  52             return -1;
  53           else
  54             // If this doesn't work for asynchronous calls we need to call
  55             // the XTI/ATM t_rcvleafchange() function to check for t_addleaf
  56             // completion.
  57             return complete (current_stream, 0, timeout);
  58         }
  59       else
  60         return -1;
  61     }
  62
  63   return 0;
  64 }
  65
  66 ACE_END_VERSIONED_NAMESPACE_DECL
  67
  68 #endif /* ACE_HAS_XTI_ATM */