Changeset 13887 for branches/thasling/DistributedGA/DistributedGA.Core.Host

Timestamp:

06/08/16 17:02:06 (8 years ago)

Author:

thasling

Message:

prepared protoype for next meeting

Location:

branches/thasling/DistributedGA/DistributedGA.Core.Host

Files:

• App.config (modified) (1 diff)
• Program.cs (modified) (1 diff)

branches/thasling/DistributedGA/DistributedGA.Core.Host/App.config

@@ -6 +6 @@
   <appSettings>
     <add key="ContactServerURL" value="net.tcp://localhost:9090/DistributedGA.ContactServer/ContactService"/>
-    <add key="LanIpPrefix" value="10."/>
+    <add key="LanIpPrefix" value="192."/>
+    <!--<add key="LanIpPrefix" value="10."/>-->
   </appSettings>
 </configuration>

branches/thasling/DistributedGA/DistributedGA.Core.Host/Program.cs

@@ -6 +6 @@
 using DistributedGA.Core.Interface;
 
-namespace DistributedGA.Core.Host {
-  class Program {
-    static void Main(string[] args) {
-      try {
-        Console.WriteLine("Starting peer...");
-        string ipPrefix = ConfigurationManager.AppSettings["LanIpPrefix"];
-        string serverUrl = ConfigurationManager.AppSettings["ContactServerURL"];
+namespace DistributedGA.Core.Host
+{
+    class Program
+    {
+        static void Main(string[] args)
+        {
+            try
+            {
+                Console.WriteLine("Starting peer...");
+                string ipPrefix = ConfigurationManager.AppSettings["LanIpPrefix"];
+                string serverUrl = ConfigurationManager.AppSettings["ContactServerURL"];
 
+                IMessageHandler h = new PeerNetworkMessageHandler();
+                h.Init(ipPrefix, serverUrl);
 
-        IMessageHandler h = new PeerNetworkMessageHandler();
-        h.Init(ipPrefix, serverUrl);
-        PeerInfo pi = h.GetPeerInfo();
-        Console.WriteLine(string.Format("Peer is hostet at IP: {0} and port: {1}", pi.IpAddress, pi.Port));
-        Thread.Sleep(1000 * 20);
-        Console.WriteLine("Current peers within network:");
-        foreach (var item in h.GetCurrentNetwork()) {
-          Console.WriteLine(string.Format("Peer at {0}:{1}", item.IpAddress, item.Port));
+                PeerInfo pi = h.GetPeerInfo();
+                Console.WriteLine(string.Format("Peer is hostet at IP: {0} and port: {1}", pi.IpAddress, pi.Port));
+                Thread.Sleep(1000 * 20);
+                Console.WriteLine("Current peers within network:");
+                foreach (var item in h.GetCurrentNetwork())
+                {
+                    Console.WriteLine(string.Format("Peer at {0}:{1}", item.IpAddress, item.Port));
+                }
+
+                int i = 0;
+                while (i < 10)
+                {
+                    i++;
+                    Thread.Sleep(1000 * 10);
+                    var message = CreateMessage(pi, i);
+                    Console.WriteLine("Publishing messages...");
+                    h.PublishDataToNetwork(message);
+                    Console.WriteLine("Messages published.");
+                    Console.WriteLine("Recieved messages:");
+                    foreach (var item in h.GetDataFromNetwork())
+                    {
+                        Console.WriteLine(string.Format("Message:{0}", GetString(item)));
+                    }
+                }
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine(ex.Message);
+                Console.WriteLine("press any key to continue...");
+                Console.ReadLine();
+            }
+
         }
-        int i = 1;
-        while (i < 10) {
-          i++;
-          Thread.Sleep(1000 * 10);
-          var pop1 = CreatePopulation();
-          Console.WriteLine("Publish population into network...");
-          h.PublishDataToNetwork(pop1);
-          Console.WriteLine("Population published.");
-          Console.WriteLine("Recieved populations:");
-          foreach (var item in h.GetDataFromNetwork()) {
-            Console.WriteLine(string.Format("Population with Quality: {0:2} in Iteration {1}", item.Quality, item.IterationNumber));
-          }
+
+        private static byte[][] CreateMessage(PeerInfo pi, int iterationNumber)
+        {
+            string msg1 = string.Concat("Message 1 from Peer ", pi.IpAddress, ":", pi.Port, " at iteration ", iterationNumber);
+            string msg2 = string.Concat("Message 2 from Peer ", pi.IpAddress, ":", pi.Port, " at iteration ", iterationNumber);
+            return new byte[][] { GetBytes(msg1), GetBytes(msg2) };
         }
-      } catch (Exception ex) {
-        Console.WriteLine(ex.Message);
-        Console.WriteLine("press any key to continue...");
-        Console.ReadLine();
-      }
 
+        static byte[] GetBytes(string str)
+        {
+            byte[] bytes = new byte[str.Length * sizeof(char)];
+            System.Buffer.BlockCopy(str.ToCharArray(), 0, bytes, 0, bytes.Length);
+            return bytes;
+        }
+
+        static string GetString(byte[] bytes)
+        {
+            char[] chars = new char[bytes.Length / sizeof(char)];
+            System.Buffer.BlockCopy(bytes, 0, chars, 0, bytes.Length);
+            return new string(chars);
+        }
     }
-
-    private static SolutionInfo[] CreatePopulation() {
-      SolutionInfo si1 = new SolutionInfo() {
-        IterationNumber = 1,
-        Quality = 3.5f,
-        Solution = new Solution() {
-        }
-      };
-      SolutionInfo si2 = new SolutionInfo() {
-        IterationNumber = 2,
-        Quality = 3.5f,
-        Solution = new Solution() {
-        }
-      };
-      SolutionInfo si3 = new SolutionInfo() {
-        IterationNumber = 3,
-        Quality = 3.5f,
-        Solution = new Solution() {
-        }
-      };
-      return new SolutionInfo[] { si1, si2, si3 };
-    }
-  }
 }