#region License Information /* HeuristicLab * Copyright (C) 2002-2014 Heuristic and Evolutionary Algorithms Laboratory (HEAL) * * This file is part of HeuristicLab. * * HeuristicLab is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * HeuristicLab is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with HeuristicLab. If not, see . */ #endregion using System; using System.Threading; using HeuristicLab.Services.Hive.DataAccess; namespace HeuristicLab.Services.Hive { public class HiveJanitor { private bool stop; private AutoResetEvent cleanupWaitHandle; private AutoResetEvent generateStatisticsWaitHandle; private DataAccess.ITransactionManager trans { get { return ServiceLocator.Instance.TransactionManager; } } private IEventManager eventManager { get { return ServiceLocator.Instance.EventManager; } } private IStatisticsGenerator statisticsGenerator { get { return ServiceLocator.Instance.StatisticsGenerator; } } private IHiveDao dao { get { return ServiceLocator.Instance.HiveDao; } } public HiveJanitor() { stop = false; cleanupWaitHandle = new AutoResetEvent(true); generateStatisticsWaitHandle = new AutoResetEvent(true); } public void StopJanitor() { stop = true; cleanupWaitHandle.Set(); } public void RunCleanup() { while (!stop) { try { LogFactory.GetLogger(typeof(HiveJanitor).Namespace).Log("HiveJanitor: starting cleanup"); bool cleanup = false; trans.UseTransaction(() => { DateTime lastCleanup = dao.GetLastCleanup(); if (DateTime.Now - lastCleanup > HeuristicLab.Services.Hive.Properties.Settings.Default.CleanupInterval) { dao.SetLastCleanup(DateTime.Now); cleanup = true; } }, true); if (cleanup) { eventManager.Cleanup(); } LogFactory.GetLogger(typeof(HiveJanitor).Namespace).Log("HiveJanitor: cleanup finished"); } catch (Exception e) { LogFactory.GetLogger(typeof(HiveJanitor).Namespace).Log(string.Format("HiveJanitor: The following exception occured: {0}", e.ToString())); } cleanupWaitHandle.WaitOne(HeuristicLab.Services.Hive.Properties.Settings.Default.CleanupInterval); } cleanupWaitHandle.Close(); } public void RunGenerateStatistics() { while (!stop) { try { LogFactory.GetLogger(typeof(HiveJanitor).Namespace).Log("HiveJanitor: starting generate statistics"); statisticsGenerator.GenerateStatistics(); LogFactory.GetLogger(typeof(HiveJanitor).Namespace).Log("HiveJanitor: generate statistics finished"); } catch (Exception e) { LogFactory.GetLogger(typeof(HiveJanitor).Namespace).Log(string.Format("HiveJanitor: The following exception occured: {0}", e)); } generateStatisticsWaitHandle.WaitOne(Properties.Settings.Default.GenerateStatisticsInterval); } generateStatisticsWaitHandle.Close(); } } }