com.fr.third.jgroups.stack

类 DiagnosticsHandler

java.lang.Object

com.fr.third.jgroups.stack.DiagnosticsHandler

所有已实现的接口:

java.lang.Runnable

public class DiagnosticsHandler
extends java.lang.Object
implements java.lang.Runnable

从以下版本开始:

3.0

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	类和说明
static interface	DiagnosticsHandler.ProbeHandler

字段概要

字段

限定符和类型	字段和说明
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 int	ttl

构造器概要

构造器

构造器和说明
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)

方法概要

方法

限定符和类型	方法和说明
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)
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 static void	sendResponse(java.net.DatagramSocket sock, java.net.SocketAddress sender, byte[] buf)
void	start()
void	stop()
void	unregisterProbeHandler(DiagnosticsHandler.ProbeHandler handler)

从类继承的方法 java.lang.Object

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

字段详细资料

THREAD_NAME

public static final java.lang.String THREAD_NAME

另请参阅:

常量字段值

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

构造器详细资料

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)

方法详细资料

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

抛出:

java.io.IOException

stop

public void stop()

isRunning

public boolean isRunning()

run

public void run()

指定者:

run 在接口中 java.lang.Runnable

handleDiagnosticProbe

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

authorizeProbeRequest

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

Performs authorization on given DatagramPacket.

参数:

packet - to authorize

返回:

offset in DatagramPacket where request payload starts

抛出:

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

sendResponse

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

抛出:

java.io.IOException

bindToInterfaces

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

isAuthorizationRequired

protected boolean isAuthorizationRequired()