diff options
Diffstat (limited to 'ace/QoS/SOCK_Dgram_Mcast_QoS.cpp')
| -rw-r--r-- | ace/QoS/SOCK_Dgram_Mcast_QoS.cpp | 258 |
1 files changed, 0 insertions, 258 deletions
diff --git a/ace/QoS/SOCK_Dgram_Mcast_QoS.cpp b/ace/QoS/SOCK_Dgram_Mcast_QoS.cpp deleted file mode 100644 index 548c56bef12..00000000000 --- a/ace/QoS/SOCK_Dgram_Mcast_QoS.cpp +++ /dev/null @@ -1,258 +0,0 @@ -// $Id$ - -#include "SOCK_Dgram_Mcast_QoS.h" -#include "ace/Log_Msg.h" -#include "ace/OS_NS_sys_socket.h" - -#if defined (ACE_WIN32) -#include "ace/Sock_Connect.h" // needed for subscribe_ifs() -#endif /* ACE_WIN32 */ - -#if !defined (__ACE_INLINE__) -#include "SOCK_Dgram_Mcast_QoS.i" -#endif /* __ACE_INLINE__ */ - -// This is a workaround for platforms with non-standard -// definitions of the ip_mreq structure -#if ! defined (IMR_MULTIADDR) -#define IMR_MULTIADDR imr_multiaddr -#endif /* ! defined (IMR_MULTIADDR) */ - - -ACE_RCSID (QoS, - SOCK_Dgram_Mcast_QoS, - "$Id$") - -ACE_BEGIN_VERSIONED_NAMESPACE_DECL - -ACE_ALLOC_HOOK_DEFINE(ACE_SOCK_Dgram_Mcast_QoS) - -// Dummy default constructor... - -ACE_SOCK_Dgram_Mcast_QoS::ACE_SOCK_Dgram_Mcast_QoS (options opts) - : ACE_SOCK_Dgram_Mcast (opts) -{ - ACE_TRACE ("ACE_SOCK_Dgram_Mcast_QoS::ACE_SOCK_Dgram_Mcast_QoS"); -} - -int -ACE_SOCK_Dgram_Mcast_QoS::open (const ACE_INET_Addr &addr, - const ACE_QoS_Params &qos_params, - int protocol_family, - int protocol, - ACE_Protocol_Info *protocolinfo, - ACE_SOCK_GROUP g, - u_long flags, - int reuse_addr) -{ - ACE_TRACE ("ACE_SOCK_Dgram_Mcast_QoS::open"); - - ACE_UNUSED_ARG (qos_params); - - // Only perform the <open> initialization if we haven't been opened - // earlier. - if (this->get_handle () != ACE_INVALID_HANDLE) - return 0; - - ACE_DEBUG ((LM_DEBUG, - "Get Handle Returns Invalid Handle\n")); - - if (ACE_SOCK::open (SOCK_DGRAM, - protocol_family, - protocol, - protocolinfo, - g, - flags, - reuse_addr) == -1) - return -1; - - return this->open_i (addr, 0, reuse_addr); -} - - -int -ACE_SOCK_Dgram_Mcast_QoS::subscribe_ifs (const ACE_INET_Addr &mcast_addr, - const ACE_QoS_Params &qos_params, - const ACE_TCHAR *net_if, - int protocol_family, - int protocol, - int reuse_addr, - ACE_Protocol_Info *protocolinfo) -{ - ACE_TRACE ("ACE_SOCK_Dgram_Mcast_QoS::subscribe_ifs"); -#if defined (ACE_WIN32) - // Windows NT's winsock has trouble with multicast subscribes in the - // presence of multiple network interfaces when the IP address is - // given as INADDR_ANY. It will pick the first interface and only - // accept mcast there. So, to work around this, cycle through all - // of the interfaces known and subscribe to all the non-loopback - // ones. - // - // Note that this only needs to be done on NT, but there's no way to - // tell at this point if the code will be running on NT - only if it - // is compiled for NT-only or for NT/95, and that doesn't really - // help us. It doesn't hurt to do this on Win95, it's just a little - // slower than it normally would be. - // - // NOTE - <ACE_Sock_Connect::get_ip_interfaces> doesn't always get all - // of the interfaces. In particular, it may not get a PPP interface. This - // is a limitation of the way <ACE_Sock_Connect::get_ip_interfaces> works - // with MSVC. The reliable way of getting the interface list is - // available only with MSVC 5. - - if (net_if == 0) - { - ACE_INET_Addr *if_addrs = 0; - size_t if_cnt; - - if (ACE::get_ip_interfaces (if_cnt, if_addrs) != 0) - return -1; - - size_t nr_subscribed = 0; - - if (if_cnt < 2) - { - if (this->subscribe (mcast_addr, - qos_params, - reuse_addr, - ACE_LIB_TEXT ("0.0.0.0"), - protocol_family, - protocol, - protocolinfo) == 0) - ++nr_subscribed; - } - else - // Iterate through all the interfaces, figure out which ones - // offer multicast service, and subscribe to them. - while (if_cnt > 0) - { - --if_cnt; - - // Convert to 0-based for indexing, next loop check. - if (if_addrs[if_cnt].get_ip_address() == INADDR_LOOPBACK) - continue; - if (this->subscribe (mcast_addr, - qos_params, - reuse_addr, - ACE_TEXT_CHAR_TO_TCHAR - (if_addrs[if_cnt].get_host_addr()), - protocol_family, - protocol, - protocolinfo) == 0) - ++nr_subscribed; - } - - delete [] if_addrs; - - if (nr_subscribed == 0) - { - errno = ENODEV; - return -1; - } - else - // 1 indicates a "short-circuit" return. This handles the - // rather bizarre semantics of checking all the interfaces on - // NT. - return 1; - } -#else - ACE_UNUSED_ARG (mcast_addr); - ACE_UNUSED_ARG (qos_params); - ACE_UNUSED_ARG (protocol_family); - ACE_UNUSED_ARG (protocol); - ACE_UNUSED_ARG (reuse_addr); - ACE_UNUSED_ARG (protocolinfo); -#endif /* ACE_WIN32 */ - // Otherwise, do it like everyone else... - - // Create multicast request. - if (this->make_multicast_ifaddr (0, - mcast_addr, - net_if) == -1) - return -1; - else - return 0; -} - -int -ACE_SOCK_Dgram_Mcast_QoS::subscribe (const ACE_INET_Addr &mcast_addr, - const ACE_QoS_Params &qos_params, - int reuse_addr, - const ACE_TCHAR *net_if, - int protocol_family, - int protocol, - ACE_Protocol_Info *protocolinfo, - ACE_SOCK_GROUP g, - u_long flags, - ACE_QoS_Session *qos_session) -{ - ACE_TRACE ("ACE_SOCK_Dgram_Mcast_QoS::subscribe"); - - if (this->open (mcast_addr, - qos_params, - protocol_family, - protocol, - protocolinfo, - g, - flags, - reuse_addr) == -1) - return -1; - - // The following method call only applies to Win32 currently. - int result = this->subscribe_ifs (mcast_addr, - qos_params, - net_if, - protocol_family, - protocol, - reuse_addr, - protocolinfo); - // Check for the "short-circuit" return value of 1 (for NT). - if (result != 0) - return result; - - // Tell network device driver to read datagrams with a - // <mcast_request_if_> IP interface. - else - { - // Check if the mcast_addr passed into this method is the - // same as the QoS session address. - if (qos_session != 0 && mcast_addr == qos_session->dest_addr ()) - { - // Subscribe to the QoS session. - if (this->qos_manager_.join_qos_session (qos_session) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - ACE_LIB_TEXT ("Unable to join QoS Session\n")), - -1); - } - else - { - if (this->close () != 0) - ACE_ERROR ((LM_ERROR, - ACE_LIB_TEXT ("Unable to close socket\n"))); - ACE_ERROR_RETURN ((LM_ERROR, - ACE_LIB_TEXT ("Dest Addr in the QoS Session does") - ACE_LIB_TEXT (" not match the address passed into") - ACE_LIB_TEXT (" subscribe\n")), - -1); - } - - ip_mreq ret_mreq; - this->make_multicast_ifaddr (&ret_mreq, mcast_addr, net_if); - - // XX This is windows stuff only. fredk - if (ACE_OS::join_leaf (this->get_handle (), - reinterpret_cast<const sockaddr *> (&ret_mreq.IMR_MULTIADDR.s_addr), - sizeof ret_mreq.IMR_MULTIADDR.s_addr, - qos_params) == ACE_INVALID_HANDLE - && errno != ENOTSUP) - return -1; - - else - if (qos_params.socket_qos () != 0 && qos_session != 0) - qos_session->qos (*(qos_params.socket_qos ())); - - return 0; - } -} - -ACE_END_VERSIONED_NAMESPACE_DECL |