Class MCGroupImpl

java.lang.Object

com.biglybt.net.udp.mc.impl.MCGroupImpl

All Implemented Interfaces:

MCGroup

public class MCGroupImpl
extends Object
implements MCGroup

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	MCGroupImpl.SelectorListener

Field Summary

Fields

Modifier and Type	Field	Description
private final CopyOnWriteList<MCGroupAdapter>	adapters
private static AsyncDispatcher	async_dispatcher
private static AEMonitor	class_mon
private int	control_port
private Map<String, Set<InetAddress>>	current_registrations
protected final InetSocketAddress	group_address
private final String	group_address_str
private final int	group_port
private boolean	ignore_v4
private boolean	ignore_v6
protected final boolean	ipv6
private static NetworkAdmin	network_admin
private static final int	PACKET_SIZE
private static Map<String, MCGroupImpl>	singletons
private Map<String, MulticastSocket>	socket_cache
private boolean	sso_problem_reported
protected AEMonitor	this_mon
private static final int	TTL
private boolean	ttl_problem_reported
private static final boolean	USE_NIO
private static VirtualAbstractChannelSelector	v4_selector
private static VirtualAbstractChannelSelector	v6_selector

Constructor Summary

Constructors

Modifier	Constructor	Description
private	MCGroupImpl(MCGroupAdapter _adapter, String _group_address, int _group_port, int _control_port)

Method Summary

Modifier and Type	Method	Description
private void	addAdapter(MCGroupAdapter adapter)
int	getControlPort()
static MCGroupImpl	getSingleton(MCGroupAdapter adapter, String group_address, int group_port)
private void	handleSocket(NetworkInterface network_interface, InetAddress local_address, DatagramSocket socket, boolean log_on_stop)
private boolean	interfaceSelected(NetworkInterface ni, String[] selected_interfaces)
boolean	isIPv6()
private void	log(String msg, Throwable e)
private void	log(Throwable e)
private void	processNetworkInterfaces(boolean start_of_day)
private void	receivePacket(NetworkInterface network_interface, InetAddress local_address, DatagramPacket packet)
private void	receivePacket(NetworkInterface network_interface, InetAddress local_address, ByteBuffer buffer, InetSocketAddress remote)
void	sendToGroup(byte[] data, String[] selected_interfaces)
void	sendToGroup(String param_data, String[] selected_interfaces)	Sends to the group but will replace any occurrence of %AZINTERFACE% in the string with the interface being used for the send
private void	sendToGroupSupport(byte[] data, String[] selected_interfaces)
private void	sendToGroupSupport(String param_data, String[] selected_interfaces)
void	sendToMember(InetSocketAddress address, byte[] data)
private void	trace(String str)
private boolean	validNetworkAddress(NetworkInterface network_interface, InetAddress ni_address)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

TTL

private static final int TTL

See Also:

• Constant Field Values

PACKET_SIZE

private static final int PACKET_SIZE

See Also:

• Constant Field Values

USE_NIO

private static final boolean USE_NIO

See Also:

• Constant Field Values

singletons

private static Map<String, MCGroupImpl> singletons

class_mon

private static AEMonitor class_mon

async_dispatcher

private static AsyncDispatcher async_dispatcher

network_admin

private static NetworkAdmin network_admin

ignore_v4

private volatile boolean ignore_v4

ignore_v6

private volatile boolean ignore_v6

v4_selector

private static VirtualAbstractChannelSelector v4_selector

v6_selector

private static VirtualAbstractChannelSelector v6_selector

adapters

private final CopyOnWriteList<MCGroupAdapter> adapters

group_address_str

private final String group_address_str

group_port

private final int group_port

group_address

protected final InetSocketAddress group_address

ipv6

protected final boolean ipv6

control_port

private int control_port

ttl_problem_reported

private boolean ttl_problem_reported

sso_problem_reported

private boolean sso_problem_reported

this_mon

protected AEMonitor this_mon

current_registrations

private Map<String, Set<InetAddress>> current_registrations

socket_cache

private Map<String, MulticastSocket> socket_cache

Constructor Details

MCGroupImpl

private MCGroupImpl(MCGroupAdapter _adapter,
 String _group_address,
 int _group_port,
 int _control_port)
             throws MCGroupException

Throws:

MCGroupException

Method Details

getSingleton

public static MCGroupImpl getSingleton(MCGroupAdapter adapter,
 String group_address,
 int group_port)
                                throws MCGroupException

Throws:

MCGroupException

addAdapter

private void addAdapter(MCGroupAdapter adapter)

trace

private void trace(String str)

log

private void log(Throwable e)

log

private void log(String msg,
 Throwable e)

isIPv6

public boolean isIPv6()

Specified by:

isIPv6 in interface MCGroup

processNetworkInterfaces

private void processNetworkInterfaces(boolean start_of_day)
                               throws SocketException

Throws:

SocketException

getControlPort

public int getControlPort()

Specified by:

getControlPort in interface MCGroup

validNetworkAddress

private boolean validNetworkAddress(NetworkInterface network_interface,
 InetAddress ni_address)

sendToGroup

public void sendToGroup(byte[] data,
 String[] selected_interfaces)

Specified by:

sendToGroup in interface MCGroup

interfaceSelected

private boolean interfaceSelected(NetworkInterface ni,
 String[] selected_interfaces)

sendToGroupSupport

private void sendToGroupSupport(byte[] data,
 String[] selected_interfaces)

sendToGroup

public void sendToGroup(String param_data,
 String[] selected_interfaces)

Description copied from interface: MCGroup

Sends to the group but will replace any occurrence of %AZINTERFACE% in the string with the interface being used for the send

Specified by:

sendToGroup in interface MCGroup

Parameters:

param_data -

sendToGroupSupport

private void sendToGroupSupport(String param_data,
 String[] selected_interfaces)

handleSocket

private void handleSocket(NetworkInterface network_interface,
 InetAddress local_address,
 DatagramSocket socket,
 boolean log_on_stop)

receivePacket

private void receivePacket(NetworkInterface network_interface,
 InetAddress local_address,
 DatagramPacket packet)

receivePacket

private void receivePacket(NetworkInterface network_interface,
 InetAddress local_address,
 ByteBuffer buffer,
 InetSocketAddress remote)

sendToMember

public void sendToMember(InetSocketAddress address,
 byte[] data)
                  throws MCGroupException

Specified by:

sendToMember in interface MCGroup

Throws:

MCGroupException