Modifier and Type	Class and Description
private class	Node.NodeConnectionPoolManager
pack-priv static class	Node.VHostMapping

Field Summary

Modifier and Type	Field and Description
private static final int	ACTIVE_PING
private final Balancer	balancerConfig
private final ByteBufferPool	bufferPool
private final ProxyConnectionPool	connectionPool
private final ConnectionPoolManager	connectionPoolManager
private final ModClusterContainer	container
private final List<Context>	contexts
private static final int	ERROR
private static final int	ERROR_MASK
private static final int	HOT_STANDBY
private final int	id
private static final AtomicInteger	idGen
private final XnioIoThread	ioThread
private final String	jvmRoute
private final NodeLbStatus	lbStatus
private final NodeConfig	nodeConfig
private static final int	REMOVED
private volatile int	state
private static final AtomicIntegerFieldUpdater<Node>	stateUpdater
pack-priv static final AtomicInteger	vHostIdGen
private final List<Node.VHostMapping>	vHosts

Access	Constructor and Description
protected	Node(NodeConfig nodeConfig, Balancer balancerConfig, XnioIoThread ioThread, ByteBufferPool bufferPool, ModClusterContainer container)

Method Summary

Modifier and Type	Method and Description
protected boolean	checkAvailable(final boolean existingSession)
protected void	checkHealth(long the threshold after which the node should be removed threshold, NodeHealthChecker the node health checker healthChecker) Check the health of the node and try to ping it if necessary.
private void	clearActivePing()
pack-priv void	elected() This node got elected to serve a request!
public Balancer	getBalancer()
public ProxyConnectionPool	Returns: the connection pool getConnectionPool() Get or create the connection pool for this node.
pack-priv Context	Returns: the context, `null` if there is no matching context getContext(final String the context path path, List<String> the aliases aliases) Get a context.
pack-priv Collection<Context>	getContexts()
public int	getElected()
pack-priv int	getElectedDiff()
public int	getId()
pack-priv XnioIoThread	getIoThread()
public String	Returns: the jvmRoute getJvmRoute() Get the JVM route.
public int	Returns: the node load getLoad() Get the load information.
public int	Returns: the load status getLoadStatus() Get the current load status, based on the number of elections and the current load;
public NodeConfig	getNodeConfig()
public NodeStatus	getStatus()
pack-priv List<Node.VHostMapping>	getVHosts()
private int	healthCheckFailed() Mark a node in error.
pack-priv void	healthCheckPing(final long threshold, NodeHealthChecker healthChecker)
protected void	hotStandby()
pack-priv boolean	isHotStandby()
protected boolean	isInErrorState()
protected void	markInError()
protected void	markRemoved()
pack-priv void	ping(final HttpServerExchange the http server exchange exchange, final NodePingUtil.PingCallback the ping callback callback) Async ping from the user
pack-priv Context	Returns: the created context registerContext(final String the context path path, final List<String> virtualHosts) Register a context.
pack-priv Context	removeContext(final String path, final List<String> aliases)
pack-priv void	resetLbStatus()
protected void	resetState()
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
protected void	updateLoad(final int i)

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

Field Detail

ACTIVE_PING	back to summary
private static final int ACTIVE_PING

balancerConfig	back to summary
private final Balancer balancerConfig

bufferPool	back to summary
private final ByteBufferPool bufferPool

connectionPool	back to summary
private final ProxyConnectionPool connectionPool

connectionPoolManager	back to summary
private final ConnectionPoolManager connectionPoolManager

container	back to summary
private final ModClusterContainer container

container

back to summary

private final ModClusterContainer container

contexts	back to summary
private final List<Context> contexts

ERROR	back to summary
private static final int ERROR

ERROR_MASK	back to summary
private static final int ERROR_MASK

HOT_STANDBY	back to summary
private static final int HOT_STANDBY

id	back to summary
private final int id

idGen	back to summary
private static final AtomicInteger idGen

ioThread	back to summary
private final XnioIoThread ioThread

jvmRoute	back to summary
private final String jvmRoute

lbStatus	back to summary
private final NodeLbStatus lbStatus

nodeConfig	back to summary
private final NodeConfig nodeConfig

REMOVED	back to summary
private static final int REMOVED

state	back to summary
private volatile int state

stateUpdater	back to summary
private static final AtomicIntegerFieldUpdater<Node> stateUpdater

vHostIdGen	back to summary
pack-priv static final AtomicInteger vHostIdGen

vHosts	back to summary
private final List<Node.VHostMapping> vHosts

Node	back to summary
protected Node(NodeConfig nodeConfig, Balancer balancerConfig, XnioIoThread ioThread, ByteBufferPool bufferPool, ModClusterContainer container)

Method Detail

checkAvailable	back to summary
protected boolean checkAvailable(final boolean existingSession)

checkHealth	back to summary
protected void checkHealth(long threshold, NodeHealthChecker healthChecker) Check the health of the node and try to ping it if necessary. Parameters threshold:long the threshold after which the node should be removed healthChecker:NodeHealthChecker the node health checker

checkHealth

back to summary

protected void checkHealth(long threshold, NodeHealthChecker healthChecker)

