Changeset 13982 for branches/thasling/DistributedGA/DistributedGA.Core/Implementation/PeerNetworkMessageHandler.cs

Timestamp:

07/02/16 15:23:57 (8 years ago)

Author:

thasling

Message:

#2615:
made minor changes

File:

• branches/thasling/DistributedGA/DistributedGA.Core/Implementation/PeerNetworkMessageHandler.cs (modified) (6 diffs)

branches/thasling/DistributedGA/DistributedGA.Core/Implementation/PeerNetworkMessageHandler.cs

@@ -28 +28 @@
     private IMessageService host = null;
 
+    private double communicationRate;
+    private Random rand;
+
     public event EventHandler<Exception> ExceptionOccurend;
 
@@ -37 +40 @@
           ProblemInstance = problemInstance
         }; // TODO: get own peerinfo
+
+        this.communicationRate = communicationRate;
+        rand = new Random();
 
         writeQueue = new SizedConcurrentQueue<KeyValuePair<PeerInfo, byte[]>>();
@@ -48 +54 @@
 
         peerListManager = new WcfPeerListManager();
-        peerListManager.Init(ownInstance, contactServerUrl, communicationRate);
+        peerListManager.Init(ownInstance, contactServerUrl);
 
         sender = new WcfMessageSender();
@@ -72 +78 @@
     public void PublishDataToNetwork(byte[] data) {
       try {
+        var peers = peerListManager.GetPeerList();
         foreach (PeerInfo peer in peerListManager.GetPeerList()) {
+          var peersForMessaging = ChoosePeersForMessaging(ref peers);
+
           //maybe something will go wrong during network communication...
           try {
@@ -129 +138 @@
     }
 
+    private List<PeerInfo> ChoosePeersForMessaging(ref List<PeerInfo> allPeers) {
+      Shuffle<PeerInfo>(allPeers);
+      int toTake = Convert.ToInt32(allPeers.Count * communicationRate) + 1;
+      if (allPeers.Count > 0 && toTake == 0) {
+        toTake = 1;
+      }
+      return allPeers.Take(toTake).ToList(); ;
+    }
+
     private string GetInternalIpAddress(string ipPrefix) {
       try {
@@ -141 +159 @@
       }
       catch { return null; }
+    }
+
+    private void Shuffle<T>(IList<T> list) {
+      int n = list.Count;
+      while (n > 1) {
+        n--;
+        int k = rand.Next(n + 1);
+        T value = list[k];
+        list[k] = list[n];
+        list[n] = value;
+      }
     }