dep/ACE_wrappers/ace/ATM_Stream.inl

   1 // -*- C++ -*-
   2 //
   3 // $Id: ATM_Stream.inl 80826 2008-03-04 14:51:23Z wotte $
   4
   5 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   6
   7 ACE_INLINE void
   8 ACE_ATM_Stream::dump (void) const
   9 {
  10 #if defined (ACE_HAS_DUMP)
  11   ACE_TRACE ("ACE_ATM_Stream::dump");
  12 #endif /* ACE_HAS_DUMP */
  13 }
  14
  15 ACE_INLINE
  16 ACE_ATM_Stream::ACE_ATM_Stream (void)
  17 {
  18   ACE_TRACE ("ACE_ATM_Stream::ACE_ATM_Stream");
  19 }
  20
  21 ACE_INLINE
  22 int
  23 ACE_ATM_Stream::open (ACE_ATM_Params params)
  24 {
  25   ACE_TRACE ("ACE_ATM_Stream::open");
  26 #if defined (ACE_HAS_FORE_ATM_XTI)
  27   ACE_HANDLE handle = stream_.open (params.get_device(),
  28                                     params.get_oflag(),
  29                                     params.get_info());
  30   return (handle == ACE_INVALID_HANDLE ? -1 : 0);
  31 #elif defined (ACE_HAS_FORE_ATM_WS2)
  32   params.set_flags( ACE_FLAG_MULTIPOINT_C_ROOT | ACE_FLAG_MULTIPOINT_D_ROOT );
  33
  34   int retval = stream_.open (params.get_type(),
  35                              params.get_protocol_family(),
  36                              params.get_protocol(),
  37                              params.get_protocol_info(),
  38                              params.get_sock_group(),
  39                              params.get_flags(),
  40                              params.get_reuse_addr());
  41   if (retval == -1)
  42     return -1;
  43
  44   struct sockaddr_atm sock_addr;
  45
  46   ACE_OS::memset(&sock_addr, 0, sizeof(struct sockaddr_atm));
  47   sock_addr.satm_family = AF_ATM;
  48   sock_addr.satm_number.AddressType=ADDR_ANY;
  49   sock_addr.satm_number.NumofDigits = ATM_ADDR_SIZE;
  50   sock_addr.satm_blli.Layer2Protocol = SAP_FIELD_ABSENT;
  51   sock_addr.satm_blli.Layer3Protocol = SAP_FIELD_ABSENT;
  52   sock_addr.satm_bhli.HighLayerInfoType = SAP_FIELD_ABSENT;
  53   if (ACE_OS::bind(get_handle(),
  54                    (struct sockaddr FAR *)&sock_addr,
  55                    sizeof(struct sockaddr_atm)) < 0)
  56     {
  57       ACE_OS::printf("Error binding local address: %d",WSAGetLastError());
  58       return -1;
  59     }
  60
  61   return 0;
  62 #else
  63   ACE_UNUSED_ARG(params);
  64   return 0;
  65 #endif /* ACE_HAS_FORE_ATM_XTI */
  66 }
  67
  68 ACE_INLINE
  69 int
  70 ACE_ATM_Stream::close (void)
  71 {
  72   ACE_TRACE ("ACE_ATM_Stream::close");
  73 #if defined (ACE_HAS_FORE_ATM_XTI) || defined (ACE_HAS_FORE_ATM_WS2)
  74   return stream_.close ();
  75 #else
  76   return 0;
  77 #endif /* ACE_HAS_FORE_ATM_XTI || ACE_HAS_FORE_ATM_WS2 */
  78 }
  79
  80 ACE_INLINE
  81 ATM_Stream&
  82 ACE_ATM_Stream::get_stream (void)
  83 {
  84   ACE_TRACE ("ACE_ATM_Stream::get_stream");
  85   return stream_;
  86 }
  87
  88 ACE_INLINE
  89 ssize_t
  90 ACE_ATM_Stream::recv (void *buf,
  91                       size_t n,
  92                       int *flags) const
  93 {
  94   ACE_TRACE ("ACE_ATM_Stream::recv");
  95 #if defined (ACE_HAS_FORE_ATM_XTI)
  96   return stream_.recv (buf,
  97                        n,
  98                        flags);
  99 #elif defined (ACE_HAS_FORE_ATM_WS2)
 100   return stream_.recv (buf,
 101                        n);
 102 #else
 103   ACE_UNUSED_ARG(buf);
 104   ACE_UNUSED_ARG(n);
 105   ACE_UNUSED_ARG(flags);
 106   return (0);
 107 #endif /* ACE_HAS_FORE_ATM_XTI */
 108 }
 109
 110 ACE_INLINE
 111 ssize_t
 112 ACE_ATM_Stream::send_n (const void *buf,
 113                         size_t n,
 114                         int flags) const
 115 {
 116   ACE_TRACE ("ACE_ATM_Stream::send_n");
 117 #if defined (ACE_HAS_FORE_ATM_XTI)
 118   return stream_.send_n (buf,
 119                          n,
 120                          flags);
 121 #elif defined (ACE_HAS_FORE_ATM_WS2)
 122   return stream_.send_n (buf,
 123                          n,
 124                          flags);
 125 #else
 126   ACE_UNUSED_ARG(buf);
 127   ACE_UNUSED_ARG(n);
 128   ACE_UNUSED_ARG(flags);
 129   return (0);
 130 #endif /* ACE_HAS_FORE_ATM_XTI */
 131 }
 132
 133 ACE_END_VERSIONED_NAMESPACE_DECL