Changeset 13956 for branches/thasling/DistributedGA/DistributedGA.Hive

Timestamp:

06/29/16 15:28:47 (8 years ago)

Author:

thasling

Message:

#2615:
finally fixed bug concerning message send to the wrong peers
also made communicationRate and messageCacheCapacity as paramters
integration in P2PMigrationAnalyzer still TBD

Location:

branches/thasling/DistributedGA/DistributedGA.Hive

Files:

• P2PMigrationAnalyzer.cs (modified) (1 diff)
• P2PTask.cs (modified) (1 diff)

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

@@ -99 +99 @@
       var lanIpPrefix = ((StringValue)(Parameters["LanIpPrefix"].ActualValue)).Value;
       var contactServerUri = ((StringValue)(Parameters["ContactServerURL"].ActualValue)).Value;
-      h.Init(lanIpPrefix, contactServerUri);
+      var problemInstance = ((StringValue)Parameters["JobGUID"].ActualValue).Value;
+      h.Init(lanIpPrefix, contactServerUri, problemInstance, 10000, 100);
       var peer = h.GetPeerInfo();
-      peer.ProblemInstance = ((StringValue)Parameters["JobGUID"].ActualValue).Value;
     }
 

branches/thasling/DistributedGA/DistributedGA.Hive/P2PTask.cs

@@ -99 +99 @@
                     var lanIpPrefix = ((StringValue)(Parameters["LanIpPrefix"].ActualValue)).Value;
                     var contactServerUri = ((StringValue)(Parameters["ContactServerURL"].ActualValue)).Value;
-                    h.Init(lanIpPrefix, contactServerUri);
+                    h.Init(lanIpPrefix, contactServerUri, "TEST", 10000, 100);
                     PeerInfo pi = h.GetPeerInfo();
                     log.LogMessage(string.Format("Peer is hostet at IP: {0} and port: {1}", pi.IpAddress, pi.Port));