- Timestamp:
- 11/14/11 22:44:16 (13 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/sources/HeuristicLab.Clients.Hive.Slave/3.3/Core.cs
r6983 r6994 149 149 clientCom.LogMessage(string.Format("Message: {0} for task: {1} ", container.Message.ToString(), container.TaskId)); 150 150 151 if (container is ExecutorMessageContainer<Guid>) { 152 ExecutorMessageContainer<Guid> c = (ExecutorMessageContainer<Guid>)container; 153 c.execute(); 154 } else if (container is MessageContainer) { 155 switch (container.Message) { 156 case MessageContainer.MessageType.CalculateTask: 157 CalculateTaskAsync(container.TaskId); 158 break; 159 case MessageContainer.MessageType.AbortTask: 160 AbortTaskAsync(container.TaskId); 161 break; 162 case MessageContainer.MessageType.StopTask: 163 StopTaskAsync(container.TaskId); 164 break; 165 case MessageContainer.MessageType.PauseTask: 166 PauseTaskAsync(container.TaskId); 167 break; 168 case MessageContainer.MessageType.StopAll: 169 DoStopAll(); 170 break; 171 case MessageContainer.MessageType.PauseAll: 172 DoPauseAll(); 173 break; 174 case MessageContainer.MessageType.AbortAll: 175 DoAbortAll(); 176 break; 177 case MessageContainer.MessageType.ShutdownSlave: 178 ShutdownCore(); 179 break; 180 case MessageContainer.MessageType.Restart: 181 DoStartSlave(); 182 break; 183 case MessageContainer.MessageType.Sleep: 184 Sleep(); 185 break; 186 case MessageContainer.MessageType.SayHello: 187 wcfService.Connect(configManager.GetClientInfo()); 188 break; 189 case MessageContainer.MessageType.NewHBInterval: 190 int interval = wcfService.GetNewHeartbeatInterval(ConfigManager.Instance.GetClientInfo().Id); 191 if (interval != -1) { 192 HeartbeatManager.Interval = TimeSpan.FromSeconds(interval); 193 } 194 break; 195 } 196 } else { 197 clientCom.LogMessage("Unknown MessageContainer: " + container); 151 switch (container.Message) { 152 case MessageContainer.MessageType.CalculateTask: 153 CalculateTaskAsync(container.TaskId); 154 break; 155 case MessageContainer.MessageType.AbortTask: 156 AbortTaskAsync(container.TaskId); 157 break; 158 case MessageContainer.MessageType.StopTask: 159 StopTaskAsync(container.TaskId); 160 break; 161 case MessageContainer.MessageType.PauseTask: 162 PauseTaskAsync(container.TaskId); 163 break; 164 case MessageContainer.MessageType.StopAll: 165 DoStopAll(); 166 break; 167 case MessageContainer.MessageType.PauseAll: 168 DoPauseAll(); 169 break; 170 case MessageContainer.MessageType.AbortAll: 171 DoAbortAll(); 172 break; 173 case MessageContainer.MessageType.ShutdownSlave: 174 ShutdownCore(); 175 break; 176 case MessageContainer.MessageType.Restart: 177 DoStartSlave(); 178 break; 179 case MessageContainer.MessageType.Sleep: 180 Sleep(); 181 break; 182 case MessageContainer.MessageType.SayHello: 183 wcfService.Connect(configManager.GetClientInfo()); 184 break; 185 case MessageContainer.MessageType.NewHBInterval: 186 int interval = wcfService.GetNewHeartbeatInterval(ConfigManager.Instance.GetClientInfo().Id); 187 if (interval != -1) { 188 HeartbeatManager.Interval = TimeSpan.FromSeconds(interval); 189 } 190 break; 198 191 } 199 192 }
Note: See TracChangeset
for help on using the changeset viewer.