Modifier and Type | Class and Description |
---|---|
static interface |
DiagnosticsHandler.ProbeHandler |
Modifier and Type | Field and Description |
---|---|
protected List<NetworkInterface> |
bind_interfaces |
protected MulticastSocket |
diag_sock |
protected InetAddress |
diagnostics_addr |
protected int |
diagnostics_port |
protected Set<DiagnosticsHandler.ProbeHandler> |
handlers |
protected Log |
log |
protected String |
passcode |
protected SocketFactory |
socket_factory |
protected Thread |
thread |
protected ThreadFactory |
thread_factory |
static String |
THREAD_NAME |
protected int |
ttl |
Constructor and Description |
---|
DiagnosticsHandler(InetAddress diagnostics_addr,
int diagnostics_port,
List<NetworkInterface> bind_interfaces,
int diagnostics_ttl,
Log log,
SocketFactory socket_factory,
ThreadFactory thread_factory,
String passcode) |
DiagnosticsHandler(InetAddress diagnostics_addr,
int diagnostics_port,
Log log,
SocketFactory socket_factory,
ThreadFactory thread_factory) |
DiagnosticsHandler(InetAddress diagnostics_addr,
int diagnostics_port,
Log log,
SocketFactory socket_factory,
ThreadFactory thread_factory,
String passcode) |
Modifier and Type | Method and Description |
---|---|
protected int |
authorizeProbeRequest(DatagramPacket packet)
Performs authorization on given DatagramPacket.
|
protected void |
bindToInterfaces(List<NetworkInterface> interfaces,
MulticastSocket s) |
Set<DiagnosticsHandler.ProbeHandler> |
getProbeHandlers() |
Thread |
getThread() |
protected void |
handleDiagnosticProbe(SocketAddress sender,
DatagramSocket sock,
String request) |
protected boolean |
isAuthorizationRequired() |
boolean |
isRunning() |
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) |
public static final String THREAD_NAME
protected Thread thread
protected MulticastSocket diag_sock
protected InetAddress diagnostics_addr
protected int diagnostics_port
protected int ttl
protected List<NetworkInterface> bind_interfaces
protected final Set<DiagnosticsHandler.ProbeHandler> handlers
protected final Log log
protected final SocketFactory socket_factory
protected final ThreadFactory thread_factory
protected final String passcode
public DiagnosticsHandler(InetAddress diagnostics_addr, int diagnostics_port, Log log, SocketFactory socket_factory, ThreadFactory thread_factory)
public DiagnosticsHandler(InetAddress diagnostics_addr, int diagnostics_port, Log log, SocketFactory socket_factory, ThreadFactory thread_factory, String passcode)
public DiagnosticsHandler(InetAddress diagnostics_addr, int diagnostics_port, List<NetworkInterface> bind_interfaces, int diagnostics_ttl, Log log, SocketFactory socket_factory, ThreadFactory thread_factory, String passcode)
public Thread getThread()
public Set<DiagnosticsHandler.ProbeHandler> getProbeHandlers()
public void registerProbeHandler(DiagnosticsHandler.ProbeHandler handler)
public void unregisterProbeHandler(DiagnosticsHandler.ProbeHandler handler)
public void start() throws IOException
IOException
public void stop()
public boolean isRunning()
protected void handleDiagnosticProbe(SocketAddress sender, DatagramSocket sock, String request)
protected int authorizeProbeRequest(DatagramPacket packet) throws Exception
packet
- to authorizeException
- thrown if passcode received from client does not match set passcodeprotected static void sendResponse(DatagramSocket sock, SocketAddress sender, byte[] buf) throws IOException
IOException
protected void bindToInterfaces(List<NetworkInterface> interfaces, MulticastSocket s)
protected boolean isAuthorizationRequired()
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.