/*

  * This software is licensed under the Apache License, Version 2.0

  * (the "License") agreement; you may not use this file except in compliance with

  * the License.  You may obtain a copy of the License at

  * 

  *      http://www.apache.org/licenses/LICENSE-2.0

  * 

  * Unless required by applicable law or agreed to in writing, software

  * distributed under the License is distributed on an "AS IS" BASIS,

  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

  * See the License for the specific language governing permissions and

  * limitations under the License.

  */

 package net.admin4j.timer;

 import java.util.HashSet;

 import java.util.Map.Entry;

 import org.slf4j.Logger;

 import org.slf4j.LoggerFactory;

 import net.admin4j.config.Admin4JConfiguration;

 import net.admin4j.dao.DAOFactory;

 public class TaskTimerCleanupTask implements Runnable {

     private static Logger log = LoggerFactory.getLogger(TaskTimerCleanupTask.class);

     public void run() {

         log.debug("Purging obsolete observations");

         for (Entry<String, TaskTimer> entry: TaskTimerRegistry.getRegisteredDataMeasures().entrySet()) {

             for (DataMeasure measure : entry.getValue().getDataMeasures()) {

                 measure.purgeObsoleteObservations();

             }

         }

         if (Admin4JConfiguration.isPerformanceInfoStored()) {

             log.debug("Saving observations");

             DAOFactory.getTaskTimerDAO().saveAll(

                     new HashSet<TaskTimer>(

                             TaskTimerRegistry.getRegisteredDataMeasures().values()));

         }

     }

 }