source: trunk/sources/HeuristicLab.Hive.Client.Core/3.2/Heartbeat.cs @ 1936

Last change on this file since 1936 was 1936, checked in by kgrading, 12 years ago

switchback to dynamic loading (#653)

File size: 3.7 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    public double Interval { get; set; }   
42    private Timer heartbeatTimer = null;
43       
44    public Heartbeat() {
45      Interval = 100;
46    }
47
48    public Heartbeat(double interval) {
49      Interval = interval;     
50    }
51
52    private WcfService wcfService;
53
54    /// <summary>
55    /// Starts the Heartbeat signal.
56    /// </summary>
57    public void StartHeartbeat() {
58      heartbeatTimer = new System.Timers.Timer();
59      heartbeatTimer.Interval = this.Interval;
60      heartbeatTimer.AutoReset = true;
61      heartbeatTimer.Elapsed += new ElapsedEventHandler(heartbeatTimer_Elapsed);
62      wcfService = WcfService.Instance;
63      wcfService.SendHeartBeatCompleted += new EventHandler<ProcessHeartBeatCompletedEventArgs>(wcfService_ProcessHeartBeatCompleted);
64      heartbeatTimer.Start();
65    }
66
67    /// <summary>
68    /// This Method is called every time the timer ticks
69    /// </summary>
70    /// <param name="sender"></param>
71    /// <param name="e"></param>
72    void heartbeatTimer_Elapsed(object sender, ElapsedEventArgs e) {
73      Console.WriteLine("tick"); 
74      ClientInfo info = ConfigManager.Instance.GetClientInfo();
75      // Todo: remove tempfix for free cores.
76
77      PerformanceCounter counter = new PerformanceCounter("Memory", "Available Bytes", true);
78      int mb = (int)(counter.NextValue() / 1024 / 1024);
79
80     
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      if (wcfService.ConnState == NetworkEnum.WcfConnState.Failed) {
89        wcfService.Connect();
90      } else if (wcfService.ConnState == NetworkEnum.WcfConnState.Loggedin) {
91        wcfService.SendHeartBeatAsync(heartBeatData);
92      }
93    }
94
95    void wcfService_ProcessHeartBeatCompleted(object sender, ProcessHeartBeatCompletedEventArgs e) {
96      System.Diagnostics.Debug.WriteLine("Heartbeat received! ");
97      e.Result.ActionRequest.ForEach(mc => MessageQueue.GetInstance().AddMessage(mc));     
98    }
99
100    public void StopHeartBeat() {
101      heartbeatTimer.Dispose();
102    }
103  }
104}
Note: See TracBrowser for help on using the repository browser.