Uses of Interface
com.google.code.yanf4j.core.Session
-
Packages that use Session Package Description com.google.code.yanf4j.core Networking core packagecom.google.code.yanf4j.core.impl com.google.code.yanf4j.nio Nio implementationcom.google.code.yanf4j.nio.impl net.rubyeye.xmemcached XMemcached's main classes and interfaces,use these classes/interfaces to interact with memcached servers.net.rubyeye.xmemcached.codec Memcached protocol codecnet.rubyeye.xmemcached.command Memcached protocol implementationsnet.rubyeye.xmemcached.impl Manage tcp connection,memcached protocol optimized,and some MBeans for monitor.net.rubyeye.xmemcached.networking Networking layout to talk with memcached. -
-
Uses of Session in com.google.code.yanf4j.core
Methods in com.google.code.yanf4j.core with parameters of type Session Modifier and Type Method Description java.lang.Object
CodecFactory.Decoder. decode(IoBuffer buff, Session session)
IoBuffer
CodecFactory.Encoder. encode(java.lang.Object message, Session session)
void
Handler. onExceptionCaught(Session session, java.lang.Throwable throwable)
void
Handler. onMessageReceived(Session session, java.lang.Object msg)
void
Handler. onMessageSent(Session session, java.lang.Object msg)
void
Handler. onSessionClosed(Session session)
void
Handler. onSessionConnected(Session session)
void
Handler. onSessionCreated(Session session)
void
Handler. onSessionExpired(Session session)
void
Handler. onSessionIdle(Session session)
void
Handler. onSessionStarted(Session session)
void
SessionManager. registerSession(Session session)
Register session to controllervoid
SessionManager. unregisterSession(Session session)
Unregister session -
Uses of Session in com.google.code.yanf4j.core.impl
Classes in com.google.code.yanf4j.core.impl that implement Session Modifier and Type Class Description class
AbstractSession
Base connectionFields in com.google.code.yanf4j.core.impl with type parameters of type Session Modifier and Type Field Description protected java.util.Set<Session>
AbstractController. sessionSet
Connected session setMethods in com.google.code.yanf4j.core.impl that return types with arguments of type Session Modifier and Type Method Description java.util.Set<Session>
AbstractController. getSessionSet()
Methods in com.google.code.yanf4j.core.impl with parameters of type Session Modifier and Type Method Description java.lang.Object
ByteBufferCodecFactory.ByteBufferDecoder. decode(IoBuffer buff, Session session)
java.lang.Object
TextLineCodecFactory.StringDecoder. decode(IoBuffer buffer, Session session)
IoBuffer
ByteBufferCodecFactory.ByteBufferEncoder. encode(java.lang.Object message, Session session)
IoBuffer
TextLineCodecFactory.StringEncoder. encode(java.lang.Object msg, Session session)
void
HandlerAdapter. onExceptionCaught(Session session, java.lang.Throwable throwable)
private void
AbstractSession. onMessage(java.lang.Object message, Session session)
void
HandlerAdapter. onMessageReceived(Session session, java.lang.Object message)
void
HandlerAdapter. onMessageSent(Session session, java.lang.Object message)
void
HandlerAdapter. onSessionClosed(Session session)
void
HandlerAdapter. onSessionConnected(Session session)
void
HandlerAdapter. onSessionCreated(Session session)
void
HandlerAdapter. onSessionExpired(Session session)
void
HandlerAdapter. onSessionIdle(Session session)
void
HandlerAdapter. onSessionStarted(Session session)
void
AbstractController. registerSession(Session session)
void
AbstractController. unregisterSession(Session session)
-
Uses of Session in com.google.code.yanf4j.nio
Subinterfaces of Session in com.google.code.yanf4j.nio Modifier and Type Interface Description interface
NioSession
Nio connection -
Uses of Session in com.google.code.yanf4j.nio.impl
Classes in com.google.code.yanf4j.nio.impl that implement Session Modifier and Type Class Description class
AbstractNioSession
Abstract nio sessionclass
NioTCPSession
Nio tcp connectionFields in com.google.code.yanf4j.nio.impl declared as Session Modifier and Type Field Description (package private) Session
Reactor.RegisterEvent. session
Methods in com.google.code.yanf4j.nio.impl that return Session Modifier and Type Method Description private Session
Reactor. getSessionFromAttchment(java.nio.channels.SelectionKey key)
Methods in com.google.code.yanf4j.nio.impl with parameters of type Session Modifier and Type Method Description private boolean
Reactor. checkExpired(java.nio.channels.SelectionKey key, Session session)
private long
Reactor. checkExpiredIdle(java.nio.channels.SelectionKey key, Session session)
private void
Reactor. checkIdle(Session session)
private void
Reactor. dispatchSessionEvent(Session session, EventType event)
(package private) Reactor
SelectorManager. getReactorFromSession(Session session)
void
Reactor. registerSession(Session session, EventType event)
void
SelectorManager. registerSession(Session session, EventType event)
Register sessionConstructors in com.google.code.yanf4j.nio.impl with parameters of type Session Constructor Description RegisterEvent(Session session, EventType eventType)
-
Uses of Session in net.rubyeye.xmemcached
Methods in net.rubyeye.xmemcached that return Session Modifier and Type Method Description Session
MemcachedSessionLocator. getSessionByKey(java.lang.String key)
Returns a session by special key.protected Session
XMemcachedClient. sendCommand(Command cmd)
Methods in net.rubyeye.xmemcached with parameters of type Session Modifier and Type Method Description int
MemcachedSessionComparator. compare(Session o1, Session o2)
Returns a session by special key.private java.util.concurrent.atomic.AtomicInteger
XMemcachedClient. getContinuousTimeoutCounter(Session session)
protected void
XMemcachedClient. latchWait(Command cmd, long timeout, Session session)
Method parameters in net.rubyeye.xmemcached with type arguments of type Session Modifier and Type Method Description void
MemcachedSessionLocator. updateSessions(java.util.Collection<Session> list)
Update sessions when session was added or removed. -
Uses of Session in net.rubyeye.xmemcached.codec
Methods in net.rubyeye.xmemcached.codec with parameters of type Session Modifier and Type Method Description java.lang.Object
MemcachedDecoder. decode(IoBuffer buffer, Session origSession)
IoBuffer
MemcachedEncoder. encode(java.lang.Object message, Session session)
-
Uses of Session in net.rubyeye.xmemcached.command
Methods in net.rubyeye.xmemcached.command with parameters of type Session Modifier and Type Method Description protected boolean
Command. decodeError(Session session, java.nio.ByteBuffer buffer)
-
Uses of Session in net.rubyeye.xmemcached.impl
Classes in net.rubyeye.xmemcached.impl that implement Session Modifier and Type Class Description class
ClosedMemcachedTCPSession
Closed sessionclass
MemcachedTCPSession
Connected session for a memcached serverFields in net.rubyeye.xmemcached.impl declared as Session Modifier and Type Field Description private Session
MemcachedHandler.CheckHeartResultThread. session
Fields in net.rubyeye.xmemcached.impl with type parameters of type Session Modifier and Type Field Description private java.util.TreeMap<java.lang.Long,java.util.List<Session>>
KetamaMemcachedSessionLocator. ketamaSessions
private java.util.TreeMap<java.lang.Long,java.util.List<Session>>
LibmemcachedMemcachedSessionLocator. ketamaSessions
protected java.util.concurrent.ConcurrentHashMap<java.net.InetSocketAddress,java.util.Queue<Session>>
MemcachedConnector. sessionMap
private java.util.List<java.util.List<Session>>
ArrayMemcachedSessionLocator. sessions
private java.util.List<Session>
ElectionMemcachedSessionLocator. sessions
private java.util.List<Session>
PHPMemcacheSessionLocator. sessions
private java.util.List<Session>
RandomMemcachedSessionLocaltor. sessions
private java.util.List<Session>
RoundRobinMemcachedSessionLocator. sessions
private java.util.concurrent.ConcurrentHashMap<java.net.InetSocketAddress,java.util.List<Session>>
MemcachedConnector. standbySessionMap
Methods in net.rubyeye.xmemcached.impl that return Session Modifier and Type Method Description Session
MemcachedConnector. findSessionByKey(java.lang.String key)
private Session
ArrayMemcachedSessionLocator. getRandomSession(java.util.List<Session> sessions)
private Session
ElectionMemcachedSessionLocator. getSessionByElection(java.lang.String key, java.util.List<Session> copySessionList)
Session
KetamaMemcachedSessionLocator. getSessionByHash(long hash)
Session
LibmemcachedMemcachedSessionLocator. getSessionByHash(long hash)
Session
ArrayMemcachedSessionLocator. getSessionByKey(java.lang.String key)
Session
ElectionMemcachedSessionLocator. getSessionByKey(java.lang.String key)
Session
KetamaMemcachedSessionLocator. getSessionByKey(java.lang.String key)
Session
LibmemcachedMemcachedSessionLocator. getSessionByKey(java.lang.String key)
Session
PHPMemcacheSessionLocator. getSessionByKey(java.lang.String key)
Session
RandomMemcachedSessionLocaltor. getSessionByKey(java.lang.String key)
Session
RoundRobinMemcachedSessionLocator. getSessionByKey(java.lang.String key)
Session
MemcachedConnector. send(Command msg)
Methods in net.rubyeye.xmemcached.impl that return types with arguments of type Session Modifier and Type Method Description java.util.Queue<Session>
MemcachedConnector. getSessionByAddress(java.net.InetSocketAddress addr)
Get session by InetSocketAddressprivate java.util.List<Session>
KetamaMemcachedSessionLocator. getSessionList(java.util.TreeMap<java.lang.Long,java.util.List<Session>> sessionMap, long k)
private java.util.List<Session>
LibmemcachedMemcachedSessionLocator. getSessionList(java.util.TreeMap<java.lang.Long,java.util.List<Session>> sessionMap, long k)
java.util.List<Session>
MemcachedConnector. getSessionListBySocketAddress(java.net.InetSocketAddress inetSocketAddress)
java.util.Set<Session>
MemcachedConnector. getSessionSet()
java.util.List<Session>
MemcachedConnector. getStandbySessionListByMainNodeAddr(java.net.InetSocketAddress addr)
Returns main node's standby session list.Methods in net.rubyeye.xmemcached.impl with parameters of type Session Modifier and Type Method Description private void
MemcachedConnector. addMainSession(Session session, java.net.InetSocketAddress lastReolvedAddr, InetSocketAddressWrapper addrWrapper)
void
MemcachedConnector. addSession(Session session)
private void
MemcachedConnector. addStandbySession(Session session, java.net.InetSocketAddress mainNodeAddress, java.net.InetSocketAddress lastResolvedMainAddr, InetSocketAddressWrapper addrWrapper)
private void
MemcachedHandler. checkHeartBeat(Session session)
int
AddressMemcachedSessionComparator. compare(Session o1, Session o2)
int
IndexMemcachedSessionComparator. compare(Session o1, Session o2)
private java.lang.String
KetamaMemcachedSessionLocator. getSockStr(Session session)
void
MemcachedHandler. onExceptionCaught(Session session, java.lang.Throwable throwable)
void
MemcachedHandler. onMessageReceived(Session session, java.lang.Object msg)
On receive message from memcached servervoid
MemcachedHandler. onMessageSent(Session session, java.lang.Object msg)
put command which have been sent to queuevoid
MemcachedHandler. onSessionClosed(Session session)
Check if have to reconnect on session closedvoid
MemcachedHandler. onSessionIdle(Session session)
Do a heartbeat actionvoid
MemcachedHandler. onSessionStarted(Session session)
On session startedprivate void
MemcachedConnector. removeMainSession(Session session)
void
MemcachedConnector. removeSession(Session session)
private void
MemcachedConnector. removeStandbySession(Session session, java.net.InetSocketAddress mainNodeAddr)
Method parameters in net.rubyeye.xmemcached.impl with type arguments of type Session Modifier and Type Method Description private void
KetamaMemcachedSessionLocator. buildMap(java.util.Collection<Session> list, HashAlgorithm alg)
private void
LibmemcachedMemcachedSessionLocator. buildMap(java.util.Collection<Session> list, HashAlgorithm alg)
private Session
ArrayMemcachedSessionLocator. getRandomSession(java.util.List<Session> sessions)
private Session
ElectionMemcachedSessionLocator. getSessionByElection(java.lang.String key, java.util.List<Session> copySessionList)
private java.util.List<Session>
KetamaMemcachedSessionLocator. getSessionList(java.util.TreeMap<java.lang.Long,java.util.List<Session>> sessionMap, long k)
private java.util.List<Session>
LibmemcachedMemcachedSessionLocator. getSessionList(java.util.TreeMap<java.lang.Long,java.util.List<Session>> sessionMap, long k)
void
ArrayMemcachedSessionLocator. updateSessions(java.util.Collection<Session> list)
void
ElectionMemcachedSessionLocator. updateSessions(java.util.Collection<Session> list)
void
KetamaMemcachedSessionLocator. updateSessions(java.util.Collection<Session> list)
void
LibmemcachedMemcachedSessionLocator. updateSessions(java.util.Collection<Session> list)
void
PHPMemcacheSessionLocator. updateSessions(java.util.Collection<Session> list)
void
RandomMemcachedSessionLocaltor. updateSessions(java.util.Collection<Session> list)
void
RoundRobinMemcachedSessionLocator. updateSessions(java.util.Collection<Session> list)
Constructors in net.rubyeye.xmemcached.impl with parameters of type Session Constructor Description CheckHeartResultThread(Command versionCommand, Session session)
Constructor parameters in net.rubyeye.xmemcached.impl with type arguments of type Session Constructor Description KetamaMemcachedSessionLocator(java.util.List<Session> list, HashAlgorithm alg)
-
Uses of Session in net.rubyeye.xmemcached.networking
Subinterfaces of Session in net.rubyeye.xmemcached.networking Modifier and Type Interface Description interface
ClosedMemcachedSession
interface
MemcachedSession
Abstract interface for memcached connection.Methods in net.rubyeye.xmemcached.networking that return Session Modifier and Type Method Description Session
Connector. send(Command packet)
Methods in net.rubyeye.xmemcached.networking that return types with arguments of type Session Modifier and Type Method Description java.util.Queue<Session>
Connector. getSessionByAddress(java.net.InetSocketAddress address)
java.util.Set<Session>
Connector. getSessionSet()
java.util.List<Session>
Connector. getStandbySessionListByMainNodeAddr(java.net.InetSocketAddress address)
Methods in net.rubyeye.xmemcached.networking with parameters of type Session Modifier and Type Method Description void
Connector. removeSession(Session session)
-