Free cookie consent management tool by TermsFeed Policy Generator

source: branches/Persistence Test/HeuristicLab.Hive.Client.Core/3.2/Heartbeat.cs @ 4004

Last change on this file since 4004 was 2116, checked in by kgrading, 15 years ago

removed additional login after 1 hour (#467)

File size: 4.5 KB
Line 
1#region License Information
2/* HeuristicLab
3 * Copyright (C) 2002-2008 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.Collections.Generic;
24using System.Linq;
25using System.Text;
26using System.Timers;
27using HeuristicLab.Hive.Client.Common;
28using HeuristicLab.Hive.Client.Communication;
29using System.Diagnostics;
30using HeuristicLab.Hive.Contracts.BusinessObjects;
31using HeuristicLab.Hive.Contracts;
32using HeuristicLab.Hive.Client.Core.ConfigurationManager;
33using HeuristicLab.Hive.Client.Communication.ServerService;
34//using BO = HeuristicLab.Hive.Contracts.BusinessObjects;
35
36namespace HeuristicLab.Hive.Client.Core {
37  /// <summary>
38  /// Heartbeat class. It sends every x ms a heartbeat to the server and receives a Message
39  /// </summary>
40  public class Heartbeat {
41
42    private bool offline;
43
44    public double Interval { get; set; }   
45    private Timer heartbeatTimer = null;
46       
47    public Heartbeat() {
48      Interval = 100;
49    }
50
51    public Heartbeat(double interval) {
52      Interval = interval;     
53    }
54
55    private WcfService wcfService;
56
57    /// <summary>
58    /// Starts the Heartbeat signal.
59    /// </summary>
60    public void StartHeartbeat() {
61      heartbeatTimer = new System.Timers.Timer();
62      heartbeatTimer.Interval = this.Interval;
63      heartbeatTimer.AutoReset = true;
64      heartbeatTimer.Elapsed += new ElapsedEventHandler(heartbeatTimer_Elapsed);
65      wcfService = WcfService.Instance;
66      wcfService.SendHeartBeatCompleted += new EventHandler<ProcessHeartBeatCompletedEventArgs>(wcfService_ProcessHeartBeatCompleted);
67      heartbeatTimer.Start();
68    }
69
70    /// <summary>
71    /// This Method is called every time the timer ticks
72    /// </summary>
73    /// <param name="sender"></param>
74    /// <param name="e"></param>
75    void heartbeatTimer_Elapsed(object sender, ElapsedEventArgs e) {
76      Console.WriteLine("tick"); 
77      ClientInfo info = ConfigManager.Instance.GetClientInfo();     
78
79      PerformanceCounter counter = new PerformanceCounter("Memory", "Available Bytes", true);
80      int mb = (int)(counter.NextValue() / 1024 / 1024);
81
82      HeartBeatData heartBeatData = new HeartBeatData {
83        ClientId = info.Id,
84        FreeCores = info.NrOfCores - ConfigManager.Instance.GetUsedCores(),
85        FreeMemory = mb,
86        JobProgress = ConfigManager.Instance.GetProgressOfAllJobs()     
87      };
88     
89      DateTime lastFullHour = DateTime.Parse(DateTime.Now.Hour.ToString() + ":00");
90      TimeSpan span = DateTime.Now - lastFullHour;
91      if (span.TotalSeconds < (Interval/1000)) {
92        if (UptimeManager.Instance.isOnline()) {
93          //That's quiet simple: Just reconnect and you're good for new jobs
94          if (wcfService.ConnState != NetworkEnum.WcfConnState.Loggedin) {
95            Logging.Instance.Info(this.ToString(), "Client goes online according to timetable");
96            wcfService.Connect();
97          }
98        } else {
99          //We have quit a lot of work to do here: snapshot all jobs, submit them back, then disconnect and then pray to god that nothing goes wrong
100          MessageQueue.GetInstance().AddMessage(MessageContainer.MessageType.UptimeLimitDisconnect);                 
101        }       
102      }
103      if (wcfService.ConnState == NetworkEnum.WcfConnState.Failed) {
104        wcfService.Connect();
105      } else if (wcfService.ConnState == NetworkEnum.WcfConnState.Loggedin) {
106        wcfService.SendHeartBeatAsync(heartBeatData);
107      }
108    }
109
110    void wcfService_ProcessHeartBeatCompleted(object sender, ProcessHeartBeatCompletedEventArgs e) {
111      System.Diagnostics.Debug.WriteLine("Heartbeat received! ");
112      e.Result.ActionRequest.ForEach(mc => MessageQueue.GetInstance().AddMessage(mc));     
113    }
114
115    public void StopHeartBeat() {
116      heartbeatTimer.Dispose();
117    }
118  }
119}
Note: See TracBrowser for help on using the repository browser.