Package net.rubyeye.xmemcached.impl

Class ClosedMemcachedTCPSession

java.lang.Object

net.rubyeye.xmemcached.impl.ClosedMemcachedTCPSession

All Implemented Interfaces:

Session, ClosedMemcachedSession, MemcachedSession

public class ClosedMemcachedTCPSession
extends java.lang.Object
implements ClosedMemcachedSession, MemcachedSession

Closed session

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.code.yanf4j.core.Session

Session.SessionStatus

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	allowReconnect
private boolean	authFailed
private InetSocketAddressWrapper	inetSocketAddressWrapper

Constructor Summary

Constructors

Constructor	Description
ClosedMemcachedTCPSession(InetSocketAddressWrapper inetSocketAddressWrapper)

Method Summary

Modifier and Type	Method	Description
void	clearAttributes()	Clear attributes
void	close()	Close session
void	destroy()
void	flush()	Flush the write queue,this method may be no effect if OP_WRITE is running.
java.lang.Object	getAttribute(java.lang.String key)	Return attribute associated with key
CodecFactory.Decoder	getDecoder()	Return current decoder
CodecFactory.Encoder	getEncoder()	Return current encoder
Handler	getHandler()
InetSocketAddressWrapper	getInetSocketAddressWrapper()
long	getLastOperationTimeStamp()	Return last operation timestamp,operation include read,write,idle
java.net.InetAddress	getLocalAddress()
int	getOrder()
java.nio.ByteOrder	getReadBufferByteOrder()	Return the session read buffer's byte order,big end or little end.
java.net.InetSocketAddress	getRemoteSocketAddress()	Return the remote end's InetSocketAddress
long	getScheduleWritenBytes()	Return the bytes in write queue,there bytes is in memory.Use this method to controll writing speed.
long	getSessionIdleTimeout()
long	getSessionTimeout()
int	getWeight()
boolean	isAllowReconnect()
boolean	isAuthFailed()
boolean	isClosed()	Check if session is closed
boolean	isExpired()	Return true if session is expired,session is expired beacause you set the sessionTimeout,if since session's last operation form now is over this vlaue,isExpired return true,and Handler.onExpired() will be invoked.
boolean	isHandleReadWriteConcurrently()	Return true if allow handling read and write concurrently,default is true.
boolean	isIdle()	Check if session is idle
boolean	isLoopbackConnection()	return true if it is a loopback connection
boolean	isUseBlockingRead()	Return true if using blocking read
boolean	isUseBlockingWrite()	Return true if using blocking write
void	quit()
void	removeAttribute(java.lang.String key)	Remove attribute
void	setAllowReconnect(boolean allow)
void	setAttribute(java.lang.String key, java.lang.Object value)	Set a attribute attched with this session
java.lang.Object	setAttributeIfAbsent(java.lang.String key, java.lang.Object value)
void	setAuthFailed(boolean authFailed)
void	setBufferAllocator(BufferAllocator allocator)
void	setDecoder(CodecFactory.Decoder decoder)
void	setEncoder(CodecFactory.Encoder encoder)	Set encoder
void	setHandleReadWriteConcurrently(boolean handleReadWriteConcurrently)
void	setReadBufferByteOrder(java.nio.ByteOrder readBufferByteOrder)
void	setSessionIdleTimeout(long sessionIdleTimeout)
void	setSessionTimeout(long sessionTimeout)
void	setUseBlockingRead(boolean useBlockingRead)
void	setUseBlockingWrite(boolean useBlockingWrite)	Set if using blocking write
void	start()	Start session
void	write(java.lang.Object packet)	Write a message,if you don't care when the message is written

Methods inherited from class java.lang.Object

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

Field Detail

inetSocketAddressWrapper

private InetSocketAddressWrapper inetSocketAddressWrapper

allowReconnect

private volatile boolean allowReconnect

authFailed

private volatile boolean authFailed

Constructor Detail

ClosedMemcachedTCPSession

public ClosedMemcachedTCPSession(InetSocketAddressWrapper inetSocketAddressWrapper)

Method Detail

setBufferAllocator

public void setBufferAllocator(BufferAllocator allocator)

Specified by:

setBufferAllocator in interface MemcachedSession

destroy

public void destroy()

Specified by:

destroy in interface MemcachedSession

quit

public void quit()

Specified by:

quit in interface MemcachedSession

isAuthFailed

public boolean isAuthFailed()

Specified by:

isAuthFailed in interface MemcachedSession

setAuthFailed

public void setAuthFailed(boolean authFailed)

Specified by:

setAuthFailed in interface MemcachedSession

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

isAllowReconnect

public boolean isAllowReconnect()

Specified by:

isAllowReconnect in interface ClosedMemcachedSession

setAllowReconnect

public void setAllowReconnect(boolean allow)

Specified by:

setAllowReconnect in interface ClosedMemcachedSession

clearAttributes

public void clearAttributes()

Description copied from interface: Session

Clear attributes

Specified by:

clearAttributes in interface Session

close

public void close()

Description copied from interface: Session

Close session

Specified by:

close in interface Session

flush

public void flush()

Description copied from interface: Session

Flush the write queue,this method may be no effect if OP_WRITE is running.

Specified by:

flush in interface Session

getAttribute

