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 TP |
transport |
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) |
protected String |
defaultHeaders() |
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 boolean |
sameCluster(String req) |
protected void |
sendResponse(DatagramSocket sock,
SocketAddress sender,
byte[] buf) |
void |
start() |
void |
stop() |
TP |
transport() |
DiagnosticsHandler |
transport(TP tp) |
void |
unregisterProbeHandler(DiagnosticsHandler.ProbeHandler handler) |
public static final String THREAD_NAME
protected TP transport
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 TP transport()
public DiagnosticsHandler transport(TP tp)
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 String defaultHeaders()
protected boolean sameCluster(String req)
protected int authorizeProbeRequest(DatagramPacket packet) throws Exception
packet
- to authorizeException
- thrown if passcode received from client does not match set passcodeprotected void sendResponse(DatagramSocket sock, SocketAddress sender, byte[] buf)
protected void bindToInterfaces(List<NetworkInterface> interfaces, MulticastSocket s)
protected boolean isAuthorizationRequired()
Copyright © 2019 JBoss, a division of Red Hat. All rights reserved.