Logo Search packages:      
Sourcecode: poco version File versions  Download package

MulticastSocket.cpp

//
// MulticastSocket.cpp
//
// $Id: //poco/1.2/Net/src/MulticastSocket.cpp#2 $
//
// Library: Net
// Package: Sockets
// Module:  MulticastSocket
//
// Copyright (c) 2005-2006, Applied Informatics Software Engineering GmbH.
// and Contributors.
//
// Permission is hereby granted, free of charge, to any person or organization
// obtaining a copy of the software and accompanying documentation covered by
// this license (the "Software") to use, reproduce, display, distribute,
// execute, and transmit the Software, and to prepare derivative works of the
// Software, and to permit third-parties to whom the Software is furnished to
// do so, all subject to the following:
// 
// The copyright notices in the Software and this entire statement, including
// the above license grant, this restriction and the following disclaimer,
// must be included in all copies of the Software, in whole or in part, and
// all derivative works of the Software, unless such copies or derivative
// works are solely in the form of machine-executable object code generated by
// a source language processor.
// 
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE, TITLE AND NON-INFRINGEMENT. IN NO EVENT
// SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
// FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
// DEALINGS IN THE SOFTWARE.
//


#include "Poco/Net/MulticastSocket.h"
#include "Poco/Net/NetException.h"
#include <string.h>


#if defined(hpux) && defined(_XOPEN_SOURCE_EXTENDED)
// netinet/in.h does not define struct ip_mreq if
// _XOPEN_SOURCE_EXTENDED is #define'd.
struct ip_mreq 
{
      struct in_addr imr_multiaddr;
      struct in_addr imr_interface;
};
#endif


// some Unix variants don't have IPV6_ADD_MEMBERSHIP/IPV6_DROP_MEMBERSHIP
#if defined(IPV6_JOIN_GROUP) && !defined(IPV6_ADD_MEMBERSHIP)
#define IPV6_ADD_MEMBERSHIP  IPV6_JOIN_GROUP
#define IPV6_DROP_MEMBERSHIP IPV6_LEAVE_GROUP
#endif


