org.jgroups.stack

Class DiagnosticsHandler

java.lang.Object

org.jgroups.stack.DiagnosticsHandler

All Implemented Interfaces:

java.lang.Runnable

public class DiagnosticsHandler
extends java.lang.Object
implements java.lang.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 java.util.List<java.net.NetworkInterface>	bind_interfaces
protected java.net.MulticastSocket	diag_sock
protected java.net.InetAddress	diagnostics_addr
protected int	diagnostics_port
protected java.util.Set<DiagnosticsHandler.ProbeHandler>	handlers
protected Log	log
protected java.lang.String	passcode
protected SocketFactory	socket_factory
protected java.lang.Thread	thread
protected ThreadFactory	thread_factory
static java.lang.String	THREAD_NAME
protected TP	transport
protected int	ttl

Constructor Summary

Constructors

Constructor and Description
DiagnosticsHandler(java.net.InetAddress diagnostics_addr, int diagnostics_port, java.util.List<java.net.NetworkInterface> bind_interfaces, int diagnostics_ttl, Log log, SocketFactory socket_factory, ThreadFactory thread_factory, java.lang.String passcode)
DiagnosticsHandler(java.net.InetAddress diagnostics_addr, int diagnostics_port, Log log, SocketFactory socket_factory, ThreadFactory thread_factory)
DiagnosticsHandler(java.net.InetAddress diagnostics_addr, int diagnostics_port, Log log, SocketFactory socket_factory, ThreadFactory thread_factory, java.lang.String passcode)

Method Summary

Modifier and Type	Method and Description
protected int	authorizeProbeRequest(java.net.DatagramPacket packet) Performs authorization on given DatagramPacket.
protected void	bindToInterfaces(java.util.List<java.net.NetworkInterface> interfaces, java.net.MulticastSocket s)
protected java.lang.String	defaultHeaders()
java.util.Set<DiagnosticsHandler.ProbeHandler>	getProbeHandlers()
java.lang.Thread	getThread()
protected void	handleDiagnosticProbe(java.net.SocketAddress sender, java.net.DatagramSocket sock, java.lang.String request)
protected boolean	isAuthorizationRequired()
boolean	isRunning()
void	registerProbeHandler(DiagnosticsHandler.ProbeHandler handler)
void	run()
protected boolean	sameCluster(java.lang.String req)
protected void	sendResponse(java.net.DatagramSocket sock, java.net.SocketAddress sender, byte[] buf)
void	start()
void	stop()
TP	transport()
DiagnosticsHandler	transport(TP tp)
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 java.lang.String THREAD_NAME

See Also:

Constant Field Values

transport

protected TP transport

thread

protected java.lang.Thread thread

diag_sock

protected java.net.MulticastSocket diag_sock

diagnostics_addr

protected java.net.InetAddress diagnostics_addr

diagnostics_port

protected int diagnostics_port

ttl

protected int ttl

bind_interfaces

protected java.util.List<java.net.NetworkInterface> bind_interfaces

handlers

protected final java.util.Set<DiagnosticsHandler.ProbeHandler> handlers

log

protected final Log log

socket_factory

protected final SocketFactory socket_factory

thread_factory

protected final ThreadFactory thread_factory

passcode

protected final java.lang.String passcode

Constructor Detail

DiagnosticsHandler

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

DiagnosticsHandler

public DiagnosticsHandler(java.net.InetAddress diagnostics_addr,
                          int diagnostics_port,
                          Log log,
                          SocketFactory socket_factory,
                          ThreadFactory thread_factory,
                          java.lang.String passcode)

DiagnosticsHandler

public DiagnosticsHandler(java.net.InetAddress diagnostics_addr,
                          int diagnostics_port,
                          java.util.List<java.net.NetworkInterface> bind_interfaces,
                          int diagnostics_ttl,
                          Log log,
                          SocketFactory socket_factory,
                          ThreadFactory thread_factory,
                          java.lang.String passcode)

Method Detail

transport

public TP transport()

transport

public DiagnosticsHandler transport(TP tp)

getThread

public java.lang.Thread getThread()

getProbeHandlers

public java.util.Set<DiagnosticsHandler.ProbeHandler> getProbeHandlers()

registerProbeHandler

public void registerProbeHandler(DiagnosticsHandler.ProbeHandler handler)

unregisterProbeHandler

public void unregisterProbeHandler(DiagnosticsHandler.ProbeHandler handler)

start

public void start()
           throws java.io.IOException

Throws:

java.io.IOException

stop

public void stop()

isRunning

public boolean isRunning()

run

public void run()

Specified by:

run in interface java.lang.Runnable

handleDiagnosticProbe

protected void handleDiagnosticProbe(java.net.SocketAddress sender,
                                     java.net.DatagramSocket sock,
                                     java.lang.String request)

defaultHeaders

protected java.lang.String defaultHeaders()

sameCluster

protected boolean sameCluster(java.lang.String req)

authorizeProbeRequest

protected int authorizeProbeRequest(java.net.DatagramPacket packet)
                             throws java.lang.Exception

Performs authorization on given DatagramPacket.

Parameters:

packet - to authorize

Returns:

offset in DatagramPacket where request payload starts

Throws:

java.lang.Exception - thrown if passcode received from client does not match set passcode

sendResponse

protected void sendResponse(java.net.DatagramSocket sock,
                            java.net.SocketAddress sender,
                            byte[] buf)

bindToInterfaces

protected void bindToInterfaces(java.util.List<java.net.NetworkInterface> interfaces,
                                java.net.MulticastSocket s)

isAuthorizationRequired

protected boolean isAuthorizationRequired()