Class LearnerSessionTracker
- java.lang.Object
-
- org.apache.zookeeper.server.quorum.LearnerSessionTracker
-
- All Implemented Interfaces:
SessionTracker
public class LearnerSessionTracker extends java.lang.Object implements SessionTracker
This is really just a shell of a SessionTracker that tracks session activity to be forwarded to the Leader using a PING.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.zookeeper.server.SessionTracker
SessionTracker.Session, SessionTracker.SessionExpirer
-
-
Constructor Summary
Constructors Constructor Description LearnerSessionTracker(SessionTracker.SessionExpirer expirer, java.util.concurrent.ConcurrentHashMap<java.lang.Long,java.lang.Integer> sessionsWithTimeouts, long id, ZooKeeperServerListener listener)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addSession(long sessionId, int sessionTimeout)
void
checkSession(long sessionId, java.lang.Object owner)
long
createSession(int sessionTimeout)
void
dumpSessions(java.io.PrintWriter pwriter)
Text dump of session information, suitable for debugging.void
removeSession(long sessionId)
void
setOwner(long sessionId, java.lang.Object owner)
void
setSessionClosing(long sessionId)
Mark that the session is in the process of closing.void
shutdown()
boolean
touchSession(long sessionId, int sessionTimeout)
-
-
-
Constructor Detail
-
LearnerSessionTracker
public LearnerSessionTracker(SessionTracker.SessionExpirer expirer, java.util.concurrent.ConcurrentHashMap<java.lang.Long,java.lang.Integer> sessionsWithTimeouts, long id, ZooKeeperServerListener listener)
-
-
Method Detail
-
removeSession
public void removeSession(long sessionId)
- Specified by:
removeSession
in interfaceSessionTracker
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfaceSessionTracker
-
addSession
public void addSession(long sessionId, int sessionTimeout)
- Specified by:
addSession
in interfaceSessionTracker
-
touchSession
public boolean touchSession(long sessionId, int sessionTimeout)
- Specified by:
touchSession
in interfaceSessionTracker
- Returns:
- false if session is no longer active
-
createSession
public long createSession(int sessionTimeout)
- Specified by:
createSession
in interfaceSessionTracker
-
checkSession
public void checkSession(long sessionId, java.lang.Object owner)
- Specified by:
checkSession
in interfaceSessionTracker
-
setOwner
public void setOwner(long sessionId, java.lang.Object owner)
- Specified by:
setOwner
in interfaceSessionTracker
-
dumpSessions
public void dumpSessions(java.io.PrintWriter pwriter)
Description copied from interface:SessionTracker
Text dump of session information, suitable for debugging.- Specified by:
dumpSessions
in interfaceSessionTracker
- Parameters:
pwriter
- the output writer
-
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 interfaceSessionTracker
-
-