namespace Poco {
namespace Net {


MulticastSocket::MulticastSocket()
{
}


00069 MulticastSocket::MulticastSocket(IPAddress::Family family): DatagramSocket(family)
{
}


00074 MulticastSocket::MulticastSocket(const SocketAddress& address, bool reuseAddress): DatagramSocket(address, reuseAddress)
{
}


00079 MulticastSocket::MulticastSocket(const Socket& socket): DatagramSocket(socket)
{
}


00084 MulticastSocket::~MulticastSocket()
{
}


00089 MulticastSocket& MulticastSocket::operator = (const Socket& socket)
{
      DatagramSocket::operator = (socket);
      return *this;
}


00096 void MulticastSocket::setInterface(const NetworkInterface& interface)
{
      if (!interface.supportsIPv6())
      {
            impl()->setOption(IPPROTO_IP, IP_MULTICAST_IF, interface.address());
      }
      else
      {
#if defined(POCO_HAVE_IPv6)
            impl()->setOption(IPPROTO_IPV6, IPV6_MULTICAST_IF, interface.index());
#endif
      }
}

      
00111 NetworkInterface MulticastSocket::getInterface() const
{
      try
      {
            IPAddress addr;
            impl()->getOption(IPPROTO_IP, IP_MULTICAST_IF, addr);
            return NetworkInterface::forAddress(addr);
      }
      catch (Poco::Exception&)
      {
#if defined(POCO_HAVE_IPv6)
            int ix;
            impl()->getOption(IPPROTO_IPV6, IPV6_MULTICAST_IF, ix);
            return NetworkInterface::forIndex(ix);
#else
            throw;
#endif
      }
}

      
00132 void MulticastSocket::setLoopback(bool flag)
{
      if (address().af() == AF_INET)
      {
            unsigned char uflag = flag ? 1 : 0;
            impl()->setOption(IPPROTO_IP, IP_MULTICAST_LOOP, uflag);
      }
      else
      {
#if defined(POCO_HAVE_IPv6)
            unsigned uflag = flag ? 1 : 0;
            impl()->setOption(IPPROTO_IPV6, IPV6_MULTICAST_LOOP, uflag);
#endif
      }
}

      
00149 bool MulticastSocket::getLoopback() const
{
      bool flag = false;
      if (address().af() == AF_INET)
      {
            unsigned char uflag;
            impl()->getOption(IPPROTO_IP, IP_MULTICAST_LOOP, uflag);
            flag = uflag != 0;
      }
      else
      {
#if defined(POCO_HAVE_IPv6)
            unsigned uflag;
            impl()->getOption(IPPROTO_IPV6, IPV6_MULTICAST_LOOP, uflag);
            flag = uflag != 0;
#endif
      }
      return flag;
}

      
00170 void MulticastSocket::setTimeToLive(unsigned value)
{
      if (address().af() == AF_INET)
      {
            unsigned char ttl = (unsigned char) value;
            impl()->setOption(IPPROTO_IP, IP_MULTICAST_TTL, ttl);
      }
      else
      {
#if defined(POCO_HAVE_IPv6)
            impl()->setOption(IPPROTO_IPV6, IPV6_MULTICAST_HOPS, value);
#endif
      }
}

      
00186 unsigned MulticastSocket::getTimeToLive() const
{
      unsigned ttl(0);
      if (address().af() == AF_INET)
      {
            unsigned char cttl;
            impl()->getOption(IPPROTO_IP, IP_MULTICAST_TTL, cttl);
            ttl = cttl;
      }
      else
      {
#if defined(POCO_HAVE_IPv6)
            impl()->getOption(IPPROTO_IPV6, IPV6_MULTICAST_HOPS, ttl);
#endif
      }
      return ttl;
}

      
00205 void MulticastSocket::joinGroup(const IPAddress& groupAddress)
{
      NetworkInterface intf;
      joinGroup(groupAddress, intf);
}

      
00212 void MulticastSocket::joinGroup(const IPAddress& groupAddress, const NetworkInterface& interface)
{
      if (groupAddress.af() == AF_INET)
      {
            struct ip_mreq mr;
            memcpy(&mr.imr_multiaddr, groupAddress.addr(), groupAddress.length());
            memcpy(&mr.imr_interface, interface.address().addr(), interface.address().length());
            impl()->setRawOption(IPPROTO_IP, IP_ADD_MEMBERSHIP, &mr, sizeof(mr));
      }
      else
      {
#if defined(POCO_HAVE_IPv6)
            struct ipv6_mreq mr;
            memcpy(&mr.ipv6mr_multiaddr, groupAddress.addr(), groupAddress.length());
            mr.ipv6mr_interface = interface.index();
            impl()->setRawOption(IPPROTO_IPV6, IPV6_ADD_MEMBERSHIP, &mr, sizeof(mr));
#endif
      }
}

      
00233 void MulticastSocket::leaveGroup(const IPAddress& groupAddress)
{
      NetworkInterface intf;
      leaveGroup(groupAddress, intf);
}

      
00240 void MulticastSocket::leaveGroup(const IPAddress& groupAddress, const NetworkInterface& interface)
{
      if (groupAddress.af() == AF_INET)
      {
            struct ip_mreq mr;
            memcpy(&mr.imr_multiaddr, groupAddress.addr(), groupAddress.length());
            memcpy(&mr.imr_interface, interface.address().addr(), interface.address().length());
            impl()->setRawOption(IPPROTO_IP, IP_DROP_MEMBERSHIP, &mr, sizeof(mr));
      }
      else
      {
#if defined(POCO_HAVE_IPv6)
            struct ipv6_mreq mr;
            memcpy(&mr.ipv6mr_multiaddr, groupAddress.addr(), groupAddress.length());
            mr.ipv6mr_interface = interface.index();
            impl()->setRawOption(IPPROTO_IPV6, IPV6_DROP_MEMBERSHIP, &mr, sizeof(mr));
#endif
      }
}


} } // namespace Poco::Net

Generated by  Doxygen 1.6.0   Back to index