ReplicationValve (Apache Tomcat 7.0.109 API Documentation)

java.lang.Object
- org.apache.catalina.util.LifecycleBase
- - org.apache.catalina.util.LifecycleMBeanBase
  - - org.apache.catalina.valves.ValveBase
    - - org.apache.catalina.ha.tcp.ReplicationValve

All Implemented Interfaces:

MBeanRegistration, Contained, ClusterValve, JmxEnabled, Lifecycle, Valve
```
public class ReplicationValve
extends ValveBase
implements ClusterValve
```
Implementation of a Valve that logs interesting contents from the specified Request (before processing) and the corresponding Response (after processing). It is especially useful in debugging problems related to headers and cookies.

This Valve may be attached to any Container, depending on the granularity of the logging you wish to perform.

primaryIndicator=true, then the request attribute org.apache.catalina.ha.tcp.isPrimarySession. is set true, when request processing is at sessions primary node.

Author:

Craig R. McClanahan, Peter Rossbach

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.catalina.Lifecycle
  Lifecycle.SingleUse

Field Summary

Fields
Modifier and Type	Field and Description
`protected ThreadLocal<ArrayList<DeltaSession>>`	`crossContextSessions` crossContext session container
`protected boolean`	`doProcessingStats` doProcessingStats (default = off)
`protected Pattern`	`filter` Filter expression
`protected long`	`lastSendTime`
`protected long`	`nrOfCrossContextSendRequests`
`protected long`	`nrOfFilterRequests`
`protected long`	`nrOfRequests`
`protected long`	`nrOfSendRequests`
`protected boolean`	`primaryIndicator` must primary change indicator set
`protected String`	`primaryIndicatorName` Name of primary change indicator as request attribute
`protected static StringManager`	`sm` The StringManager for this package.
`protected long`	`totalRequestTime`
`protected long`	`totalSendTime`

Fields inherited from class org.apache.catalina.valves.ValveBase
asyncSupported, container, containerLog, next

Fields inherited from class org.apache.catalina.util.LifecycleMBeanBase
mserver

Fields inherited from interface org.apache.catalina.Lifecycle
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 Summary

Constructors
Constructor and Description

ReplicationValve()

Constructors
Constructor and Description
`ReplicationValve()`

Method Summary

Methods
Modifier and Type	Method and Description
`protected void`	`createPrimaryIndicator(Request request)` Mark Request that processed at primary node with attribute primaryIndicatorName
`boolean`	`doStatistics()` Calc processing stats
`CatalinaCluster`	`getCluster()` Returns the cluster the cluster deployer is associated with
`String`	`getFilter()`
`String`	`getInfo()` Return descriptive information about this Valve implementation.
`long`	`getLastSendTime()`
`long`	`getNrOfCrossContextSendRequests()`
`long`	`getNrOfFilterRequests()`
`long`	`getNrOfRequests()`
`long`	`getNrOfSendRequests()`
`String`	`getPrimaryIndicatorName()`
`long`	`getTotalRequestTime()`
`long`	`getTotalSendTime()`
`void`	`invoke(Request request, Response response)` Log the interesting request parameters, invoke the next Valve in the sequence, and log the interesting response parameters.
`boolean`	`isPrimaryIndicator()`
`protected boolean`	`isRequestWithoutSessionChange(String uri)` is request without possible session change
`void`	`registerReplicationSession(DeltaSession session)` Register all cross context sessions inside endAccess.
`protected void`	`resetDeltaRequest(Session session)` Reset DeltaRequest from session
`protected void`	`resetReplicationRequest(Request request, boolean isCrossContext)` Fix memory leak for long sessions with many changes, when no backup member exists!
`void`	`resetStatistics()` reset the active statistics
`protected void`	`send(ClusterManager manager, CatalinaCluster cluster, String sessionId)` send manager requestCompleted message to cluster
`protected void`	`sendCrossContextSession(CatalinaCluster containerCluster)` Send all changed cross context sessions to backups
`protected void`	`sendInvalidSessions(ClusterManager manager, CatalinaCluster cluster)` check for session invalidations
`protected void`	`sendMessage(Session session, ClusterManager manager, CatalinaCluster cluster)` Send message delta message from request session
`protected void`	`sendReplicationMessage(Request request, long totalstart, boolean isCrossContext, ClusterManager clusterManager, CatalinaCluster containerCluster)`
`protected void`	`sendSessionReplicationMessage(Request request, ClusterManager manager, CatalinaCluster cluster)` Send Cluster Replication Request
`void`	`setCluster(CatalinaCluster cluster)` Associates the cluster deployer with a cluster
`void`	`setFilter(String filter)` compile filter string to regular expression
`void`	`setPrimaryIndicator(boolean primaryIndicator)`
`void`	`setPrimaryIndicatorName(String primaryIndicatorName)`
`void`	`setStatistics(boolean doProcessingStats)` Set Calc processing stats
`protected void`	`startInternal()` Start this component and implement the requirements of `LifecycleBase.startInternal()`.
`protected void`	`updateStats(long requestTime, long clusterTime)` Protocol cluster replications stats

