com.tangosol.net

Class LoadBalancer.ResponseHandler

java.lang.Object

com.tangosol.util.Base

com.tangosol.util.Daemon

com.tangosol.net.LoadBalancer.SocketHandler

com.tangosol.net.LoadBalancer.ResponseHandler

All Implemented Interfaces:

Guardable, Runnable

Enclosing class:

LoadBalancer

public class LoadBalancer.ResponseHandler
extends LoadBalancer.SocketHandler

A ResponseHandler is a daemon thread that processes an outgoing response from a destination server.

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, Base.StackFrame

Field Summary

Fields

Modifier and Type	Field and Description
protected LoadBalancer.RequestHandler	m_daemonRequest The RequestHandler that this ResponseHandler belongs to.
protected Socket	m_socketClient The Socket to write the response to.
protected Socket	m_socketServer The Socket to read the response from.

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

m_abBuf

Fields inherited from class com.tangosol.util.Base

LOG_ALWAYS, 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 and Description
ResponseHandler(LoadBalancer.RequestHandler daemonRequest) Construct a ResponseHandler that belongs to the specified RequestHandler.

Method Summary

Modifier and Type	Method and Description
void	relayResponse(Socket socketServer, Socket socketClient) This method is used to assign a task to the ResponseHandler thread from the RequestHandler thread.
void	run() Processing loop for the ResponseHandler 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, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mod, mod, 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 Detail

m_daemonRequest

protected LoadBalancer.RequestHandler m_daemonRequest

The RequestHandler that this ResponseHandler belongs to.

m_socketServer

protected Socket m_socketServer

The Socket to read the response from.

m_socketClient

protected Socket m_socketClient

The Socket to write the response to.

Constructor Detail

ResponseHandler

public ResponseHandler(LoadBalancer.RequestHandler daemonRequest)

Construct a ResponseHandler that belongs to the specified RequestHandler.

Parameters:

daemonRequest - the RequestHandler that this ResponseHandler belongs to

Method Detail

run

public void run()

Processing loop for the ResponseHandler daemon.

Specified by:

run in interface Runnable

Specified by:

run in class LoadBalancer.SocketHandler

relayResponse

public void relayResponse(Socket socketServer,
                          Socket socketClient)

This method is used to assign a task to the ResponseHandler thread from the RequestHandler thread.

Parameters:

socketServer - the socket to copy from

socketClient - the socket to copy to