Class MemcachedTCPSession

java.lang.Object

com.google.code.yanf4j.core.impl.AbstractSession

com.google.code.yanf4j.nio.impl.AbstractNioSession

com.google.code.yanf4j.nio.impl.NioTCPSession

net.rubyeye.xmemcached.impl.MemcachedTCPSession

All Implemented Interfaces:

Session, NioSession, ClosedMemcachedSession, MemcachedSession

public class MemcachedTCPSession
extends NioTCPSession
implements MemcachedSession

Connected session for a memcached server

Nested Class Summary

Nested classes/interfaces inherited from interface Session

Session.SessionStatus

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	allowReconnect
private boolean	authFailed
private BufferAllocator	bufferAllocator
protected BlockingQueue<Command>	commandAlreadySent	Command which are already sent
private final CommandFactory	commandFactory
private final AtomicReference<Command>	currentCommand
private InetSocketAddressWrapper	inetSocketAddressWrapper
private final MemcachedOptimizer	optimiezer
private SocketAddress	remoteSocketAddress
private int	sendBufferSize

Fields inherited from class AbstractNioSession

selectableChannel, selectorManager

Fields inherited from class AbstractSession

attributes, closed, currentMessage, decoder, dispatchMessageDispatcher, encoder, handler, handleReadWriteConcurrently, lastOperationTimeStamp, log, loopback, readBuffer, scheduleWritenBytes, sessionIdleTimeout, sessionTimeout, statistics, useBlockingRead, useBlockingWrite, writeLock, writeQueue

Constructor Summary

Constructors

Constructor	Description
MemcachedTCPSession(NioSessionConfig sessionConfig, int readRecvBufferSize, MemcachedOptimizer optimiezer, int readThreadCount, CommandFactory commandFactory)

Method Summary

Modifier and Type	Method	Description
void	addCommand(Command command)
void	destroy()
final BufferAllocator	getBufferAllocator()
Command	getCurrentCommand()
InetSocketAddressWrapper	getInetSocketAddressWrapper()
int	getOrder()
InetSocketAddress	getRemoteSocketAddress()	Return the remote end's InetSocketAddress
int	getWeight()
boolean	isAllowReconnect()	is allow auto recconect if closed?
boolean	isAuthFailed()
protected WriteMessage	preprocessWriteMessage(WriteMessage writeMessage)	Pre-Process WriteMessage before writing to channel
void	quit()
void	setAllowReconnect(boolean reconnected)
void	setAuthFailed(boolean authFailed)
final void	setBufferAllocator(BufferAllocator bufferAllocator)
void	setCurrentCommand(Command cmd)
void	setInetSocketAddressWrapper(InetSocketAddressWrapper inetSocketAddressWrapper)
void	takeCurrentCommand()
private Command	takeExecutingCommand()	get current command from queue
String	toString()
protected final WriteMessage	wrapMessage(Object msg, Future<Boolean> writeFuture)

Methods inherited from class NioTCPSession

blockingRead, blockingWrite, closeChannel, decode, isExpired, readFromBuffer, socket, writeToChannel

Methods inherited from class AbstractNioSession

channel, doRealWrite, enableRead, enableWrite, flush, flush0, getLocalAddress, onEvent, onRead, onWrite, registerSession, schduleWriteMessage, start0, unregisterChannel, unregisterSession, writeFromUserCode

Methods inherited from class AbstractSession

clearAttributes, clearWriteQueue, close, dispatchReceivedMessage, getAttribute, getDecoder, getDispatchMessageDispatcher, getEncoder, getHandler, getLastOperationTimeStamp, getReadBuffer, getReadBufferByteOrder, getScheduleWritenBytes, getSessionIdleTimeout, getSessionTimeout, getStatistics, getWriteLock, getWriteQueue, isClosed, isHandleReadWriteConcurrently, isIdle, isLoopbackConnection, isUseBlockingRead, isUseBlockingWrite, onClosed, onConnected, onCreated, onException, onExpired, onIdle, onStarted, removeAttribute, setAttribute, setAttributeIfAbsent, setClosed, setDecoder, setEncoder, setHandleReadWriteConcurrently, setReadBuffer, setReadBufferByteOrder, setSessionIdleTimeout, setSessionTimeout, setUseBlockingRead, setUseBlockingWrite, start, transferFrom, transferTo, updateTimeStamp, write

