Class ReplicationValve

java/org/apache/catalina/ha/tcp/ReplicationValve.java:52–639

Valve that triggers session replication across the cluster.

 * Valve that triggers session replication across the cluster.
 */
public class ReplicationValve extends ValveBase implements ClusterValve {

    private static final Log log = LogFactory.getLog(ReplicationValve.class);

    // ----------------------------------------------------- Instance Variables

    /**
     * The StringManager for this package.
     */
    protected static final StringManager sm = StringManager.getManager(Constants.Package);

    private CatalinaCluster cluster = null;

    /**
     * Filter expression
     */
    protected Pattern filter = null;

    /**
     * crossContext session container
     */
    protected final ThreadLocal<ArrayList<DeltaSession>> crossContextSessions = new ThreadLocal<>();

    /**
     * doProcessingStats (default = off)
     */
    protected boolean doProcessingStats = false;

    /**
     * Total request time in nanoseconds.
     */
    protected LongAdder totalRequestTime = new LongAdder();
    /**
     * Total send time in nanoseconds.
     */
    protected LongAdder totalSendTime = new LongAdder();
    /**
     * Total number of requests.
     */
    protected AtomicLong lastSendTime = new AtomicLong();
    /**
     * Number of requests filtered out.
     */
    protected LongAdder nrOfFilterRequests = new LongAdder();
    /**
     * Number of requests sent for replication.
     */
    protected LongAdder nrOfSendRequests = new LongAdder();
    /**
     * Number of cross-context requests sent for replication.
     */
    protected LongAdder nrOfCrossContextSendRequests = new LongAdder();
    /**
     * Number of requests.
     */
    protected LongAdder nrOfRequests = new LongAdder();

    /**