Changeset 790 for trunk/sources/HeuristicLab.Hive.Client.Core/Core.cs

Timestamp:

11/20/08 15:41:25 (16 years ago)

Author:

whackl

Message:

implemented ticket (#376) (Client Services)

File:

• trunk/sources/HeuristicLab.Hive.Client.Core/Core.cs (modified) (7 diffs)

trunk/sources/HeuristicLab.Hive.Client.Core/Core.cs

@@ -32 +32 @@
 using System.Security.Policy;
 using System.Security;
+using HeuristicLab.Hive.Client.Communication;
+using BO = HeuristicLab.Hive.Contracts.BusinessObjects;
 
 
@@ -58 +60 @@
     }
 
-    public void Start() {      
-      Heartbeat beat = new Heartbeat();
-      beat.Interval = 5000;
-      beat.StartHeartbeat();  
+    public void Start() {
+      Heartbeat beat = new Heartbeat { Interval = 5000 };
+      beat.StartHeartbeat();
+
+      BO.Client clientInfo = new BO.Client { ClientId = Guid.NewGuid() };
+
+      ClientCommunicatorClient clientCommunicator = ServiceLocator.GetClientCommunicator();
+      clientCommunicator.LoginCompleted += new EventHandler<LoginCompletedEventArgs>(ClientCommunicator_LoginCompleted);
+      clientCommunicator.LoginAsync(clientInfo);
 
       MessageQueue queue = MessageQueue.GetInstance();
-      queue.AddMessage(MessageContainer.MessageType.FetchJob);     
+      queue.AddMessage(MessageContainer.MessageType.FetchJob);
       while (true) {
         MessageContainer container = queue.GetMessage();
         Debug.WriteLine("Main loop received this message: " + container.Message.ToString());
-        Logging.GetInstance().Info(this.ToString(), container.Message.ToString()); 
+        Logging.GetInstance().Info(this.ToString(), container.Message.ToString());
         DetermineAction(container);
       }
+    }
+
+    void ClientCommunicator_LoginCompleted(object sender, LoginCompletedEventArgs e) {     
+      if (e.Result.Success) {
+        Logging.GetInstance().Info(this.ToString(), "Login completed to Hive Server @ " + DateTime.Now);
+        Status.LoginTime = DateTime.Now;
+        Status.LoggedIn = true;
+      } else
+        Logging.GetInstance().Error(this.ToString(), e.Result.StatusMessage);
     }
 
@@ -77 +93 @@
       if (sandboxed) {
         pset = new PermissionSet(PermissionState.None);
-        pset.AddPermission(new SecurityPermission(SecurityPermissionFlag.Execution));        
+        pset.AddPermission(new SecurityPermission(SecurityPermissionFlag.Execution));
       } else {
         pset = new PermissionSet(PermissionState.Unrestricted);
@@ -85 +101 @@
       //Temp Fix!
       setup.PrivateBinPath = "plugins";
-      return System.AppDomain.CreateDomain("appD", AppDomain.CurrentDomain.Evidence, setup, pset, CreateStrongName(Assembly.GetExecutingAssembly())); 
+      return System.AppDomain.CreateDomain("appD", AppDomain.CurrentDomain.Evidence, setup, pset, CreateStrongName(Assembly.GetExecutingAssembly()));
 
     }
@@ -97 +113 @@
           Debug.WriteLine("-- Job Aborted Message received");
           break;
-        
-        
+
+
         case MessageContainer.MessageType.RequestSnapshot:
           engines[container.JobId].RequestSnapshot();
@@ -105 +121 @@
           engines[container.JobId].GetSnapshot();
           break;
-        
-        
+
+
         case MessageContainer.MessageType.FetchJob:
           bool sandboxed = true;
 
           IJob job = CreateNewJob();
-          
-          AppDomain appDomain = CreateNewAppDomain(true);
+
+          AppDomain appDomain = CreateNewAppDomain(false);
           appDomains.Add(job.JobId, appDomain);
-          
+
           Executor engine = (Executor)appDomain.CreateInstanceAndUnwrap(typeof(Executor).Assembly.GetName().Name, typeof(Executor).FullName);
           engine.Job = job;
@@ -132 +148 @@
       }
     }
-    
+
     /// <summary>
     /// Simulator Class for new Jobs. will be replaced with fetching Jobs from the Interface