Changeset 14061 for branches/thasling/DistributedGA/DistributedGA.Core/Implementation

Timestamp:

07/13/16 19:13:03 (8 years ago)

Author:

thasling

Message:

#2615:
PeerList is now recieved each 10 seconds instead of 20 seconds
PeerList is also recieved at Init-Call for the first time
changed data type of some parameters of P2PMigrationAnalyzer

File:

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

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

@@ -6 +6 @@
 using DistributedGA.Core.Interface;
 using System.Timers;
+using System.Threading.Tasks;
 
 namespace DistributedGA.Core.Implementation {
@@ -30 +31 @@
       cachedPeerList = new List<PeerInfo>();
       rand = new Random();
+      //Init
+      Task.Factory.StartNew(() => RefreshPeerList(this, null), TaskCreationOptions.LongRunning);
       //Start heartbeat timer
-      timer = new Timer(1000 * 20); //each 20 seconds
+      timer = new Timer(1000 * 10); //each 10 seconds
       timer.Elapsed += RefreshPeerList;
       timer.Start();
@@ -45 +48 @@
       using (var myChannelFactory = new ChannelFactory<IContactService>(binding, endpoint)) {
         using (IClientChannel client = (IClientChannel)myChannelFactory.CreateChannel()) {
-          ((IContactService)client).MakeLog(myself, msg);      
+          ((IContactService)client).MakeLog(myself, msg);
         }
       }
@@ -83 +86 @@
           using (var myChannelFactory = new ChannelFactory<IContactService>(binding, endpoint)) {
             using (IClientChannel client = (IClientChannel)myChannelFactory.CreateChannel()) {
-              allPeers = ((IContactService)client).GetPeerList(myself);            
+              allPeers = ((IContactService)client).GetPeerList(myself);
             }
           }