sub mcast_add_source { my $sock = shift; my $group = shift || croak 'usage: $sock->mcast_add_source($mcast_addr, $source_addr [,$interface] +)'; my $source = shift || croak 'usage: $sock->mcast_add_source($mcast_addr, $source_addr [,$interface +])'; my $interface = shift; if ($sock->sockdomain() == AF_INET) { my $if_addr = _get_if_ipv4addr($interface); my $ip_mreq = pack_ip_mreq_source( inet_pton( AF_INET, $group ), inet_pton( AF_INET, $source ), inet_pton( AF_INET, $if_addr ) ); setsockopt($sock, IPPROTO_IP, IP_ADD_SOURCE_MEMBERSHIP, $ip_mreq ) or croak "Could not set IP_ADD_SOURCE_MEMBERSHIP socket option: $!"; } elsif ($sock->sockdomain() == AF_INET6) { croak("mcast_add_source failed, IPv6 is currently unsupported." ); } else { croak("mcast_add_source failed, unsupported socket family." ); } # Success return 1; }