Changeset 5375 for branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive

Timestamp:

01/25/11 17:34:47 (14 years ago)

Author:

ascheibe

Message:

#1233

• added various bits to the Hive Server
• adjusted data model

File:

• branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive/3.4/HiveService.cs (modified) (5 diffs)

branches/HeuristicLab.Hive-3.4/sources/HeuristicLab.Services.Hive/3.4/HiveService.cs

@@ -2 +2 @@
 using System.Collections.Generic;
 using System.Linq;
-using System.Text;
 using System.ServiceModel;
+using HeuristicLab.Services.Hive.Common;
+using HeuristicLab.Services.Hive.Common.DataTransfer;
 using HeuristicLab.Services.Hive.Common.ServiceContracts;
-using HeuristicLab.Services.Hive.Common.DataTransfer;
-using System.IO;
-using System.Security.Permissions;
-using System.Data.Linq;
-using HeuristicLab.Services.Hive.Common;
-using System.Transactions;
 
 namespace HeuristicLab.Services.Hive {
@@ -121 +116 @@
 
     public PluginData GetConfigurationFile() {
-      throw new NotImplementedException();
+      using (trans.OpenTransaction()) {
+        //TODO: move filename to app.config
+        PluginData configFile = dao.GetPluginDatas(x => x.FileName == "HeuristicLab 3.3.exe.config").SingleOrDefault();
+        if (configFile == null) {
+          //TODO: error handling
+          return null;
+        } else {
+          return configFile;
+        }
+      }
     }
 
@@ -173 +177 @@
     #region Login Methods
     public void Hello(Guid slaveId, string name, int cores, int memory) {
-      throw new NotImplementedException();
-    }
-
-    public void GoodBye() {
-      throw new NotImplementedException();
+      using (trans.OpenTransaction()) {
+        var slave = dao.GetSlave(slaveId);
+
+        if (slave == null) {
+          slave = new Slave { Id = slaveId, Name = name, Cores = cores, Memory = memory };
+          slave.IsAllowedToCalculate = true; //a little bit to optimistic?
+          slave.SlaveState = SlaveState.Idle;
+          dao.AddSlave(slave);
+        } else {
+          //TODO: error handling? 
+        }
+      }
+    }
+
+    public void GoodBye(Guid slaveId) {
+      using (trans.OpenTransaction()) {
+        var slave = dao.GetSlave(slaveId);
+        if (slave != null) {
+          slave.SlaveState = SlaveState.Offline;
+          dao.UpdateSlave(slave);
+        }
+      }
     }
     #endregion
@@ -203 +224 @@
       return dao.GetPlugins(x => true);
     }
+
     public IEnumerable<PluginData> GetPluginDatas(List<Guid> pluginIds) {
-      throw new NotImplementedException();
-    }
-    public Stream GetStreamedPluginDatas(List<Guid> pluginIds) {
-      throw new NotImplementedException();
-    }
+      List<PluginData> pluginDatas = new List<PluginData>();
+
+      using (trans.OpenTransaction()) {
+        foreach (Guid guid in pluginIds) {
+          List<PluginData> pluginData = dao.GetPluginDatas(x => x.PluginId == guid).ToList();
+          if (pluginData != null) {
+            pluginDatas.AddRange(pluginData);
+          } else {
+            //ignore ? 
+          }
+        }
+        return pluginDatas;
+      }
+    }
+
     #endregion
 
@@ -301 +333 @@
 
     #endregion
-  
+
   }
 }