Methods inherited from class org.apache.catalina.valves.ValveBase
backgroundProcess, event, getContainer, getDomainInternal, getNext, getObjectNameKeyProperties, initInternal, isAsyncSupported, setAsyncSupported, setContainer, setNext, stopInternal, toString

Methods inherited from class org.apache.catalina.util.LifecycleMBeanBase
destroyInternal, getDomain, getObjectName, postDeregister, postRegister, preDeregister, preRegister, register, setDomain, unregister

Methods inherited from class org.apache.catalina.util.LifecycleBase
addLifecycleListener, destroy, findLifecycleListeners, fireLifecycleEvent, getState, getStateName, getThrowOnFailure, init, removeLifecycleListener, setState, setState, setThrowOnFailure, start, stop

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.catalina.Valve
backgroundProcess, event, getNext, isAsyncSupported, setNext

- Field Detail
  - sm
```
protected static final StringManager sm
```
    The StringManager for this package.
  - filter
```
protected Pattern filter
```
    Filter expression
  - crossContextSessions
```
protected ThreadLocal<ArrayList<DeltaSession>> crossContextSessions
```
    crossContext session container
  - doProcessingStats
```
protected boolean doProcessingStats
```
    doProcessingStats (default = off)
  - totalRequestTime
```
protected volatile long totalRequestTime
```
  - totalSendTime
```
protected volatile long totalSendTime
```
  - nrOfRequests
```
protected volatile long nrOfRequests
```
  - lastSendTime
```
protected volatile long lastSendTime
```
  - nrOfFilterRequests
```
protected volatile long nrOfFilterRequests
```
  - nrOfSendRequests
```
protected volatile long nrOfSendRequests
```
  - nrOfCrossContextSendRequests
```
protected volatile long nrOfCrossContextSendRequests
```
  - primaryIndicator
```
protected boolean primaryIndicator
```
    must primary change indicator set
  - primaryIndicatorName
```
protected String primaryIndicatorName
```
    Name of primary change indicator as request attribute
- Constructor Detail
  - ReplicationValve
```
public ReplicationValve()
```
- Method Detail
  - getInfo
```
public String getInfo()
```
    Return descriptive information about this Valve implementation.
    
    Specified by:
    
    getInfo in interface Valve
    
    Overrides:
    
    getInfo in class ValveBase
    
    Returns:
    descriptive information about this Valve implementation.
  - getCluster
```
public CatalinaCluster getCluster()
```
    Description copied from interface: ClusterValve
    
    Returns the cluster the cluster deployer is associated with
    
    Specified by:
    
    getCluster in interface ClusterValve
    
    Returns:
    the cluster.
  - setCluster
