Package com.biglybt.net.udp.mc.impl

Class MCGroupImpl

java.lang.Object

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

All Implemented Interfaces:

MCGroup

public class MCGroupImpl
extends Object
implements MCGroup

Field Summary

Fields

Modifier and Type	Field	Description
private MCGroupAdapter	adapter
private static AsyncDispatcher	async_dispatcher
private static AEMonitor	class_mon
private int	control_port
private Map<String,Set<InetAddress>>	current_registrations
protected InetSocketAddress	group_address
private String	group_address_str
private int	group_port
private boolean	instance_suspended
private static boolean	overall_suspended
private static final int	PACKET_SIZE
private String[]	selected_interfaces
private static Map<String,MCGroupImpl>	singletons
private Map<String,MulticastSocket>	socket_cache
private boolean	sso_problem_reported
private List<Object[]>	suspended_threads
protected AEMonitor	this_mon
private static final int	TTL
private boolean	ttl_problem_reported

Constructor Summary

Constructors

Modifier	Constructor	Description
private	MCGroupImpl(MCGroupAdapter _adapter, String _group_address, int _group_port, int _control_port, String[] _interfaces, boolean _is_suspended)

Method Summary

Modifier and Type	Method	Description
int	getControlPort()
static MCGroupImpl	getSingleton(MCGroupAdapter adapter, String group_address, int group_port, int control_port, String[] interfaces)
private void	handleSocket(NetworkInterface network_interface, InetAddress local_address, DatagramSocket socket, boolean log_on_stop)
private boolean	interfaceSelected(NetworkInterface ni)
private void	processNetworkInterfaces(boolean start_of_day)
private void	receivePacket(NetworkInterface network_interface, InetAddress local_address, DatagramPacket packet)
void	sendToGroup(byte[] data)
void	sendToGroup(String param_data)	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)
private void	sendToGroupSupport(String param_data)
void	sendToMember(InetSocketAddress address, byte[] data)
private void	setInstanceSuspended(boolean _suspended)
static void	setSuspended(boolean suspended)
private boolean	validNetworkAddress(NetworkInterface network_interface, InetAddress ni_address)

Methods inherited from class java.lang.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

overall_suspended

private static boolean overall_suspended

singletons

private static Map<String,MCGroupImpl> singletons

class_mon

private static AEMonitor class_mon

async_dispatcher

private static AsyncDispatcher async_dispatcher

adapter

private MCGroupAdapter adapter

group_address_str

private String group_address_str

group_port

private int group_port

control_port

private int control_port

group_address

protected InetSocketAddress group_address

selected_interfaces

private String[] selected_interfaces

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

instance_suspended

private volatile boolean instance_suspended

suspended_threads

private List<Object[]> suspended_threads

socket_cache

private Map<String,MulticastSocket> socket_cache

Constructor Details

MCGroupImpl

private MCGroupImpl(MCGroupAdapter _adapter,
 String _group_address,
 int _group_port,
 int _control_port,
 String[] _interfaces,
 boolean _is_suspended)
             throws MCGroupException

Throws:

MCGroupException

Method Details

getSingleton

public static MCGroupImpl getSingleton(MCGroupAdapter adapter,
 String group_address,
 int group_port,
 int control_port,
 String[] interfaces)
                                throws MCGroupException

Throws:

MCGroupException

setSuspended

public static void setSuspended(boolean suspended)

setInstanceSuspended

private void setInstanceSuspended(boolean _suspended)

processNetworkInterfaces

private void processNetworkInterfaces(boolean start_of_day)
                               throws SocketException

Throws:

SocketException

getControlPort

public int getControlPort()

Specified by:

getControlPort in interface MCGroup

interfaceSelected

private boolean interfaceSelected(NetworkInterface ni)

validNetworkAddress

private boolean validNetworkAddress(NetworkInterface network_interface,
 InetAddress ni_address)

sendToGroup

public void sendToGroup(byte[] data)

Specified by:

sendToGroup in interface MCGroup

sendToGroupSupport

private void sendToGroupSupport(byte[] data)

sendToGroup

public void sendToGroup(String param_data)

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)

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)

sendToMember

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

Specified by:

sendToMember in interface MCGroup

Throws:

MCGroupException