Changeset 13528 for branches/thasling/DistributedGA/DistributedGA.Core

Timestamp:

01/17/16 11:10:34 (8 years ago)

Author:

thasling

Message:

Peers only communicate with 10% of the network

Location:

branches/thasling/DistributedGA/DistributedGA.Core

Files:

• Implementation/PeerNetworkMessageHandler.cs (modified) (2 diffs)
• Implementation/WcfPeerListManager.cs (modified) (3 diffs)
• bin/Debug/DistributedGA.Core.dll (modified) (previous)
• bin/Debug/DistributedGA.Core.pdb (modified) (previous)
• obj/Debug/DesignTimeResolveAssemblyReferencesInput.cache (modified) (previous)
• obj/Debug/DistributedGA.Core.csproj.FileListAbsolute.txt (modified) (1 diff)
• obj/Debug/DistributedGA.Core.dll (modified) (previous)
• obj/Debug/DistributedGA.Core.pdb (modified) (previous)

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

@@ -51 +51 @@
 
                 peerListManager = new WcfPeerListManager();
+                //peerListManager = new TestPeerListManager();
                 peerListManager.Init(ownInstance);
 
@@ -72 +73 @@
                     try
                     {
-                        //HACK: If IP is same as own: it is a "localhost"
+                        //TODO: NEEDED WHEN PEER IS IN LAN, TOO????
+                        //Note: If IP is same as own: it is a "localhost"
                         if(peer.IpAddress.Equals(ownInstance.IpAddress))
                         {

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

@@ -12 +12 @@
     public class WcfPeerListManager : IPeerListManager
     {
-        //private const string SERVER_STRING = "http://localhost:9002/DistributedGA.ContactServer/ContactService";
         private const string SERVER_STRING = "http://localhost:9090/DistributedGA.ContactServer/ContactService";
 
@@ -31 +30 @@
         public List<PeerInfo> GetPeerList()
         {
-            if(allPeers == null)
+            //TODO: maybe always request a new list from the contact server so that he can refresh the heartbeat...
+            if (allPeers == null)
             {
-                allPeers =  client.GetPeerList(myself);
+                allPeers = client.GetPeerList(myself);
                 peersForMessaging = ChoosePeersForMessaging(allPeers);
             }
-            //TODO: maybe always request a new list from the contact server so that he can refresh the heartbeat...
-            return peersForMessaging;
+            //return peersForMessaging;
+            return allPeers; //TODO: Enable 10% list communication
         }
 
@@ -58 +58 @@
         private List<PeerInfo> ChoosePeersForMessaging(List<PeerInfo> allPeers)
         {
-            //TODO: strategy: 10% of list random choosen
-            int noOfPeers = allPeers.Count / 10; //communicate with 10% of the network
+            //communicate with 10% of the network
+            int noOfPeers = allPeers.Count / 10; 
+            List<Int32> indexList = GetRandomItemIndexes(noOfPeers, 0, allPeers.Count - 1);
             List<PeerInfo> res = new List<PeerInfo>();
+            foreach (Int32 index in indexList)
+            {
+                res.Add(allPeers.ElementAt(index));
+            }
+            return allPeers;
+        }
 
-            return allPeers;
+        private List<Int32> GetRandomItemIndexes(int noOfItems, int minValue, int maxValue)
+        {
+            List<Int32> res = new List<Int32>();
+            Random rnd = new Random();
+            int tmp = -1;
+            while (res.Count < noOfItems)
+            {
+                tmp = rnd.Next(minValue, maxValue);
+                if (!res.Contains(tmp))
+                {
+                    res.Add(tmp);
+                }
+            }
+            return res;
         }
 

branches/thasling/DistributedGA/DistributedGA.Core/obj/Debug/DistributedGA.Core.csproj.FileListAbsolute.txt

@@ -3 +3 @@
 M:\FHOOE_02_Master\_MasterArbeit\_Implementierung\MAKK_20151116a\MAKK\02_Implementierung\VS\DistributedGA\DistributedGA.Core\obj\Debug\DistributedGA.Core.dll
 M:\FHOOE_02_Master\_MasterArbeit\_Implementierung\MAKK_20151116a\MAKK\02_Implementierung\VS\DistributedGA\DistributedGA.Core\obj\Debug\DistributedGA.Core.pdb
+P:\_DATA\SVN\thasling\DistributedGA\DistributedGA.Core\bin\Debug\DistributedGA.Core.dll
+P:\_DATA\SVN\thasling\DistributedGA\DistributedGA.Core\bin\Debug\DistributedGA.Core.pdb
+P:\_DATA\SVN\thasling\DistributedGA\DistributedGA.Core\obj\Debug\DistributedGA.Core.csprojResolveAssemblyReference.cache
+P:\_DATA\SVN\thasling\DistributedGA\DistributedGA.Core\obj\Debug\DistributedGA.Core.dll
+P:\_DATA\SVN\thasling\DistributedGA\DistributedGA.Core\obj\Debug\DistributedGA.Core.pdb