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 void setInterval(long interval) {

            this.interval = interval;

        }

        protected boolean canDumpMoreMessages() {

            if( interval>0 ) {

                long now = System.currentTimeMillis();

                if( this.lastTime < 0 ) {

                    this.lastTime = now;

                    this.showTooManyErrorsMessage = true;

                    return true;

                }

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

                    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 info(String msg) {

            if( canDumpMoreMessages() ) {

                this.logger.info(msg);

            }

        }

}