Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	NodePingUtil.CancellableTask
pack-priv static class	NodePingUtil.ConnectionPoolPingTask
pack-priv static class	NodePingUtil.HostPingTask
pack-priv static class	NodePingUtil.HttpClientPingTask
pack-priv static interface	NodePingUtil.PingCallback
pack-priv static class	NodePingUtil.RequestExchangeListener
pack-priv static enum	NodePingUtil.State

Constructor Summary

Access	Constructor and Description
pack-priv	NodePingUtil()

Method Summary

Modifier and Type	Method and Description
pack-priv static void	internalPingNode(Node the node node, NodePingUtil.PingCallback the ping callback callback, NodeHealthChecker healthChecker, XnioIoThread the xnio i/o thread ioThread, ByteBufferPool the xnio buffer pool bufferPool, UndertowClient the undertow client client, XnioSsl the ssl setup xnioSsl, OptionMap the options options) Internally ping a node.
pack-priv static void	pingHost(InetSocketAddress the socket address address, HttpServerExchange the http servers exchange exchange, NodePingUtil.PingCallback the ping callback callback, OptionMap the options options) Try to open a socket connection to given address.
pack-priv static void	pingHttpClient(URI the connection URI connection, NodePingUtil.PingCallback the ping callback callback, HttpServerExchange the http servers exchange exchange, UndertowClient the undertow client client, XnioSsl the ssl setup xnioSsl, OptionMap the options options) Try to ping a server using the undertow client.
pack-priv static void	pingNode(final Node the node node, final HttpServerExchange the http servers exchange exchange, final NodePingUtil.PingCallback the ping callback callback) Try to ping a node using it's connection pool.
pack-priv static void	scheduleCancelTask(final XnioIoThread ioThread, final NodePingUtil.CancellableTask cancellable, final long timeout, final TimeUnit timeUnit)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

NodePingUtil	back to summary
pack-priv NodePingUtil()

Method Detail

internalPingNode	back to summary
pack-priv static void internalPingNode(Node node, NodePingUtil.PingCallback callback, NodeHealthChecker healthChecker, XnioIoThread ioThread, ByteBufferPool bufferPool, UndertowClient client, XnioSsl xnioSsl, OptionMap options) Internally ping a node. This should probably use the connections from the nodes pool, if there are any available. Parameters node:Node the node callback:NodePingUtil.PingCallback the ping callback ioThread:XnioIoThread the xnio i/o thread bufferPool:ByteBufferPool the xnio buffer pool client:UndertowClient the undertow client xnioSsl:XnioSsl the ssl setup options:OptionMap the options

internalPingNode

back to summary

pack-priv static void internalPingNode(Node node, NodePingUtil.PingCallback callback, NodeHealthChecker healthChecker, XnioIoThread ioThread, ByteBufferPool bufferPool, UndertowClient client, XnioSsl xnioSsl, OptionMap options)

Internally ping a node. This should probably use the connections from the nodes pool, if there are any available.

Parameters

node:Node: the node
callback:NodePingUtil.PingCallback: the ping callback
ioThread:XnioIoThread: the xnio i/o thread
bufferPool:ByteBufferPool: the xnio buffer pool
client:UndertowClient: the undertow client
xnioSsl:XnioSsl: the ssl setup
options:OptionMap: the options

pingHost	back to summary
pack-priv static void pingHost(InetSocketAddress address, HttpServerExchange exchange, NodePingUtil.PingCallback callback, OptionMap options) Try to open a socket connection to given address. Parameters address:InetSocketAddress the socket address exchange:HttpServerExchange the http servers exchange callback:NodePingUtil.PingCallback the ping callback options:OptionMap the options

pingHost

back to summary

pack-priv static void pingHost(InetSocketAddress address, HttpServerExchange exchange, NodePingUtil.PingCallback callback, OptionMap options)

Try to open a socket connection to given address.

Parameters

address:InetSocketAddress: the socket address
exchange:HttpServerExchange: the http servers exchange
callback:NodePingUtil.PingCallback: the ping callback
options:OptionMap: the options

pingHttpClient	back to summary
pack-priv static void pingHttpClient(URI connection, NodePingUtil.PingCallback callback, HttpServerExchange exchange, UndertowClient client, XnioSsl xnioSsl, OptionMap options) Try to ping a server using the undertow client. Parameters connection:URI the connection URI callback:NodePingUtil.PingCallback the ping callback exchange:HttpServerExchange the http servers exchange client:UndertowClient the undertow client xnioSsl:XnioSsl the ssl setup options:OptionMap the options

pingHttpClient

back to summary

pack-priv static void pingHttpClient(URI connection, NodePingUtil.PingCallback callback, HttpServerExchange exchange, UndertowClient client, XnioSsl xnioSsl, OptionMap options)

Try to ping a server using the undertow client.

Parameters

