org.jgroups.stack

Class DiagnosticsHandler

java.lang.Object

org.jgroups.stack.DiagnosticsHandler

All Implemented Interfaces:

Runnable

public class DiagnosticsHandler
extends Object
implements Runnable

Since:

3.0

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DiagnosticsHandler.ProbeHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected MulticastSocket	diag_sock
protected InetAddress	diagnostics_addr
protected int	diagnostics_port
protected Set<DiagnosticsHandler.ProbeHandler>	handlers
protected Log	log
protected SocketFactory	socket_factory
protected Thread	thread
protected ThreadFactory	thread_factory
static String	THREAD_NAME

Constructor Summary

Constructors

Constructor and Description
DiagnosticsHandler(InetAddress diagnostics_addr, int diagnostics_port, Log log, SocketFactory socket_factory, ThreadFactory thread_factory)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	bindToInterfaces(List<NetworkInterface> interfaces, MulticastSocket s)
Set<DiagnosticsHandler.ProbeHandler>	getProbeHandlers()
Thread	getThread()
protected void	handleDiagnosticProbe(SocketAddress sender, DatagramSocket sock, String request)
void	registerProbeHandler(DiagnosticsHandler.ProbeHandler handler)
void	run()
protected static void	sendResponse(DatagramSocket sock, SocketAddress sender, byte[] buf)
void	start()
void	stop()
void	unregisterProbeHandler(DiagnosticsHandler.ProbeHandler handler)

Methods inherited from class java.lang.Object

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

Field Detail

THREAD_NAME

public static final String THREAD_NAME

See Also:

Constant Field Values

thread

protected Thread thread

diag_sock

protected MulticastSocket diag_sock

diagnostics_addr

protected InetAddress diagnostics_addr

diagnostics_port

protected int diagnostics_port

handlers

protected final Set<DiagnosticsHandler.ProbeHandler> handlers

log

protected final Log log

socket_factory

protected final SocketFactory socket_factory

thread_factory

protected final ThreadFactory thread_factory

Constructor Detail

DiagnosticsHandler

public DiagnosticsHandler(InetAddress diagnostics_addr,
                  int diagnostics_port,
                  Log log,
                  SocketFactory socket_factory,
                  ThreadFactory thread_factory)

Method Detail

getThread

public Thread getThread()

getProbeHandlers

public Set<DiagnosticsHandler.ProbeHandler> getProbeHandlers()

registerProbeHandler

public void registerProbeHandler(DiagnosticsHandler.ProbeHandler handler)

unregisterProbeHandler

public void unregisterProbeHandler(DiagnosticsHandler.ProbeHandler handler)

start

public void start()
           throws IOException

Throws:

IOException

stop

public void stop()

run

public void run()

Specified by:

run in interface Runnable

handleDiagnosticProbe

protected void handleDiagnosticProbe(SocketAddress sender,
                         DatagramSocket sock,
                         String request)

sendResponse

protected static void sendResponse(DatagramSocket sock,
                SocketAddress sender,
                byte[] buf)
                            throws IOException

Throws:

IOException

bindToInterfaces

protected void bindToInterfaces(List<NetworkInterface> interfaces,
                    MulticastSocket s)