Changeset 14019

Timestamp:

07/07/16 16:33:17 (8 years ago)

Author:

thasling

Message:

#2615:
added jobguid as parameter, so it can be accesed from outside the analyzer

File:

• branches/thasling/DistributedGA/DistributedGA.Hive/P2PMigrationAnalyzer.cs (modified) (4 diffs)

branches/thasling/DistributedGA/DistributedGA.Hive/P2PMigrationAnalyzer.cs

@@ -21 +21 @@
 
 using System;
+using System.Collections;
 using System.Collections.Generic;
 using System.IO;
 using System.Linq;
+using DistributedGA.Core.Domain;
 using DistributedGA.Core.Implementation;
 using DistributedGA.Core.Interface;
@@ -70 +72 @@
     public IValueParameter<ILog> LogParameter {
       get { return (IValueParameter<ILog>)Parameters["Log"]; }
+    }
+    public ILookupParameter<StringValue> JobGuidParameter {
+      get { return (ILookupParameter<StringValue>)Parameters["JobGUID"]; }
     }
 
@@ -225 +230 @@
           // recieve
           var message = h.GetDataFromNetwork();
-         
+          List<KeyValuePair<PeerInfo, byte[]>> immigrants = new List<KeyValuePair<PeerInfo, byte[]>>();
+          //limit number of immigrants to use
+          if(noOfEmigrants < message.Count)
+          {
+            immigrants = message.Skip(Math.Max(0, message.Count() - noOfEmigrants)).ToList();
+          } else {
+            immigrants = message;
+          }
+          
           // remove individuals from population to make place for immigrants
-          for (int i = 0; i < message.Count; i++) {
+          for (int i = 0; i < immigrants.Count; i++) {
             switch (selectedMigStratReplace) {
               case MigrationStrategy.Best:
@@ -251 +264 @@
           var qualities = QualityParameter.ActualValue;
           var qualityTranslatedName = QualityParameter.TranslatedName;
-          foreach (var msg in message) {
+          foreach (var msg in immigrants) {
             using (var stream = new MemoryStream(msg.Value)) {
               var immigrantScope = HeuristicLab.Persistence.Default.Xml.XmlParser.Deserialize<IScope>(stream);