Changeset 811

Timestamp:

11/24/08 13:38:55 (16 years ago)

Author:

kgrading

Message:

implemented the async calls to GetSnapshot and GetFinishedJob (#383)

Location:

trunk/sources

Files:

• HeuristicLab.Hive.Client.Core/Core.cs (modified) (2 diffs)
• HeuristicLab.Hive.Server.Core/ClientCommunicator.cs (modified) (1 diff)

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

@@ -67 +67 @@
 
     public void Start() {
-      Heartbeat beat = new Heartbeat { Interval = 30000 };
+      Heartbeat beat = new Heartbeat { Interval = 5000 };
       beat.StartHeartbeat();
 
@@ -124 +124 @@
           break;
         case MessageContainer.MessageType.SnapshotReady:
-          //Grabbing of the snapshot will need some time, so let's make this functun async
-          GetASnapshotDelegate ssd = new GetASnapshotDelegate(engines[container.JobId].GetSnapshot);
-          ssd.BeginInvoke(new AsyncCallback(SnapshotReceived), null);
-          //engines[container.JobId].GetSnapshot();
+          Thread ssr = new Thread(new ParameterizedThreadStart(GetSnapshot));
+          ssr.Start(container.JobId);          
           break;
 
-
-        case MessageContainer.MessageType.FetchJob:          
+        case MessageContainer.MessageType.FetchJob: 
           clientCommunicator.PullJobAsync(Guid.NewGuid());
-          break;
-
+          break;          
         case MessageContainer.MessageType.FinishedJob:
-          engines[container.JobId].GetFinishedJob();
-          AppDomain.Unload(appDomains[container.JobId]);
-          appDomains.Remove(container.JobId);
-          engines.Remove(container.JobId);
-          Status.CurrentJobs--;
-          Debug.WriteLine("Decrement CurrentJobs to:"+Status.CurrentJobs.ToString());
-          break;
+          Thread finThread = new Thread(new ParameterizedThreadStart(GetFinishedJob));
+          finThread.Start(container.JobId);          
+          break;      
       }
     }
 
-    void SnapshotReceived(IAsyncResult res) {
-      AsyncResult ar = (AsyncResult) res;
-      GetASnapshotDelegate gss = (GetASnapshotDelegate) ar.AsyncDelegate;
-      String objectRepr = gss.EndInvoke(res);
+    private void GetFinishedJob(object jobId) {
+      long jId = (long)jobId;
+      String obj = engines[jId].GetFinishedJob();
+      engines[jId].GetFinishedJob();
+      AppDomain.Unload(appDomains[jId]);
+      appDomains.Remove(jId);
+      engines.Remove(jId);
+
+      Status.CurrentJobs--;
+      Debug.WriteLine("Decrement CurrentJobs to:" + Status.CurrentJobs.ToString());      
+    }
+
+    private void GetSnapshot(object jobId) {
+      long jId = (long)jobId;
+      String obj = engines[jId].GetSnapshot();
     }
 

trunk/sources/HeuristicLab.Hive.Server.Core/ClientCommunicator.cs

@@ -14 +14 @@
     List<ClientInfo> clients;
     LinkedList<long> jobs;
-    int nrOfJobs = 10;
+    int nrOfJobs = 3;
 
     public ClientCommunicator() {
       jobs = new LinkedList<long>();
-      for (long i = 1; i < nrOfJobs; i++) {
+      for (long i = 0; i < nrOfJobs; i++) {
         jobs.AddFirst(i);
       }