public java.lang.Object getAttribute(java.lang.String key)

Description copied from interface: Session

Return attribute associated with key

Specified by:

getAttribute in interface Session

Returns:

getDecoder

public CodecFactory.Decoder getDecoder()

Description copied from interface: Session

Return current decoder

Specified by:

getDecoder in interface Session

Returns:

getEncoder

public CodecFactory.Encoder getEncoder()

Description copied from interface: Session

Return current encoder

Specified by:

getEncoder in interface Session

Returns:

getHandler

public Handler getHandler()

Specified by:

getHandler in interface Session

getLastOperationTimeStamp

public long getLastOperationTimeStamp()

Description copied from interface: Session

Return last operation timestamp,operation include read,write,idle

Specified by:

getLastOperationTimeStamp in interface Session

Returns:

getLocalAddress

public java.net.InetAddress getLocalAddress()

Specified by:

getLocalAddress in interface Session

getReadBufferByteOrder

public java.nio.ByteOrder getReadBufferByteOrder()

Description copied from interface: Session

Return the session read buffer's byte order,big end or little end.

Specified by:

getReadBufferByteOrder in interface Session

Returns:

getRemoteSocketAddress

public java.net.InetSocketAddress getRemoteSocketAddress()

Description copied from interface: Session

Return the remote end's InetSocketAddress

Specified by:

getRemoteSocketAddress in interface Session

Returns:

getScheduleWritenBytes

public long getScheduleWritenBytes()

Description copied from interface: Session

Return the bytes in write queue,there bytes is in memory.Use this method to controll writing speed.

Specified by:

getScheduleWritenBytes in interface Session

Returns:

getSessionIdleTimeout

public long getSessionIdleTimeout()

Specified by:

getSessionIdleTimeout in interface Session

getSessionTimeout

public long getSessionTimeout()

Specified by:

getSessionTimeout in interface Session

isClosed

public boolean isClosed()

Description copied from interface: Session

Check if session is closed

Specified by:

isClosed in interface Session

Returns:

isExpired

public boolean isExpired()

Description copied from interface: Session

Return true if session is expired,session is expired beacause you set the sessionTimeout,if since session's last operation form now is over this vlaue,isExpired return true,and Handler.onExpired() will be invoked.

Specified by:

isExpired in interface Session

Returns:

isHandleReadWriteConcurrently

public boolean isHandleReadWriteConcurrently()

Description copied from interface: Session

Return true if allow handling read and write concurrently,default is true.

Specified by:

isHandleReadWriteConcurrently in interface Session

Returns:

isIdle

public boolean isIdle()

Description copied from interface: Session

Check if session is idle

Specified by:

isIdle in interface Session

Returns:

isLoopbackConnection

public boolean isLoopbackConnection()

Description copied from interface: Session

return true if it is a loopback connection

Specified by:

isLoopbackConnection in interface Session

Returns:

isUseBlockingRead

public boolean isUseBlockingRead()

Description copied from interface: Session

Return true if using blocking read

Specified by:

isUseBlockingRead in interface Session

Returns:

isUseBlockingWrite

public boolean isUseBlockingWrite()

Description copied from interface: Session

Return true if using blocking write

Specified by:

isUseBlockingWrite in interface Session

Returns:

removeAttribute

public void removeAttribute(java.lang.String key)

Description copied from interface: Session

Remove attribute

Specified by:

removeAttribute in interface Session

setAttribute

public void setAttribute(java.lang.String key,
                         java.lang.Object value)

Description copied from interface: Session

Set a attribute attched with this session

Specified by:

setAttribute in interface Session

setAttributeIfAbsent

public java.lang.Object setAttributeIfAbsent(java.lang.String key,
                                             java.lang.Object value)

Specified by:

setAttributeIfAbsent in interface Session

setDecoder

public void setDecoder(CodecFactory.Decoder decoder)

Specified by:

setDecoder in interface Session

setEncoder

public void setEncoder(CodecFactory.Encoder encoder)

Description copied from interface: Session

Set encoder

Specified by:

setEncoder in interface Session

setHandleReadWriteConcurrently

public void setHandleReadWriteConcurrently(boolean handleReadWriteConcurrently)

Specified by:

setHandleReadWriteConcurrently in interface Session

setReadBufferByteOrder

public void setReadBufferByteOrder(java.nio.ByteOrder readBufferByteOrder)

Specified by:

setReadBufferByteOrder in interface Session

setSessionIdleTimeout

public void setSessionIdleTimeout(long sessionIdleTimeout)

Specified by:

setSessionIdleTimeout in interface Session

setSessionTimeout

public void setSessionTimeout(long sessionTimeout)

Specified by:

setSessionTimeout in interface Session

setUseBlockingRead

public void setUseBlockingRead(boolean useBlockingRead)

Specified by:

setUseBlockingRead in interface Session

setUseBlockingWrite

public void setUseBlockingWrite(boolean useBlockingWrite)

Description copied from interface: Session

Set if using blocking write

Specified by:

setUseBlockingWrite in interface Session

start

public void start()

Description copied from interface: Session

Start session

Specified by:

start in interface Session

write

public void write(java.lang.Object packet)

Description copied from interface: Session

Write a message,if you don't care when the message is written

Specified by:

write in interface Session