Changeset 923 for trunk/sources/HeuristicLab.Hive.Client.Core/Heartbeat.cs
- Timestamp:
- 12/07/08 16:14:00 (15 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/sources/HeuristicLab.Hive.Client.Core/Heartbeat.cs
r798 r923 48 48 } 49 49 50 private ClientCommunicatorClient clientCommunicator;50 private WcfService wcfService; 51 51 52 52 /// <summary> … … 58 58 heartbeatTimer.AutoReset = true; 59 59 heartbeatTimer.Elapsed += new ElapsedEventHandler(heartbeatTimer_Elapsed); 60 clientCommunicator = ServiceLocator.GetClientCommunicator();61 clientCommunicator.SendHeartBeatCompleted += new EventHandler<SendHeartBeatCompletedEventArgs>(ClientCommunicator_SendHeartBeatCompleted);60 wcfService = WcfService.Instance; 61 wcfService.SendHeartBeatCompleted += new EventHandler<SendHeartBeatCompletedEventArgs>(wcfService_SendHeartBeatCompleted); 62 62 heartbeatTimer.Start(); 63 63 } … … 74 74 freeMemory = 1000, 75 75 jobProgress = 1}; 76 clientCommunicator.SendHeartBeatAsync(heartBeatData); 76 if (wcfService.ConnState == WcfService.ConnectionState.failed) { 77 wcfService.Connect(); 78 } else if (wcfService.ConnState == WcfService.ConnectionState.connected) { 79 wcfService.SendHeartBeatAsync(heartBeatData); 80 } 77 81 } 78 82 79 void ClientCommunicator_SendHeartBeatCompleted(object sender, SendHeartBeatCompletedEventArgs e) {83 void wcfService_SendHeartBeatCompleted(object sender, SendHeartBeatCompletedEventArgs e) { 80 84 System.Diagnostics.Debug.WriteLine("Heartbeat received! "); 81 85 e.Result.ActionRequest.ForEach(mc => MessageQueue.GetInstance().AddMessage(mc));
Note: See TracChangeset
for help on using the changeset viewer.