connection:URI: the connection URI
callback:NodePingUtil.PingCallback: the ping callback
exchange:HttpServerExchange: the http servers exchange
client:UndertowClient: the undertow client
xnioSsl:XnioSsl: the ssl setup
options:OptionMap: the options

pingNode	back to summary
pack-priv static void pingNode(final Node node, final HttpServerExchange exchange, final NodePingUtil.PingCallback callback) Try to ping a node using it's connection pool. Parameters node:Node the node exchange:HttpServerExchange the http servers exchange callback:NodePingUtil.PingCallback the ping callback

pingNode

back to summary

pack-priv static void pingNode(final Node node, final HttpServerExchange exchange, final NodePingUtil.PingCallback callback)

Try to ping a node using it's connection pool.

Parameters

node:Node: the node
exchange:HttpServerExchange: the http servers exchange
callback:NodePingUtil.PingCallback: the ping callback

scheduleCancelTask	back to summary
pack-priv static void scheduleCancelTask(final XnioIoThread ioThread, final NodePingUtil.CancellableTask cancellable, final long timeout, final TimeUnit timeUnit)

io.undertow.server.handlers.proxy.mod_cluster back to summary

pack-priv Class NodePingUtil.CancellableTask

Class Inheritance

extends Object

java.lang.Object
io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.CancellableTask

Known Direct Subclasses

io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.HostPingTask, io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.RequestExchangeListener

Field Summary

Modifier and Type	Field and Description
private volatile XnioExecutor.Key	cancelKey
private final NodePingUtil.PingCallback	delegate
private volatile NodePingUtil.State	state

Constructor Summary

Access	Constructor and Description
pack-priv	CancellableTask(NodePingUtil.PingCallback callback)

Method Summary

Modifier and Type	Method and Description
pack-priv void	cancel()
pack-priv boolean	isDone()
pack-priv void	setCancelKey(XnioExecutor.Key cancelKey)
pack-priv void	taskCompleted()
pack-priv void	taskFailed()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

cancelKey	back to summary
private volatile XnioExecutor.Key cancelKey

delegate	back to summary
private final NodePingUtil.PingCallback delegate

state	back to summary
private volatile NodePingUtil.State state

Constructor Detail

CancellableTask	back to summary
pack-priv CancellableTask(NodePingUtil.PingCallback callback)

Method Detail

cancel	back to summary
pack-priv void cancel()

isDone	back to summary
pack-priv boolean isDone()

setCancelKey	back to summary
pack-priv void setCancelKey(XnioExecutor.Key cancelKey)

taskCompleted	back to summary
pack-priv void taskCompleted()

taskFailed	back to summary
pack-priv void taskFailed()

io.undertow.server.handlers.proxy.mod_cluster back to summary

pack-priv Class NodePingUtil.ConnectionPoolPingTask

Class Inheritance

extends Object
implements Runnable

java.lang.Object
io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.ConnectionPoolPingTask

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private final NodePingUtil.RequestExchangeListener	exchangeListener
private final ProxyConnection	proxyConnection
private final URI	uri

Constructor Summary

Access	Constructor and Description
pack-priv	ConnectionPoolPingTask(ProxyConnection proxyConnection, NodePingUtil.RequestExchangeListener exchangeListener, URI uri)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

exchangeListener	back to summary
private final NodePingUtil.RequestExchangeListener exchangeListener

proxyConnection	back to summary
private final ProxyConnection proxyConnection

uri	back to summary
private final URI uri

Constructor Detail

ConnectionPoolPingTask	back to summary
pack-priv ConnectionPoolPingTask(ProxyConnection proxyConnection, NodePingUtil.RequestExchangeListener exchangeListener, URI uri)

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

io.undertow.server.handlers.proxy.mod_cluster back to summary

pack-priv Class NodePingUtil.HostPingTask

Class Inheritance

extends CancellableTask
implements Runnable

java.lang.Object
io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.CancellableTask
io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.HostPingTask

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private final InetSocketAddress	address
private final OptionMap	options
private final XnioWorker	worker

Constructor Summary

Access	Constructor and Description
pack-priv	HostPingTask(InetSocketAddress address, XnioWorker worker, NodePingUtil.PingCallback callback, OptionMap options)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.CancellableTask:: cancel isDone setCancelKey taskCompleted taskFailed

Field Detail

address	back to summary
private final InetSocketAddress address

options	back to summary
private final OptionMap options

worker	back to summary
private final XnioWorker worker

Constructor Detail

HostPingTask	back to summary
pack-priv HostPingTask(InetSocketAddress address, XnioWorker worker, NodePingUtil.PingCallback callback, OptionMap options)

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

io.undertow.server.handlers.proxy.mod_cluster back to summary

pack-priv Class NodePingUtil.HttpClientPingTask

Class Inheritance

extends Object
implements Runnable