```
public void setCluster(CatalinaCluster cluster)
```
    Description copied from interface: ClusterValve
    
    Associates the cluster deployer with a cluster
    
    Specified by:
    
    setCluster in interface ClusterValve
    
    Parameters:
    cluster - The cluster to set.
  - getFilter
```
public String getFilter()
```
    Returns:
    the filter
  - setFilter
```
public void setFilter(String filter)
```
    compile filter string to regular expression
    
    Parameters:
    filter - The filter to set.
    See Also:
    Pattern.compile(java.lang.String)
  - isPrimaryIndicator
```
public boolean isPrimaryIndicator()
```
    Returns:
    the primaryIndicator.
  - setPrimaryIndicator
```
public void setPrimaryIndicator(boolean primaryIndicator)
```
    Parameters:
    primaryIndicator - The primaryIndicator to set.
  - getPrimaryIndicatorName
```
public String getPrimaryIndicatorName()
```
    Returns:
    the primaryIndicatorName.
  - setPrimaryIndicatorName
```
public void setPrimaryIndicatorName(String primaryIndicatorName)
```
    Parameters:
    primaryIndicatorName - The primaryIndicatorName to set.
  - doStatistics
```
public boolean doStatistics()
```
    Calc processing stats
    
    Returns:
    true if statistics are enabled
  - setStatistics
```
public void setStatistics(boolean doProcessingStats)
```
    Set Calc processing stats
    
    Parameters:
    doProcessingStats - New flag value
    See Also:
    resetStatistics()
  - getLastSendTime
```
public long getLastSendTime()
```
    Returns:
    the lastSendTime.
  - getNrOfRequests
```
public long getNrOfRequests()
```
    Returns:
    the nrOfRequests.
  - getNrOfFilterRequests
```
public long getNrOfFilterRequests()
```
    Returns:
    the nrOfFilterRequests.
  - getNrOfCrossContextSendRequests
```
public long getNrOfCrossContextSendRequests()
```
    Returns:
    the nrOfCrossContextSendRequests.
  - getNrOfSendRequests
```
public long getNrOfSendRequests()
```
    Returns:
    the nrOfSendRequests.
  - getTotalRequestTime
```
public long getTotalRequestTime()
```
    Returns:
    the totalRequestTime.
  - getTotalSendTime
```
public long getTotalSendTime()
```
    Returns:
    the totalSendTime.
  - registerReplicationSession
```
public void registerReplicationSession(DeltaSession session)
```
    Register all cross context sessions inside endAccess. Use a list with contains check, that the Portlet API can include a lot of fragments from same or different applications with session changes.
    
    Parameters:
    session - cross context session
  - invoke
```
public void invoke(Request request,
          Response response)
            throws IOException,
                   ServletException
```
    Log the interesting request parameters, invoke the next Valve in the sequence, and log the interesting response parameters.
    
    Specified by:
    
    invoke in interface Valve
    
    Specified by:
    
    invoke in class ValveBase
    
    Parameters:
    request - The servlet request to be processed
    response - The servlet response to be created
    
    Throws:
    
    IOException - if an input/output error occurs
    
    ServletException - if a servlet error occurs
  - resetStatistics
```
public void resetStatistics()
```
    reset the active statistics
  - startInternal
```
protected void startInternal()
                      throws LifecycleException
```
    Start this component and implement the requirements of LifecycleBase.startInternal().
    
    Overrides:
    
    startInternal in class ValveBase
    
    Throws:
    
    LifecycleException - if this component detects a fatal error that prevents this component from being used
  - sendReplicationMessage
```
protected void sendReplicationMessage(Request request,
                          long totalstart,
                          boolean isCrossContext,
                          ClusterManager clusterManager,
                          CatalinaCluster containerCluster)
```
  - sendCrossContextSession
```
protected void sendCrossContextSession(CatalinaCluster containerCluster)
```
    Send all changed cross context sessions to backups
    
    Parameters:
    containerCluster -
  - resetReplicationRequest