Check the health of the node and try to ping it if necessary.

Parameters

threshold:long: the threshold after which the node should be removed
healthChecker:NodeHealthChecker: the node health checker

clearActivePing	back to summary
private void clearActivePing()

elected	back to summary
pack-priv void elected() This node got elected to serve a request!

getBalancer	back to summary
public Balancer getBalancer()

getConnectionPool	back to summary
public ProxyConnectionPool getConnectionPool() Get or create the connection pool for this node. Returns:ProxyConnectionPool the connection pool

getConnectionPool

back to summary

public ProxyConnectionPool getConnectionPool()

Get or create the connection pool for this node.

Returns:ProxyConnectionPool: the connection pool

getContext back to summary

getContext	back to summary
pack-priv Context getContext(final String path, List<String> aliases) Get a context. Parameters path:String the context path aliases:List<String> the aliases Returns:Context the context, `null` if there is no matching context

pack-priv Context getContext(final String path, List<String> aliases)

Get a context.

Parameters

path:String: the context path
aliases:List<String>: the aliases

Returns:Context

the context, null if there is no matching context

getContexts	back to summary
pack-priv Collection<Context> getContexts()

getElected	back to summary
public int getElected()

getElectedDiff	back to summary
pack-priv int getElectedDiff()

getId	back to summary
public int getId()

getIoThread	back to summary
pack-priv XnioIoThread getIoThread()

getJvmRoute	back to summary
public String getJvmRoute() Get the JVM route. Returns:String the jvmRoute

getJvmRoute

back to summary

public String getJvmRoute()

Get the JVM route.

Returns:String: the jvmRoute

getLoad	back to summary
public int getLoad() Get the load information. Add the error information for clients. Returns:int the node load

getLoad

back to summary

public int getLoad()

Get the load information. Add the error information for clients.

Returns:int: the node load

getLoadStatus	back to summary
public int getLoadStatus() Get the current load status, based on the number of elections and the current load; Returns:int the load status

getLoadStatus

back to summary

public int getLoadStatus()

Get the current load status, based on the number of elections and the current load;

Returns:int: the load status

getNodeConfig	back to summary
public NodeConfig getNodeConfig()

getStatus	back to summary
public NodeStatus getStatus()

getVHosts	back to summary
pack-priv List<Node.VHostMapping> getVHosts()

healthCheckFailed	back to summary
private int healthCheckFailed() Mark a node in error. Mod_cluster has a threshold after which broken nodes get removed.

healthCheckPing	back to summary
pack-priv void healthCheckPing(final long threshold, NodeHealthChecker healthChecker)

hotStandby	back to summary
protected void hotStandby()

isHotStandby	back to summary
pack-priv boolean isHotStandby()

isInErrorState	back to summary
protected boolean isInErrorState()

markInError	back to summary
protected void markInError()

markRemoved	back to summary
protected void markRemoved()

ping

back to summary

pack-priv void ping(final HttpServerExchange exchange, final NodePingUtil.PingCallback callback)

Async ping from the user

Parameters

exchange:HttpServerExchange: the http server exchange
callback:NodePingUtil.PingCallback: the ping callback

registerContext

back to summary

pack-priv Context registerContext(final String path, final List<String> virtualHosts)

Parameters

path:String: the context path

Returns:Context

the created context

removeContext	back to summary
pack-priv Context removeContext(final String path, final List<String> aliases)

resetLbStatus	back to summary
pack-priv void resetLbStatus()

resetState	back to summary
protected void resetState()

toString back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

updateLoad	back to summary
protected void updateLoad(final int i)

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

private Class Node.NodeConnectionPoolManager

Class Inheritance

extends Object
implements ConnectionPoolManager

java.lang.Object
io.undertow.server.handlers.proxy.mod_cluster.Node.NodeConnectionPoolManager

All Implemented Interfaces

io.undertow.server.handlers.proxy.ConnectionPoolManager, io.undertow.server.handlers.proxy.ConnectionPoolErrorHandler, io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig

Constructor Summary

Access	Constructor and Description
private	NodeConnectionPoolManager()

Method Summary

Modifier and Type	Method and Description
public boolean	clearError() Implements io.undertow.server.handlers.proxy.ConnectionPoolErrorHandler.clearError. Clear the connection errors.
public int	getMaxCachedConnections() Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxCachedConnections. Get the maximum number of cached (idle) connections per thread.
public int	getMaxConnections() Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxConnections. Get the maximum number of connections per thread.
public int	getMaxQueueSize() Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxQueueSize. Get the maximum number of requests which can be queued if there are no connections available.
public int	getProblemServerRetry() Implements io.undertow.server.handlers.proxy.ConnectionPoolManager.getProblemServerRetry.
public int	getSMaxConnections() Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getSMaxConnections. Get number of cached connections above which are closed after the time to live.
public long	getTtl() Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getTtl. Get the time to live for idle connections.
public boolean	handleError() Implements io.undertow.server.handlers.proxy.ConnectionPoolErrorHandler.handleError. Handle a connection error.
public boolean	isAvailable() Implements io.undertow.server.handlers.proxy.ConnectionPoolErrorHandler.isAvailable. Check whether pool is available