com.hazelcast.cp.internal.session

Class AbstractProxySessionManager

java.lang.Object

com.hazelcast.cp.internal.session.AbstractProxySessionManager

Direct Known Subclasses:

ClientProxySessionManager, ProxySessionManagerService

public abstract class AbstractProxySessionManager
extends Object

Implements session management APIs for Raft-based server and client proxies

Field Summary

Fields

Modifier and Type	Field and Description
static long	NO_SESSION_ID Represents absence of a Raft session

Constructor Summary

Constructors

Constructor and Description
AbstractProxySessionManager()

Method Summary

Modifier and Type	Method and Description
long	acquireSession(RaftGroupId groupId) Increments acquire count of the session.
long	acquireSession(RaftGroupId groupId, int count) Increments acquire count of the session.
protected abstract ICompletableFuture<Object>	closeSession(RaftGroupId groupId, Long sessionId) Closes the given session on the Raft group
protected abstract long	generateThreadId(RaftGroupId groupId) Generates a cluster-wide unique thread id for the caller
Long	getOrCreateUniqueThreadId(RaftGroupId groupId)
long	getSession(RaftGroupId groupId) Returns id of the session opened for the given Raft group.
long	getSessionAcquireCount(RaftGroupId groupId, long sessionId)
protected abstract ICompletableFuture<Object>	heartbeat(RaftGroupId groupId, long sessionId) Commits a heartbeat for the session on the Raft group
void	invalidateSession(RaftGroupId groupId, long id) Invalidates the given session.
void	releaseSession(RaftGroupId groupId, long id) Decrements acquire count of the session.
void	releaseSession(RaftGroupId groupId, long id, int count) Decrements acquire count of the session.
protected abstract SessionResponse	requestNewSession(RaftGroupId groupId) Creates a new session on the Raft group
protected void	resetInternalState()
protected abstract ScheduledFuture<?>	scheduleWithRepetition(Runnable task, long period, TimeUnit unit) Schedules the given task for repeating execution
Map<RaftGroupId,ICompletableFuture<Object>>	shutdown() Invokes a shutdown call on server to close all existing sessions.

Methods inherited from class java.lang.Object

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

Field Detail

NO_SESSION_ID

public static final long NO_SESSION_ID

Represents absence of a Raft session

See Also:

Constant Field Values

Constructor Detail

AbstractProxySessionManager

public AbstractProxySessionManager()

Method Detail

generateThreadId

protected abstract long generateThreadId(RaftGroupId groupId)

Generates a cluster-wide unique thread id for the caller

requestNewSession

protected abstract SessionResponse requestNewSession(RaftGroupId groupId)

Creates a new session on the Raft group

heartbeat

protected abstract ICompletableFuture<Object> heartbeat(RaftGroupId groupId,
                                                        long sessionId)

Commits a heartbeat for the session on the Raft group

closeSession

protected abstract ICompletableFuture<Object> closeSession(RaftGroupId groupId,
                                                           Long sessionId)

Closes the given session on the Raft group

scheduleWithRepetition

protected abstract ScheduledFuture<?> scheduleWithRepetition(Runnable task,
                                                             long period,
                                                             TimeUnit unit)

Schedules the given task for repeating execution

resetInternalState

protected final void resetInternalState()

getOrCreateUniqueThreadId

public final Long getOrCreateUniqueThreadId(RaftGroupId groupId)

acquireSession

public final long acquireSession(RaftGroupId groupId)

Increments acquire count of the session. Creates a new session if there is no session yet.

acquireSession

public final long acquireSession(RaftGroupId groupId,
                                 int count)

Increments acquire count of the session. Creates a new session if there is no session yet.

releaseSession

public final void releaseSession(RaftGroupId groupId,
                                 long id)

Decrements acquire count of the session. Returns silently if no session exists for the given id.

releaseSession

public final void releaseSession(RaftGroupId groupId,
                                 long id,
                                 int count)

Decrements acquire count of the session. Returns silently if no session exists for the given id.

invalidateSession

public final void invalidateSession(RaftGroupId groupId,
                                    long id)

Invalidates the given session. No more heartbeats will be sent for the given session.

getSession

public final long getSession(RaftGroupId groupId)

Returns id of the session opened for the given Raft group. Returns NO_SESSION_ID if no session exists.

shutdown

public Map<RaftGroupId,ICompletableFuture<Object>> shutdown()

Invokes a shutdown call on server to close all existing sessions.

getSessionAcquireCount

public final long getSessionAcquireCount(RaftGroupId groupId,
                                         long sessionId)