java.lang.Object
io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.HttpClientPingTask

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private final ByteBufferPool	bufferPool
private final UndertowClient	client
private final URI	connection
private final NodePingUtil.RequestExchangeListener	exchangeListener
private final OptionMap	options
private final XnioIoThread	thread
private final XnioSsl	xnioSsl

Constructor Summary

Access	Constructor and Description
pack-priv	HttpClientPingTask(URI connection, NodePingUtil.RequestExchangeListener exchangeListener, XnioIoThread thread, UndertowClient client, XnioSsl xnioSsl, ByteBufferPool bufferPool, OptionMap options)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

bufferPool	back to summary
private final ByteBufferPool bufferPool

client	back to summary
private final UndertowClient client

connection	back to summary
private final URI connection

exchangeListener	back to summary
private final NodePingUtil.RequestExchangeListener exchangeListener

options	back to summary
private final OptionMap options

thread	back to summary
private final XnioIoThread thread

xnioSsl	back to summary
private final XnioSsl xnioSsl

Constructor Detail

HttpClientPingTask	back to summary
pack-priv HttpClientPingTask(URI connection, NodePingUtil.RequestExchangeListener exchangeListener, XnioIoThread thread, UndertowClient client, XnioSsl xnioSsl, ByteBufferPool bufferPool, OptionMap options)

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

io.undertow.server.handlers.proxy.mod_cluster back to summary

pack-priv Interface NodePingUtil.PingCallback

Method Summary

Modifier and Type	Method and Description
public void	completed() Ping completed.
public void	failed() Ping failed.

Method Detail

completed	back to summary
public void completed() Ping completed.

failed	back to summary
public void failed() Ping failed.

io.undertow.server.handlers.proxy.mod_cluster back to summary

pack-priv Class NodePingUtil.RequestExchangeListener

Class Inheritance

extends CancellableTask
implements ClientCallback<ClientExchange>

java.lang.Object
io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.CancellableTask
io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.RequestExchangeListener

All Implemented Interfaces

io.undertow.client.ClientCallback

Field Summary

Modifier and Type	Field and Description
private final boolean	closeConnection
private ClientExchange	exchange
private final NodeHealthChecker	healthChecker

Constructor Summary

Access	Constructor and Description
pack-priv	RequestExchangeListener(NodePingUtil.PingCallback callback, NodeHealthChecker healthChecker, boolean closeConnection)

Method Summary

Modifier and Type	Method and Description
public void	completed(final ClientExchange the operation result result) Implements io.undertow.client.ClientCallback.completed. Invoked when an operation completed.
public void	failed(IOException the exception e) Implements io.undertow.client.ClientCallback.failed. Invoked when the operation failed.

Inherited from io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.CancellableTask:: cancel isDone setCancelKey taskCompleted taskFailed

Field Detail

closeConnection	back to summary
private final boolean closeConnection

exchange	back to summary
private ClientExchange exchange

healthChecker	back to summary
private final NodeHealthChecker healthChecker

Constructor Detail

RequestExchangeListener	back to summary
pack-priv RequestExchangeListener(NodePingUtil.PingCallback callback, NodeHealthChecker healthChecker, boolean closeConnection)

Method Detail

completed

back to summary

public void completed(final ClientExchange result)

Implements io.undertow.client.ClientCallback.completed.

Doc from io.undertow.client.ClientCallback.completed.

Invoked when an operation completed.

Parameters

result:ClientExchange: the operation result

Annotations

@Override

failed

back to summary

public void failed(IOException e)

Implements io.undertow.client.ClientCallback.failed.

Doc from io.undertow.client.ClientCallback.failed.

Invoked when the operation failed.

Parameters

e:IOException: the exception

Annotations

@Override

io.undertow.server.handlers.proxy.mod_cluster back to summary

pack-priv final Enum NodePingUtil.State

Class Inheritance

extends Enum<NodePingUtil.State>

java.lang.Object
java.lang.Enum
io.undertow.server.handlers.proxy.mod_cluster.NodePingUtil.State

Field Summary

Modifier and Type	Field and Description
public static final NodePingUtil.State	CANCELLED
public static final NodePingUtil.State	DONE
public static final NodePingUtil.State	WAITING

Constructor Summary

Access	Constructor and Description
private	State()

Method Summary

Modifier and Type	Method and Description
public static NodePingUtil.State	valueOf(String name)
public static NodePingUtil.State[]	values()

Inherited from java.lang.Enum:: clone compareTo describeConstable equals finalize getDeclaringClass hashCode name ordinal toString valueOf

Field Detail

CANCELLED	back to summary
public static final NodePingUtil.State CANCELLED

DONE	back to summary
public static final NodePingUtil.State DONE

WAITING	back to summary
public static final NodePingUtil.State WAITING

Constructor Detail

State	back to summary
private State()

Method Detail

valueOf	back to summary
public static NodePingUtil.State valueOf(String name)

values	back to summary
public static NodePingUtil.State[] values()