Class RateLimiterBase

java/org/apache/catalina/util/RateLimiterBase.java:29–161

Base implementation of RateLimiter, provides runtime data maintenance mechanism monitor.

 * Base implementation of {@link RateLimiter}, provides runtime data maintenance mechanism monitor.
 */
public abstract class RateLimiterBase implements RateLimiter {

    /**
     * Default constructor.
     */
    public RateLimiterBase() {
    }

    private static final AtomicInteger index = new AtomicInteger();

    TimeBucketCounterBase bucketCounter;

    int requests;
    int actualRequests;

    int duration;
    int actualDuration;

    // Initial policy name can be rewritten by setPolicyName()
    private String policyName = null;

    /*
     * The self-owned utility executor, will be instantiated only when ScheduledThreadPoolExecutor is absent during
     * filter configure phase.
     */
    private ScheduledThreadPoolExecutor internalExecutorService = null;

    /**
     * If policy name has not been specified, the first call of {@link #getPolicyName()} returns an auto-generated
     * policy name using the default policy name as prefix and followed by auto-increase index.
     *
     * @return default policy name, as a prefix of auto-generated policy name.
     */
    protected abstract String getDefaultPolicyName();


    @Override
    public String getPolicyName() {
        if (policyName == null) {
            policyName = getDefaultPolicyName() + "-" + index.incrementAndGet();
        }
        return policyName;
    }


    @Override
    public void setPolicyName(String name) {
        Objects.requireNonNull(name);
        this.policyName = name;
    }


    @Override
    public int getDuration() {
        return actualDuration;
    }