Package com.tangosol.net

Class LoadBalancer.RequestHandler

java.lang.Object

com.tangosol.util.Base

com.tangosol.util.Daemon

com.tangosol.net.LoadBalancer.SocketHandler

com.tangosol.net.LoadBalancer.RequestHandler

All Implemented Interfaces:

Guardable, Runnable

Enclosing class:

LoadBalancer

public class LoadBalancer.RequestHandler
extends LoadBalancer.SocketHandler

A RequestHandler is a daemon thread that processes a request from a queue.

Nested Class Summary

Nested classes/interfaces inherited from class com.tangosol.util.Daemon

Daemon.DaemonWorker

Nested classes/interfaces inherited from class com.tangosol.util.Base

Base.LoggingWriter

Field Summary

Fields

Modifier and Type	Field	Description
protected LoadBalancer.ResponseHandler	m_daemonResponse	The ResponseHandler that handles the server-to-client response routing corresponding to requests routed client-to-server by this daemon.
protected LoadBalancer.Queue	m_queue	The Queue that this RequestHandler listens to connections (Socket) on.

Fields inherited from class com.tangosol.net.LoadBalancer.SocketHandler

m_abBuf

Fields inherited from class com.tangosol.util.Base

DEFAULT_LOAD_FACTOR, LOG_ALWAYS, LOG_CONFIG, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US

Constructor Summary

Constructors

Constructor	Description
RequestHandler(LoadBalancer.Queue queue)	Constructs a RequestHandler that will pull request connections (Socket objects) from a Queue.

Method Summary

Modifier and Type	Method	Description
void	run()	Processing loop for the RequestHandler daemon.

Methods inherited from class com.tangosol.net.LoadBalancer.SocketHandler

copy, ensureBuffer, process

Methods inherited from class com.tangosol.util.Daemon

changeState, configureWorker, ensureThreadGroup, finishStarting, finishStopping, getConfiguredName, getConfiguredPriority, getContext, getDescription, getGuardRegisterAction, getMaxWaitMillis, getState, getThread, getThreadContextClassLoader, getWorker, guardIfNeeded, heartbeat, heartbeat, instantiateWorker, isGuarded, isOnWorkerThread, isRunning, isStopping, recover, setConfiguredName, setConfiguredPriority, setContext, setGuardPolicy, setGuardRegisterAction, setThreadContextClassLoader, shutdown, start, stop, terminate, toStateString, toString

Methods inherited from class com.tangosol.util.Base

azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, mod, mod, newHashMap, newHashMap, newHashSet, newHashSet, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait

Methods inherited from class java.lang.Object

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

Field Details

m_queue

protected LoadBalancer.Queue m_queue

The Queue that this RequestHandler listens to connections (Socket) on.

m_daemonResponse

protected LoadBalancer.ResponseHandler m_daemonResponse

The ResponseHandler that handles the server-to-client response routing corresponding to requests routed client-to-server by this daemon.

Constructor Details

RequestHandler

public RequestHandler(LoadBalancer.Queue queue)

Constructs a RequestHandler that will pull request connections (Socket objects) from a Queue.

Parameters:

queue - a Queue of Socket objects

Method Details

run

public void run()

Processing loop for the RequestHandler daemon.

Specified by:

run in interface Runnable

Specified by:

run in class LoadBalancer.SocketHandler