public class DeltaManager extends ClusterManagerBase
start()
and
stop()
methods of this class at the correct times.ManagerBase.SessionTiming
Lifecycle.SingleUse
Modifier and Type | Field and Description |
---|---|
Log |
log |
protected static java.lang.String |
managerName
The descriptive name of this Manager implementation (for logging).
|
protected java.lang.String |
name |
protected static StringManager |
sm
The string manager for this package.
|
cluster
distributable, duplicates, expiredSessions, maxActive, maxActiveSessions, maxInactiveInterval, processExpiresFrequency, processingTime, rejectedSessions, secureRandomAlgorithm, secureRandomClass, secureRandomProvider, SESSION_ID_LENGTH_UNSET, sessionCounter, sessionCreationTiming, sessionExpirationTiming, sessionIdGenerator, sessionIdGeneratorClass, sessionIdLength, sessionMaxAliveTime, sessions, support, TIMING_STATS_CACHE_SIZE
mserver
AFTER_DESTROY_EVENT, AFTER_INIT_EVENT, AFTER_START_EVENT, AFTER_STOP_EVENT, BEFORE_DESTROY_EVENT, BEFORE_INIT_EVENT, BEFORE_START_EVENT, BEFORE_STOP_EVENT, CONFIGURE_START_EVENT, CONFIGURE_STOP_EVENT, PERIODIC_EVENT, START_EVENT, STOP_EVENT
Constructor and Description |
---|
DeltaManager() |
Modifier and Type | Method and Description |
---|---|
void |
changeSessionId(Session session)
Change the session ID of the current session to a new randomly generated
session ID.
|
protected void |
changeSessionId(Session session,
boolean notify) |
void |
changeSessionId(Session session,
java.lang.String newId)
Change the session ID of the current session to a specified session ID.
|
protected void |
changeSessionId(Session session,
java.lang.String newId,
boolean notify) |
ClusterManager |
cloneFromTemplate() |
Session |
createEmptySession()
Get a session from the recycled ones or create a new empty one.
|
Session |
createSession(java.lang.String sessionId)
Construct and return a new session object, based on the default
settings specified by this Manager's properties.
|
Session |
createSession(java.lang.String sessionId,
boolean distribute)
Create new session with check maxActiveSessions and send session creation
to other cluster nodes.
|
protected DeltaRequest |
deserializeDeltaRequest(DeltaSession session,
byte[] data)
Load Deltarequest from external node
Load the Class at container classloader
|
protected java.lang.String |
deserializeSessionId(byte[] data)
Load sessionID
|
protected void |
deserializeSessions(byte[] data)
Load sessions from other cluster node.
|
void |
expireAllLocalSessions()
Expire all find sessions.
|
protected Member |
findSessionMasterMember()
Find the master of the session state
|
void |
getAllClusterSessions()
get from first session master the backup from all clustered sessions
|
int |
getCounterNoStateTransfered() |
long |
getCounterReceive_EVT_ALL_SESSION_DATA() |
long |
getCounterReceive_EVT_ALL_SESSION_NOCONTEXTMANAGER() |
int |
getCounterReceive_EVT_ALL_SESSION_TRANSFERCOMPLETE() |
long |
getCounterReceive_EVT_CHANGE_SESSION_ID() |
long |
getCounterReceive_EVT_GET_ALL_SESSIONS() |
long |
getCounterReceive_EVT_SESSION_ACCESSED() |
long |
getCounterReceive_EVT_SESSION_CREATED() |
long |
getCounterReceive_EVT_SESSION_DELTA() |
long |
getCounterReceive_EVT_SESSION_EXPIRED() |
long |
getCounterSend_EVT_ALL_SESSION_DATA() |
int |
getCounterSend_EVT_ALL_SESSION_TRANSFERCOMPLETE() |
long |
getCounterSend_EVT_CHANGE_SESSION_ID() |
long |
getCounterSend_EVT_GET_ALL_SESSIONS() |
long |
getCounterSend_EVT_SESSION_ACCESSED() |
long |
getCounterSend_EVT_SESSION_CREATED() |
long |
getCounterSend_EVT_SESSION_DELTA() |
long |
getCounterSend_EVT_SESSION_EXPIRED() |
java.lang.String[] |
getInvalidatedSessions()
When the manager expires session not tied to a request.
|
java.lang.String |
getName()
Return the name of the manager, at host /context name and at engine hostname+/context.
|
protected DeltaSession |
getNewDeltaSession()
Get new session class to be used in the doLoad() method.
|
long |
getProcessingTime() |
int |
getReceivedQueueSize() |
int |
getSendAllSessionsSize() |
int |
getSendAllSessionsWaitTime() |
long |
getSessionReplaceCounter() |
boolean |
getStateTransfered()
is session state transfered complete?
|
int |
getStateTransferTimeout() |
protected void |
handleALL_SESSION_DATA(SessionMessage msg,
Member sender)
handle receive sessions from other not ( restart )
|
protected void |
handleALL_SESSION_NOCONTEXTMANAGER(SessionMessage msg,
Member sender)
handle receive no context manager.
|
protected void |
handleALL_SESSION_TRANSFERCOMPLETE(SessionMessage msg,
Member sender)
handle receive session state is complete transfered
|
protected void |
handleCHANGE_SESSION_ID(SessionMessage msg,
Member sender)
handle receive change sessionID at other node
|
protected void |
handleGET_ALL_SESSIONS(SessionMessage msg,
Member sender)
handle receive that other node want all sessions ( restart )
a) send all sessions with one message
b) send session at blocks
After sending send state is complete transfered
|
protected void |
handleSESSION_ACCESSED(SessionMessage msg,
Member sender)
handle receive session is access at other node ( primary session is now false)
|
protected void |
handleSESSION_CREATED(SessionMessage msg,
Member sender)
handle receive new session is created at other node (create backup - primary false)
|
protected void |
handleSESSION_DELTA(SessionMessage msg,
Member sender)
handle receive session delta
|
protected void |
handleSESSION_EXPIRED(SessionMessage msg,
Member sender)
handle receive session is expire at other node ( expire session also here)
|
boolean |
isExpireSessionsOnShutdown() |
boolean |
isNoContextManagerReceived() |
boolean |
isNotifyContainerListenersOnReplication() |
boolean |
isNotifySessionListenersOnReplication() |
boolean |
isSendAllSessions() |
boolean |
isStateTimestampDrop() |
void |
messageDataReceived(ClusterMessage cmsg)
A message was received from another node, this is the callback method to
implement if you are interested in receiving replication messages.
|
protected void |
messageReceived(SessionMessage msg,
Member sender)
This method is called by the received thread when a SessionMessage has
been received from one of the other nodes in the cluster.
|
ClusterMessage |
requestCompleted(java.lang.String sessionId)
When the request has been completed, the replication valve will notify
the manager, and the manager will decide whether any replication is
needed or not.
|
ClusterMessage |
requestCompleted(java.lang.String sessionId,
boolean expires)
When the request has been completed, the replication valve will notify
the manager, and the manager will decide whether any replication is
needed or not.
|
void |
resetStatistics()
Reset manager statistics
|
protected void |
send(SessionMessage msg)
Send messages to other backup member (domain or all)
|
protected void |
sendChangeSessionId(java.lang.String newSessionID,
java.lang.String orgSessionID) |
protected void |
sendCreateSession(java.lang.String sessionId,
DeltaSession session)
Send create session evt to all backup node
|
protected void |
sendSessions(Member sender,
Session[] currentSessions,
long sendTimestamp)
send a block of session to sender
|
protected byte[] |
serializeDeltaRequest(DeltaSession session,
DeltaRequest deltaRequest)
serialize DeltaRequest
|
protected byte[] |
serializeSessionId(java.lang.String sessionId)
serialize sessionID
|
protected byte[] |
serializeSessions(Session[] currentSessions)
Save any currently active sessions in the appropriate persistence
mechanism, if any.
|
protected void |
sessionExpired(java.lang.String id)
send session expired to other cluster nodes
|
void |
setExpireSessionsOnShutdown(boolean expireSessionsOnShutdown) |
void |
setName(java.lang.String name)
Set the name of the manager, at host /context name and at engine hostname+/context
|
void |
setNoContextManagerReceived(boolean noContextManagerReceived) |
void |
setNotifyContainerListenersOnReplication(boolean notifyContainerListenersOnReplication) |
void |
setNotifySessionListenersOnReplication(boolean notifyListenersCreateSessionOnReplication) |
void |
setSendAllSessions(boolean sendAllSessions) |
void |
setSendAllSessionsSize(int sendAllSessionsSize) |
void |
setSendAllSessionsWaitTime(int sendAllSessionsWaitTime) |
void |
setStateTimestampDrop(boolean isTimestampDrop) |
void |
setStateTransfered(boolean stateTransfered)
set that state ist complete transfered
|
void |
setStateTransferTimeout(int timeoutAllSession) |
protected void |
startInternal()
Start this component and implement the requirements
of
LifecycleBase.startInternal() . |
protected void |
stopInternal()
Stop this component and implement the requirements
of
LifecycleBase.stopInternal() . |
protected void |
waitForSendAllSessions(long beforeSendTime)
Wait that cluster session state is transfer or timeout after 60 Sec
With stateTransferTimeout == -1 wait that backup is transfered (forever mode)
|
clone, getClassLoaders, getClassLoaders, getCluster, getReplicationStream, getReplicationStream, getSessionAttributeFilter, isNotifyListenersOnReplication, isRecordAllActions, load, registerSessionAtReplicationValve, setCluster, setNotifyListenersOnReplication, setRecordAllActions, setSessionAttributeFilter, unload, willAttributeDistribute
add, addPropertyChangeListener, backgroundProcess, changeSessionId, expireSession, findSession, findSessions, generateSessionId, getActiveSessions, getClassName, getContainer, getContext, getCreationTime, getCreationTimestamp, getDistributable, getDomainInternal, getDuplicates, getEngine, getExpiredSessions, getJvmRoute, getLastAccessedTime, getLastAccessedTimestamp, getMaxActive, getMaxActiveSessions, getMaxInactiveInterval, getNewSession, getObjectNameKeyProperties, getProcessExpiresFrequency, getRejectedSessions, getSecureRandomAlgorithm, getSecureRandomClass, getSecureRandomProvider, getSession, getSessionAttribute, getSessionAttributeNameFilter, getSessionAttributeNamePattern, getSessionAttributeValueClassNameFilter, getSessionAttributeValueClassNamePattern, getSessionAverageAliveTime, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdGenerator, getSessionIdLength, getSessionMaxAliveTime, getThisAccessedTime, getThisAccessedTimestamp, getWarnOnSessionAttributeFilterFailure, initInternal, listSessionIds, processExpires, remove, remove, removePropertyChangeListener, setContainer, setContext, setDistributable, setDuplicates, setExpiredSessions, setMaxActive, setMaxActiveSessions, setMaxInactiveInterval, setProcessExpiresFrequency, setProcessingTime, setSecureRandomAlgorithm, setSecureRandomClass, setSecureRandomProvider, setSessionAttributeNameFilter, setSessionAttributeValueClassNameFilter, setSessionCounter, setSessionIdGenerator, setSessionIdLength, setSessionMaxAliveTime, setWarnOnSessionAttributeFilterFailure, toString, updateSessionMaxAliveTime, willAttributeDistribute
destroyInternal, getDomain, getObjectName, postDeregister, postRegister, preDeregister, preRegister, register, setDomain, unregister
addLifecycleListener, destroy, findLifecycleListeners, fireLifecycleEvent, getState, getStateName, init, removeLifecycleListener, setState, setState, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
add, addPropertyChangeListener, backgroundProcess, findSession, findSessions, getActiveSessions, getContainer, getContext, getDistributable, getExpiredSessions, getMaxActive, getMaxInactiveInterval, getRejectedSessions, getSessionAverageAliveTime, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdGenerator, getSessionIdLength, getSessionMaxAliveTime, remove, remove, removePropertyChangeListener, setContainer, setContext, setDistributable, setExpiredSessions, setMaxActive, setMaxInactiveInterval, setSessionCounter, setSessionIdGenerator, setSessionIdLength, setSessionMaxAliveTime, willAttributeDistribute
public final Log log
protected static final StringManager sm
protected static final java.lang.String managerName
protected java.lang.String name
public void setName(java.lang.String name)
ClusterManager
public java.lang.String getName()
ClusterManager
getName
in interface ClusterManager
getName
in class ManagerBase
public long getCounterSend_EVT_GET_ALL_SESSIONS()
public long getCounterSend_EVT_SESSION_ACCESSED()
public long getCounterSend_EVT_SESSION_CREATED()
public long getCounterSend_EVT_SESSION_DELTA()
public long getCounterSend_EVT_SESSION_EXPIRED()
public long getCounterSend_EVT_ALL_SESSION_DATA()
public int getCounterSend_EVT_ALL_SESSION_TRANSFERCOMPLETE()
public long getCounterSend_EVT_CHANGE_SESSION_ID()
public long getCounterReceive_EVT_ALL_SESSION_DATA()
public long getCounterReceive_EVT_GET_ALL_SESSIONS()
public long getCounterReceive_EVT_SESSION_ACCESSED()
public long getCounterReceive_EVT_SESSION_CREATED()
public long getCounterReceive_EVT_SESSION_DELTA()
public long getCounterReceive_EVT_SESSION_EXPIRED()
public int getCounterReceive_EVT_ALL_SESSION_TRANSFERCOMPLETE()
public long getCounterReceive_EVT_CHANGE_SESSION_ID()
public long getCounterReceive_EVT_ALL_SESSION_NOCONTEXTMANAGER()
public long getProcessingTime()
getProcessingTime
in class ManagerBase
public long getSessionReplaceCounter()
public int getCounterNoStateTransfered()
public int getReceivedQueueSize()
public int getStateTransferTimeout()
public void setStateTransferTimeout(int timeoutAllSession)
timeoutAllSession
- The timeoutpublic boolean getStateTransfered()
public void setStateTransfered(boolean stateTransfered)
stateTransfered
- public boolean isNoContextManagerReceived()
public void setNoContextManagerReceived(boolean noContextManagerReceived)
public int getSendAllSessionsWaitTime()
public void setSendAllSessionsWaitTime(int sendAllSessionsWaitTime)
sendAllSessionsWaitTime
- The sendAllSessionsWaitTime to set at msec.public boolean isStateTimestampDrop()
public void setStateTimestampDrop(boolean isTimestampDrop)
isTimestampDrop
- The new flag valuepublic boolean isSendAllSessions()
public void setSendAllSessions(boolean sendAllSessions)
sendAllSessions
- The sendAllSessions to set.public int getSendAllSessionsSize()
public void setSendAllSessionsSize(int sendAllSessionsSize)
sendAllSessionsSize
- The sendAllSessionsSize to set.public boolean isNotifySessionListenersOnReplication()
public void setNotifySessionListenersOnReplication(boolean notifyListenersCreateSessionOnReplication)
notifyListenersCreateSessionOnReplication
- The notifySessionListenersOnReplication to set.public boolean isExpireSessionsOnShutdown()
public void setExpireSessionsOnShutdown(boolean expireSessionsOnShutdown)
public boolean isNotifyContainerListenersOnReplication()
public void setNotifyContainerListenersOnReplication(boolean notifyContainerListenersOnReplication)
public Session createSession(java.lang.String sessionId)
Manager
null
.createSession
in interface Manager
createSession
in class ManagerBase
sessionId
- The session id which should be used to create the
new session; if null
, the session
id will be assigned by this method, and available via the getId()
method of the returned session.public Session createSession(java.lang.String sessionId, boolean distribute)
distribute
- protected void sendCreateSession(java.lang.String sessionId, DeltaSession session)
sessionId
- session
- protected void send(SessionMessage msg)
msg
- Session messagepublic Session createEmptySession()
Creates new DeltaSession instance.
createEmptySession
in interface Manager
createEmptySession
in class ManagerBase
protected DeltaSession getNewDeltaSession()
public void changeSessionId(Session session)
Manager
changeSessionId
in interface Manager
changeSessionId
in class ManagerBase
session
- The session to change the session ID forpublic void changeSessionId(Session session, java.lang.String newId)
Manager
changeSessionId
in interface Manager
changeSessionId
in class ManagerBase
session
- The session to change the session ID fornewId
- new session IDprotected void changeSessionId(Session session, boolean notify)
protected void changeSessionId(Session session, java.lang.String newId, boolean notify)
protected void sendChangeSessionId(java.lang.String newSessionID, java.lang.String orgSessionID)
protected byte[] serializeSessionId(java.lang.String sessionId) throws java.io.IOException
java.io.IOException
- if an input/output error occursprotected java.lang.String deserializeSessionId(byte[] data) throws java.io.IOException
java.io.IOException
- if an input/output error occursprotected DeltaRequest deserializeDeltaRequest(DeltaSession session, byte[] data) throws java.lang.ClassNotFoundException, java.io.IOException
session
- data
- message datajava.lang.ClassNotFoundException
java.io.IOException
DeltaRequest.readExternal(java.io.ObjectInput)
protected byte[] serializeDeltaRequest(DeltaSession session, DeltaRequest deltaRequest) throws java.io.IOException
deltaRequest
- java.io.IOException
DeltaRequest.writeExternal(java.io.ObjectOutput)
protected void deserializeSessions(byte[] data) throws java.lang.ClassNotFoundException, java.io.IOException
java.lang.ClassNotFoundException
- if a serialized class cannot be found during the reloadjava.io.IOException
- if an input/output error occursprotected byte[] serializeSessions(Session[] currentSessions) throws java.io.IOException
java.io.IOException
- if an input/output error occursprotected void startInternal() throws LifecycleException
LifecycleBase.startInternal()
.startInternal
in class ClusterManagerBase
LifecycleException
- if this component detects a fatal error
that prevents this component from being usedpublic void getAllClusterSessions()
findSessionMasterMember()
protected Member findSessionMasterMember()
protected void waitForSendAllSessions(long beforeSendTime)
protected void stopInternal() throws LifecycleException
LifecycleBase.stopInternal()
.stopInternal
in class ClusterManagerBase
LifecycleException
- if this component detects a fatal error
that prevents this component from being usedpublic void messageDataReceived(ClusterMessage cmsg)
cmsg
- -
the message received.public ClusterMessage requestCompleted(java.lang.String sessionId)
sessionId
- -
the sessionId that just completed.public ClusterMessage requestCompleted(java.lang.String sessionId, boolean expires)
sessionId
- -
the sessionId that just completed.expires
- -
whether this method has been called during session expirationpublic void resetStatistics()
protected void sessionExpired(java.lang.String id)
id
- session idpublic void expireAllLocalSessions()
public java.lang.String[] getInvalidatedSessions()
ClusterManager
protected void messageReceived(SessionMessage msg, Member sender)
msg
- -
the message receivedsender
- -
the sender of the message, this is used if we receive a
EVT_GET_ALL_SESSION message, so that we only reply to the
requesting nodeprotected void handleALL_SESSION_TRANSFERCOMPLETE(SessionMessage msg, Member sender)
msg
- sender
- protected void handleSESSION_DELTA(SessionMessage msg, Member sender) throws java.io.IOException, java.lang.ClassNotFoundException
msg
- sender
- java.io.IOException
java.lang.ClassNotFoundException
protected void handleSESSION_ACCESSED(SessionMessage msg, Member sender) throws java.io.IOException
msg
- sender
- java.io.IOException
protected void handleSESSION_EXPIRED(SessionMessage msg, Member sender) throws java.io.IOException
msg
- sender
- java.io.IOException
protected void handleSESSION_CREATED(SessionMessage msg, Member sender)
msg
- sender
- protected void handleALL_SESSION_DATA(SessionMessage msg, Member sender) throws java.lang.ClassNotFoundException, java.io.IOException
msg
- sender
- java.lang.ClassNotFoundException
java.io.IOException
protected void handleGET_ALL_SESSIONS(SessionMessage msg, Member sender) throws java.io.IOException
msg
- sender
- java.io.IOException
protected void handleCHANGE_SESSION_ID(SessionMessage msg, Member sender) throws java.io.IOException
msg
- sender
- java.io.IOException
protected void handleALL_SESSION_NOCONTEXTMANAGER(SessionMessage msg, Member sender)
msg
- sender
- protected void sendSessions(Member sender, Session[] currentSessions, long sendTimestamp) throws java.io.IOException
sender
- currentSessions
- sendTimestamp
- java.io.IOException
public ClusterManager cloneFromTemplate()
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.