Application: gvSIG desktop » Library: org.gvsig.tools

package org.gvsig.tools.logger;

import org.slf4j.Logger;

public class FilteredLogger {

        protected int count = 0;

        protected final Logger logger;

        protected final int max;

        protected String processName;

        protected long interval;

        protected long lastTime;

        protected boolean showTooManyErrorsMessage;

        public FilteredLogger(Logger logger, String processName, int max) {

            this.max = max;

            this.logger = logger;

            this.processName = processName;

            this.count = 0;

            this.interval = -1;

            this.lastTime = -1;

            this.showTooManyErrorsMessage = false;

        }

        public FilteredLogger(Logger logger, String processName, long milis) {

            this(logger, processName, 0);

            this.interval = milis;

        }

        public FilteredLogger setInterval(long interval) {

            this.interval = interval;

            return this;

        }

        protected boolean canDumpMoreMessages() {

            long now = System.currentTimeMillis();

            if(this.max > 0 && interval > 0){

                if( this.lastTime  == 0){

                    if( ++this.count < this.max ) {

                        return true;

                    } else if( this.count == this.max ) {

                        this.logger.info("Too many errors, don't dump more in this process ("+processName+") until "+this.interval+"ms.");

                        this.lastTime = now;

                    }

                    return false;

                }

                if( now - this.lastTime > this.interval ) {

                    return false;

                }

                this.lastTime = 0;

                this.count = 0;

                return true;

            } else if( interval>0 ) {

                if( this.lastTime < 0 ) {

                    this.lastTime = now;

                    this.showTooManyErrorsMessage = true;

                    return true;

                }

                if( now - this.lastTime > this.interval ) {

                    this.lastTime = now;

                    this.showTooManyErrorsMessage = true;

                    return true;

                }

                if( this.showTooManyErrorsMessage ) {

                    this.logger.info("Too many errors, skip some in this process ("+processName+").");

                    this.showTooManyErrorsMessage = false;

                }

                return false;

            } else {

                if( ++this.count < this.max ) {

                    return true;

                } else if( this.count == this.max ) {

                    this.logger.info("Too many errors, don't dump more in this process ("+processName+").");

                }

                return false;

            }

        }

        public void warn(String msg, Throwable th) {

            if( canDumpMoreMessages() ) {

                this.logger.warn(msg,th);

            }

        }

        public void warn(String msg) {

            if( canDumpMoreMessages() ) {

                this.logger.warn(msg);

            }

        }

        public void error(String msg, Throwable th) {

            if( canDumpMoreMessages() ) {

                this.logger.error(msg,th);

            }

        }

        public void error(String msg) {

            if( canDumpMoreMessages() ) {

                this.logger.error(msg);

            }

        }

        public void info(String msg) {

            if( canDumpMoreMessages() ) {

                this.logger.info(msg);

            }

        }

}