source: trunk/sources/HeuristicLab.Services.Hive/3.3/HiveJanitor.cs @ 12012

Last change on this file since 12012 was 12012, checked in by ascheibe, 7 years ago

#2212 merged r12008, r12009, r12010 back into trunk

File size: 2.6 KB
Line 
1#region License Information
2/* HeuristicLab
3 * Copyright (C) 2002-2015 Heuristic and Evolutionary Algorithms Laboratory (HEAL)
4 *
5 * This file is part of HeuristicLab.
6 *
7 * HeuristicLab is free software: you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation, either version 3 of the License, or
10 * (at your option) any later version.
11 *
12 * HeuristicLab is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15 * GNU General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License
18 * along with HeuristicLab. If not, see <http://www.gnu.org/licenses/>.
19 */
20#endregion
21
22using System;
23using System.Threading;
24using HeuristicLab.Services.Hive.DataAccess;
25
26namespace HeuristicLab.Services.Hive {
27  public class HiveJanitor {
28    private bool stop;
29    private AutoResetEvent waitHandle;
30
31    private DataAccess.ITransactionManager trans {
32      get { return ServiceLocator.Instance.TransactionManager; }
33    }
34
35    private IEventManager eventManager {
36      get { return ServiceLocator.Instance.EventManager; }
37    }
38
39    private IHiveDao dao {
40      get { return ServiceLocator.Instance.HiveDao; }
41    }
42
43    public HiveJanitor() {
44      stop = false;
45      waitHandle = new AutoResetEvent(true);
46    }
47
48    public void StopJanitor() {
49      stop = true;
50      waitHandle.Set();
51    }
52
53    public void Run() {
54      while (!stop) {
55        try {
56          LogFactory.GetLogger(typeof(HiveJanitor).Namespace).Log("HiveJanitor: starting cleanup");
57          bool cleanup = false;
58          trans.UseTransaction(() => {
59            DateTime lastCleanup = dao.GetLastCleanup();
60            if (DateTime.Now - lastCleanup > HeuristicLab.Services.Hive.Properties.Settings.Default.CleanupInterval) {
61              dao.SetLastCleanup(DateTime.Now);
62              cleanup = true;
63            }
64          }, true);
65
66          if (cleanup) {
67            eventManager.Cleanup();
68          }
69          LogFactory.GetLogger(typeof(HiveJanitor).Namespace).Log("HiveJanitor: cleanup finished");
70        }
71        catch (Exception e) {
72          LogFactory.GetLogger(typeof(HiveJanitor).Namespace).Log(string.Format("HiveJanitor: The following exception occured: {0}", e.ToString()));
73        }
74        waitHandle.WaitOne(HeuristicLab.Services.Hive.Properties.Settings.Default.CleanupInterval);
75      }
76      waitHandle.Close();
77    }
78  }
79}
80
81
82
Note: See TracBrowser for help on using the repository browser.