Changeset 14009 for branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfPeerListManager.cs

Timestamp:

07/06/16 16:47:47 (8 years ago)

Author:

thasling

Message:

#2615:
made minor changes,
wrong commit happende last time, so still tbd:
-sort List
-dispose of anaylzer is never called

File:

• branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfPeerListManager.cs (modified) (2 diffs)

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

@@ -22 +22 @@
     private IContactService client;
 
-    private IContactService heartbeatClient;
+    private List<PeerInfo> cachedPeerList;
 
+    private double communicationRate;
 
+    private Random rand;
 
-    public void Init(PeerInfo source, string contactServerUrl) {
+    public void Init(PeerInfo source, string contactServerUrl, double communicationRate) {
       serverString = contactServerUrl;
+      this.communicationRate = communicationRate;
       myself = source;
-
-      //Init ChannelFactory and Clients
+      cachedPeerList = new List<PeerInfo>();
+      rand = new Random();
+      //Init ChannelFactory and Client
       var binding = new NetTcpBinding();
       var endpoint = new EndpointAddress(serverString);
       myChannelFactory = new ChannelFactory<IContactService>(binding, endpoint);
       client = myChannelFactory.CreateChannel();
-      heartbeatClient = myChannelFactory.CreateChannel();
       //Register Peer
-      client.RegisterPeer(source);
+      client.RegisterPeer(myself);
       //Start heartbeat timer
       timer = new Timer(1000 * 20); //each 20 seconds
-      timer.Elapsed += SendHeartbeatToServer;
+      timer.Elapsed += RefreshPeerList;
       timer.Start();
     }
 
     public List<PeerInfo> GetPeerList() {
-      try {
-        var allPeers = client.GetPeerList(myself); //maybe timout exception...
-        return allPeers;
-      }
-      catch { } //if maybe sending failed (because of connection lost, etc.): just ignore
-      return new List<PeerInfo>();
+      return cachedPeerList;
     }
 
@@ -61 +59 @@
       timer.Dispose();
       ((IClientChannel)client).Close();
-      ((IClientChannel)heartbeatClient).Close();
       myChannelFactory.Close();
-      client = null;
       myChannelFactory = null;
     }
 
-    private void SendHeartbeatToServer(object sender, ElapsedEventArgs e) {
+    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 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;
+      }
+    }
+
+    private void RefreshPeerList(object sender, ElapsedEventArgs e) {
       lock (timerLock) {
         try {
-          heartbeatClient.UpdateHeartbeat(myself);
+          var allPeers = client.GetPeerList(myself);
+          cachedPeerList = ChoosePeersForMessaging(ref allPeers);
         }
         catch { } //nothing to do