org.apache.zookeeper.server

Class SessionTrackerImpl

java.lang.Object

java.lang.Thread

org.apache.zookeeper.server.ZooKeeperThread

org.apache.zookeeper.server.ZooKeeperCriticalThread

org.apache.zookeeper.server.SessionTrackerImpl

All Implemented Interfaces:

Runnable, SessionTracker

Direct Known Subclasses:

LocalSessionTracker

public class SessionTrackerImpl
extends ZooKeeperCriticalThread
implements SessionTracker

This is a full featured SessionTracker. It tracks session in grouped by tick interval. It always rounds up the tick interval to provide a sort of grace period. Sessions are thus expired in batches made up of sessions that expire in a given interval.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SessionTrackerImpl.SessionImpl

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Nested classes/interfaces inherited from interface org.apache.zookeeper.server.SessionTracker

SessionTracker.Session, SessionTracker.SessionExpirer

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentHashMap<Long,SessionTrackerImpl.SessionImpl>	sessionsById

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
SessionTrackerImpl(SessionTracker.SessionExpirer expirer, ConcurrentMap<Long,Integer> sessionsWithTimeout, int tickTime, long serverId, ZooKeeperServerListener listener)

Method Summary

Modifier and Type	Method and Description
boolean	addGlobalSession(long id, int sessionTimeout) Add a global session to those being tracked.
boolean	addSession(long id, int sessionTimeout) Add a session to those being tracked.
void	checkGlobalSession(long sessionId, Object owner) Strictly check that a given session is a global session or not
void	checkSession(long sessionId, Object owner) Checks whether the SessionTracker is aware of this session, the session is still active, and the owner matches.
long	createSession(int sessionTimeout)
void	dumpSessions(PrintWriter pwriter) Text dump of session information, suitable for debugging.
Map<Long,Set<Long>>	getSessionExpiryMap() Returns a mapping from time to session IDs of sessions expiring at that time.
int	getSessionTimeout(long sessionId)
static long	initializeNextSession(long id) Generates an initial sessionId.
boolean	isTrackingSession(long sessionId)
void	removeSession(long sessionId)
void	run()
void	setOwner(long id, Object owner)
void	setSessionClosing(long sessionId) Mark that the session is in the process of closing.
void	shutdown()
String	toString()
boolean	touchSession(long sessionId, int timeout)

Methods inherited from class org.apache.zookeeper.server.ZooKeeperCriticalThread

handleException

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Field Detail

sessionsById

protected final ConcurrentHashMap<Long,SessionTrackerImpl.SessionImpl> sessionsById

Constructor Detail

SessionTrackerImpl

public SessionTrackerImpl(SessionTracker.SessionExpirer expirer,
                          ConcurrentMap<Long,Integer> sessionsWithTimeout,
                          int tickTime,
                          long serverId,
                          ZooKeeperServerListener listener)

Method Detail

initializeNextSession

public static long initializeNextSession(long id)

Generates an initial sessionId. High order byte is serverId, next 5 5 bytes are from timestamp, and low order 2 bytes are 0s.

dumpSessions

public void dumpSessions(PrintWriter pwriter)

Description copied from interface: SessionTracker

Text dump of session information, suitable for debugging.

Specified by:

dumpSessions in interface SessionTracker

Parameters:

pwriter - the output writer

getSessionExpiryMap

public Map<Long,Set<Long>> getSessionExpiryMap()

Returns a mapping from time to session IDs of sessions expiring at that time.

Specified by:

getSessionExpiryMap in interface SessionTracker

toString

public String toString()

Overrides:

toString in class Thread

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

touchSession

public boolean touchSession(long sessionId,
                            int timeout)

Specified by:

touchSession in interface SessionTracker

Returns:

false if session is no longer active

getSessionTimeout

public int getSessionTimeout(long sessionId)

setSessionClosing

public void setSessionClosing(long sessionId)

Description copied from interface: SessionTracker

Mark that the session is in the process of closing.

Specified by:

setSessionClosing in interface SessionTracker

removeSession

public void removeSession(long sessionId)

Specified by:

removeSession in interface SessionTracker

shutdown

public void shutdown()

Specified by:

shutdown in interface SessionTracker

createSession

public long createSession(int sessionTimeout)

Specified by:

createSession in interface SessionTracker

addGlobalSession

public boolean addGlobalSession(long id,
                                int sessionTimeout)

Description copied from interface: SessionTracker

Add a global session to those being tracked.

Specified by:

addGlobalSession in interface SessionTracker

Parameters:

id - sessionId

sessionTimeout - sessionTimeout

Returns:

whether the session was newly added (if false, already existed)

addSession

public boolean addSession(long id,
                          int sessionTimeout)

Description copied from interface: SessionTracker

Add a session to those being tracked. The session is added as a local session if they are enabled, otherwise as global.

Specified by:

addSession in interface SessionTracker

Parameters:

id - sessionId

sessionTimeout - sessionTimeout

Returns:

whether the session was newly added (if false, already existed)

isTrackingSession

public boolean isTrackingSession(long sessionId)

Specified by:

isTrackingSession in interface SessionTracker

Returns:

whether or not the SessionTracker is aware of this session

checkSession

public void checkSession(long sessionId,
                         Object owner)
                  throws KeeperException.SessionExpiredException,
                         KeeperException.SessionMovedException,
                         KeeperException.UnknownSessionException

Description copied from interface: SessionTracker

Checks whether the SessionTracker is aware of this session, the session is still active, and the owner matches. If the owner wasn't previously set, this sets the owner of the session. UnknownSessionException should never been thrown to the client. It is only used internally to deal with possible local session from other machine

Specified by:

checkSession in interface SessionTracker

Throws:

KeeperException.SessionExpiredException

KeeperException.SessionMovedException

KeeperException.UnknownSessionException

setOwner

public void setOwner(long id,
                     Object owner)
              throws KeeperException.SessionExpiredException

Specified by:

setOwner in interface SessionTracker

Throws:

KeeperException.SessionExpiredException

checkGlobalSession

public void checkGlobalSession(long sessionId,
                               Object owner)
                        throws KeeperException.SessionExpiredException,
                               KeeperException.SessionMovedException

Description copied from interface: SessionTracker

Strictly check that a given session is a global session or not

Specified by:

checkGlobalSession in interface SessionTracker

Throws:

KeeperException.SessionExpiredException

KeeperException.SessionMovedException