com.hazelcast.cp.internal.session

Class SessionAwareProxy

java.lang.Object

com.hazelcast.cp.internal.session.SessionAwareProxy

Direct Known Subclasses:

AbstractRaftFencedLockProxy, RaftSessionAwareSemaphoreProxy, RaftSessionlessSemaphoreProxy

public abstract class SessionAwareProxy
extends Object

Base class for server and client proxies that make use of Raft sessions

Field Summary

Fields

Modifier and Type	Field and Description
protected RaftGroupId	groupId

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SessionAwareProxy(AbstractProxySessionManager sessionManager, RaftGroupId groupId)

Method Summary

Modifier and Type	Method and Description
protected long	acquireSession() Increments acquire count of the session.
protected long	acquireSession(int count) Increments acquire count of the session.
RaftGroupId	getGroupId()
protected Long	getOrCreateUniqueThreadId(RaftGroupId groupId)
protected long	getSession() Returns id of the session opened for the given Raft group.
protected void	invalidateSession(long sessionId) Invalidates the given session.
protected void	releaseSession(long sessionId) Decrements acquire count of the session.
protected void	releaseSession(long sessionId, int count) Decrements acquire count of the session.

Methods inherited from class java.lang.Object

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

Field Detail

groupId

protected final RaftGroupId groupId

Constructor Detail

SessionAwareProxy

protected SessionAwareProxy(AbstractProxySessionManager sessionManager,
                            RaftGroupId groupId)

Method Detail

getGroupId

public final RaftGroupId getGroupId()

getOrCreateUniqueThreadId

protected final Long getOrCreateUniqueThreadId(RaftGroupId groupId)

acquireSession

protected final long acquireSession()

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

acquireSession

protected final long acquireSession(int count)

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

releaseSession

protected final void releaseSession(long sessionId)

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

releaseSession

protected final void releaseSession(long sessionId,
                                    int count)

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

invalidateSession

protected final void invalidateSession(long sessionId)

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

getSession

protected final long getSession()

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