Package org.jgroups.tests

Class Probe

java.lang.Object

org.jgroups.tests.Probe

public class Probe
extends Object

Discovers all UDP-based members running on a certain mcast address

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	Probe.Requester
protected class	Probe.TcpRequester
protected class	Probe.UdpRequester

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicInteger	count
protected static final int	DEFAULT_DIAG_PORT
protected String	match
protected final AtomicInteger	matched
protected static final String	MEMBER_ADDRS
protected final AtomicInteger	not_matched
protected static final String	PREFIX
protected final List<Probe.Requester>	requesters
protected final Set<String>	senders
protected ExecutorService	thread_pool
protected boolean	verbose
protected boolean	weed_out_duplicates

Constructor Summary

Constructors

Constructor	Description
Probe()

Method Summary

Modifier and Type	Method	Description
private boolean	checkDuplicateResponse(String response)
protected void	fetchAddressesAndInvoke(SocketAddress dest, InetAddress bind_addr, String request, String passcode, long timeout, int ttl, boolean udp, boolean tcp)
protected static void	help()
static void	main(String[] args)
private static boolean	matches(String response, String match)
private static String	parseAddress(String response)
protected static Collection<SocketAddress>	parseAddresses(String input, int port)	Returns a list of addr:port responses.
void	start(List<InetAddress> addrs, InetAddress bind_addr, int port, int ttl, long timeout, String request, String match, boolean weed_out_duplicates, String passcode, boolean udp, boolean tcp)
boolean	verbose()
Probe	verbose(boolean b)

Methods inherited from class java.lang.Object

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

Field Details

senders

protected final Set<String> senders

weed_out_duplicates

protected boolean weed_out_duplicates

match

protected String match

DEFAULT_DIAG_PORT

protected static final int DEFAULT_DIAG_PORT

See Also:

• Constant Field Values

MEMBER_ADDRS

protected static final String MEMBER_ADDRS

See Also:

• Constant Field Values

thread_pool

protected ExecutorService thread_pool

requesters

protected final List<Probe.Requester> requesters

matched

protected final AtomicInteger matched

not_matched

protected final AtomicInteger not_matched

count

protected final AtomicInteger count

verbose

protected boolean verbose

PREFIX

protected static final String PREFIX

See Also:

• Constant Field Values

Constructor Details

Probe

public Probe()

Method Details

verbose

public boolean verbose()

verbose

public Probe verbose(boolean b)

start

public void start(List<InetAddress> addrs,
 InetAddress bind_addr,
 int port,
 int ttl,
 long timeout,
 String request,
 String match,
 boolean weed_out_duplicates,
 String passcode,
 boolean udp,
 boolean tcp)
           throws Exception

Throws:

Exception

fetchAddressesAndInvoke

protected void fetchAddressesAndInvoke(SocketAddress dest,
 InetAddress bind_addr,
 String request,
 String passcode,
 long timeout,
 int ttl,
 boolean udp,
 boolean tcp)
                                throws IOException

Throws:

IOException

parseAddresses

protected static Collection<SocketAddress> parseAddresses(String input,
 int port)
                                                   throws Exception

Returns a list of addr:port responses. Counting the occurrences of a given address, e.g. 3 assumes we have 3 processes on the same host, yielding requests to host:port, host:port+1 and host_port+3. This is a quick-n-dirty scheme and it will fail when processes don't occupy adjacent ports.

Throws:

Exception

checkDuplicateResponse

private boolean checkDuplicateResponse(String response)

parseAddress

private static String parseAddress(String response)

matches

private static boolean matches(String response,
 String match)

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

help

protected static void help()