Changeset 13888
- Timestamp:
- 06/09/16 11:37:51 (8 years ago)
- Location:
- branches/thasling/DistributedGA
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/thasling/DistributedGA/DistributedGA.ContactServer/ContactServiceImpl.cs
r13887 r13888 25 25 allPeers = new ConcurrentDictionary<PeerInfo, DateTime>(); 26 26 27 timer = new Timer(1000 * 60 * 60); //each hour27 timer = new Timer(1000); //each hour 28 28 timer.Elapsed += CleanUpContactTable; 29 29 timer.Start(); … … 104 104 if (allPeers.TryGetValue(pi, out tmp)) 105 105 { 106 if (tmp.AddHours(1f) < deadline) 106 //if (tmp.AddHours(1f) < deadline) 107 if (tmp.AddMinutes(1) < deadline) //TODO 107 108 { 108 109 //if (tmp < deadline.AddHours(1f)) { -
branches/thasling/DistributedGA/DistributedGA.Core.Host/Program.cs
r13887 r13888 31 31 32 32 int i = 0; 33 while ( i < 10)33 while (true) 34 34 { 35 35 i++; 36 Thread.Sleep(1000 * 10);36 Thread.Sleep(1000); 37 37 var message = CreateMessage(pi, i); 38 38 Console.WriteLine("Publishing messages..."); -
branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfPeerListManager.cs
r13887 r13888 28 28 myself = source; 29 29 client.RegisterPeer(source); 30 timer = new Timer(1000 * 60 * 5); //each 5 minutes30 timer = new Timer(1000 ); //each 5 minutes 31 31 timer.Elapsed += SendHeartbeatToServer; 32 32 timer.Start();
Note: See TracChangeset
for help on using the changeset viewer.