Methods inherited from class Object

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

Methods inherited from interface Session

clearAttributes, close, flush, getAttribute, getDecoder, getEncoder, getHandler, getLastOperationTimeStamp, getLocalAddress, getReadBufferByteOrder, getScheduleWritenBytes, getSessionIdleTimeout, getSessionTimeout, isClosed, isExpired, isHandleReadWriteConcurrently, isIdle, isLoopbackConnection, isUseBlockingRead, isUseBlockingWrite, removeAttribute, setAttribute, setAttributeIfAbsent, setDecoder, setEncoder, setHandleReadWriteConcurrently, setReadBufferByteOrder, setSessionIdleTimeout, setSessionTimeout, setUseBlockingRead, setUseBlockingWrite, start, write

Field Details

commandAlreadySent

protected BlockingQueue<Command> commandAlreadySent

Command which are already sent

currentCommand

private final AtomicReference<Command> currentCommand

remoteSocketAddress

private SocketAddress remoteSocketAddress

sendBufferSize

private int sendBufferSize

optimiezer

private final MemcachedOptimizer optimiezer

allowReconnect

private boolean allowReconnect

authFailed

private volatile boolean authFailed

commandFactory

private final CommandFactory commandFactory

inetSocketAddressWrapper

private InetSocketAddressWrapper inetSocketAddressWrapper

bufferAllocator

private BufferAllocator bufferAllocator

Constructor Details

MemcachedTCPSession

public MemcachedTCPSession(NioSessionConfig sessionConfig,
 int readRecvBufferSize,
 MemcachedOptimizer optimiezer,
 int readThreadCount,
 CommandFactory commandFactory)

Method Details

getInetSocketAddressWrapper

public InetSocketAddressWrapper getInetSocketAddressWrapper()

Specified by:

getInetSocketAddressWrapper in interface ClosedMemcachedSession

getOrder

public int getOrder()

Specified by:

getOrder in interface ClosedMemcachedSession

getWeight

public int getWeight()

Specified by:

getWeight in interface ClosedMemcachedSession

setInetSocketAddressWrapper

public void setInetSocketAddressWrapper(InetSocketAddressWrapper inetSocketAddressWrapper)

toString

public String toString()

Overrides:

toString in class Object

destroy

public void destroy()

Specified by:

destroy in interface MemcachedSession

getRemoteSocketAddress

public InetSocketAddress getRemoteSocketAddress()

Description copied from interface: Session

Return the remote end's InetSocketAddress

Specified by:

getRemoteSocketAddress in interface Session

Overrides:

getRemoteSocketAddress in class NioTCPSession

Returns:

preprocessWriteMessage

protected WriteMessage preprocessWriteMessage(WriteMessage writeMessage)

Description copied from class: AbstractSession

Pre-Process WriteMessage before writing to channel

Overrides:

preprocessWriteMessage in class AbstractSession

Parameters:

writeMessage -

Returns:

isAuthFailed

public boolean isAuthFailed()

Specified by:

isAuthFailed in interface MemcachedSession

setAuthFailed

public void setAuthFailed(boolean authFailed)

Specified by:

setAuthFailed in interface MemcachedSession

getBufferAllocator

public final BufferAllocator getBufferAllocator()

setBufferAllocator

public final void setBufferAllocator(BufferAllocator bufferAllocator)

Specified by:

setBufferAllocator in interface MemcachedSession

wrapMessage

protected final WriteMessage wrapMessage(Object msg,
 Future<Boolean> writeFuture)

Overrides:

wrapMessage in class NioTCPSession

takeExecutingCommand

private Command takeExecutingCommand()

get current command from queue

Returns:

isAllowReconnect

public boolean isAllowReconnect()

is allow auto recconect if closed?

Specified by:

isAllowReconnect in interface ClosedMemcachedSession

Returns:

setAllowReconnect

public void setAllowReconnect(boolean reconnected)

Specified by:

setAllowReconnect in interface ClosedMemcachedSession

addCommand

public void addCommand(Command command)

setCurrentCommand

public void setCurrentCommand(Command cmd)

getCurrentCommand

public Command getCurrentCommand()

takeCurrentCommand

public void takeCurrentCommand()

quit

public void quit()

Specified by:

quit in interface MemcachedSession