HArrayPoolMonitor.java

package org.objectweb.jonas.resource.pool.lib;

import org.objectweb.jonas.common.Log;
import org.objectweb.jonas.resource.pool.api.Pool;
import org.objectweb.util.monolog.api.Logger;
import org.objectweb.util.monolog.api.BasicLevel;

public class HArrayPoolMonitor extends Thread {

    private Pool pool;
    private Logger logger = null;

    private long adjustPeriod = 15 * 1000L;  // default = 15s in ms
    private long samplingPeriod = 60 * 1000L;  // default = 60s in ms
    private long validationPeriod = 10 * 60 * 1000L;  //default = 10 min in ms

    private long adjustTime = 0;
    private long samplingTime = 0;
    private long validationTime = 0;

    public HArrayPoolMonitor(Pool pool) {
        super("HArrayPoolMonitor");
        setDaemon(true);
        this.pool = pool;
        logger = Log.getLogger(Log.JONAS_JCA_PREFIX);
    }

    public void setAdjustPeriod(int sec) {
        logger.log(BasicLevel.DEBUG, " to " + sec);
        adjustPeriod = sec * 1000L;
    }

    public void setSamplingPeriod(int sec) {
        logger.log(BasicLevel.DEBUG, " to " + sec);
        samplingPeriod = sec * 1000L;
    }

    public void setValidationPeriod(int sec) {
        logger.log(BasicLevel.DEBUG, " to " + sec);
        validationPeriod = sec * 1000L;
    }

    public void run() {
        long timeout;
        resetTimes();
        while (true) {
            timeout = adjustTime;
            if (samplingTime < timeout) {
                timeout = samplingTime;
            }
            if (validationTime < timeout) {
                timeout = validationTime;
            }
            try {
                sleep(timeout);
                adjustTime -= timeout;
                samplingTime -= timeout;
                validationTime -= timeout;
                if (adjustTime <= 0) {
                    pool.adjust();
                    adjustTime = adjustPeriod;
                }
                if (samplingTime <= 0) {
                    pool.sampling();
                    samplingTime = samplingPeriod;
                }
                if (validationTime <= 0) {
                    pool.validateMCs();
                    validationTime = validationPeriod;
                }
            } catch (NullPointerException e) {
                logger.log(BasicLevel.ERROR, "HArrayPoolMonitor NPE:" + e);
                e.printStackTrace();
                resetTimes();
            } catch (Exception e) {
                logger.log(BasicLevel.ERROR, "HArrayPoolMonitor error:" + e);
                e.printStackTrace();
                resetTimes();
            }
        }
    }

    private void resetTimes() {
        adjustTime = adjustPeriod;
        samplingTime = samplingPeriod;
        validationTime = validationPeriod;
    }
}

---