```
protected void resetReplicationRequest(Request request,
                           boolean isCrossContext)
```
    Fix memory leak for long sessions with many changes, when no backup member exists!
    
    Parameters:
    request - current request after response is generated
    isCrossContext - check crosscontext threadlocal
  - resetDeltaRequest
```
protected void resetDeltaRequest(Session session)
```
    Reset DeltaRequest from session
    
    Parameters:
    session - HttpSession from current request or cross context session
  - sendSessionReplicationMessage
```
protected void sendSessionReplicationMessage(Request request,
                                 ClusterManager manager,
                                 CatalinaCluster cluster)
```
    Send Cluster Replication Request
    
    Parameters:
    request - current request
    manager - session manager
    cluster - replication cluster
  - sendMessage
```
protected void sendMessage(Session session,
               ClusterManager manager,
               CatalinaCluster cluster)
```
    Send message delta message from request session
    
    Parameters:
    session - current session
    manager - session manager
    cluster - replication cluster
  - send
```
protected void send(ClusterManager manager,
        CatalinaCluster cluster,
        String sessionId)
```
    send manager requestCompleted message to cluster
    
    Parameters:
    manager - SessionManager
    cluster - replication cluster
    sessionId - sessionid from the manager
    See Also:
    DeltaManager.requestCompleted(String), SimpleTcpCluster.send(ClusterMessage)
  - sendInvalidSessions
```
protected void sendInvalidSessions(ClusterManager manager,
                       CatalinaCluster cluster)
```
    check for session invalidations
    
    Parameters:
    manager - Associated manager
    cluster -
  - isRequestWithoutSessionChange
```
protected boolean isRequestWithoutSessionChange(String uri)
```
    is request without possible session change
    
    Parameters:
    uri - The request uri
    
    Returns:
    True if no session change
  - updateStats
```
protected void updateStats(long requestTime,
               long clusterTime)
```
    Protocol cluster replications stats
    
    Parameters:
    requestTime - Request time
    clusterTime - Cluster time
  - createPrimaryIndicator
```
protected void createPrimaryIndicator(Request request)
                               throws IOException
```
    Mark Request that processed at primary node with attribute primaryIndicatorName
    
    Parameters:
    request - The Servlet request
    
    Throws:
    
    IOException - IO error finding session

Class ReplicationValve

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.catalina.Lifecycle

Field Summary

Fields inherited from class org.apache.catalina.valves.ValveBase

Fields inherited from class org.apache.catalina.util.LifecycleMBeanBase

Fields inherited from interface org.apache.catalina.Lifecycle

Constructor Summary

Method Summary

Methods inherited from class org.apache.catalina.valves.ValveBase

Methods inherited from class org.apache.catalina.util.LifecycleMBeanBase

Methods inherited from class org.apache.catalina.util.LifecycleBase

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.catalina.Valve

Field Detail

sm

filter

crossContextSessions

doProcessingStats

totalRequestTime

totalSendTime

nrOfRequests

lastSendTime

nrOfFilterRequests

nrOfSendRequests

nrOfCrossContextSendRequests

primaryIndicator

primaryIndicatorName

Constructor Detail

ReplicationValve

Method Detail

getInfo

getCluster

setCluster

getFilter

setFilter

isPrimaryIndicator

setPrimaryIndicator

getPrimaryIndicatorName

setPrimaryIndicatorName

doStatistics

setStatistics

getLastSendTime

getNrOfRequests

getNrOfFilterRequests

getNrOfCrossContextSendRequests

getNrOfSendRequests

getTotalRequestTime

getTotalSendTime

registerReplicationSession

invoke

resetStatistics

startInternal

sendReplicationMessage

sendCrossContextSession

resetReplicationRequest

resetDeltaRequest

sendSessionReplicationMessage

sendMessage

send

sendInvalidSessions

isRequestWithoutSessionChange

updateStats

createPrimaryIndicator