Changeset 13547 for branches/thasling/DistributedGA
- Timestamp:
- 01/18/16 15:28:29 (9 years ago)
- Location:
- branches/thasling/DistributedGA
- Files:
-
- 5 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/thasling/DistributedGA/DistributedGA.Core/Implementation/PeerNetworkMessageHandler.cs
r13541 r13547 24 24 private ConcurrentQueue<SolutionInfo> writeQueue; 25 25 private ConcurrentQueue<SolutionInfo> readQueue; 26 private bool collectingInFirstQueue = true; //currently first queue is filled with recieved populations27 26 28 27 //uses IMessageService for recieving population from one peer at once … … 55 54 } catch (Exception ex) { 56 55 AddError("PeerNetworkMessageHandler.Init", ex); 56 } 57 } 58 59 public void Dispose() { 60 try { 61 host.Dispose(); 62 } catch (Exception ex) { 63 AddError("PeerNetworkMessageHandler.Dispose", ex); 57 64 } 58 65 } … … 144 151 } 145 152 } 153 146 154 } 147 155 } -
branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfMessageService.cs
r13541 r13547 42 42 } 43 43 44 public void Dispose() { 45 _ResetEvent.Set(); 46 } 47 44 48 private int FreeTcpPort() { 45 49 TcpListener l = new TcpListener(IPAddress.Loopback, 0); … … 55 59 } 56 60 } 57 58 61 } 59 62 } -
branches/thasling/DistributedGA/DistributedGA.Core/Interface/IMessageHandler.cs
r13524 r13547 1 using DistributedGA.Core.Domain; 2 using System; 3 using System.Collections.Generic; 4 using System.Linq; 5 using System.Text; 6 using System.Threading.Tasks; 1 using System.Collections.Generic; 2 using DistributedGA.Core.Domain; 7 3 8 namespace DistributedGA.Core.Interface 9 { 10 public interface IMessageHandler 11 { 12 void Init(); //Registers at contract-server 4 namespace DistributedGA.Core.Interface { 5 public interface IMessageHandler { 6 void Init(); //Registers at contract-server 13 7 14 8 void PublishMigrationInfo(SolutionInfo[] population); 15 9 16 10 SolutionInfo[] GetMigrationInfo(); 17 11 18 12 PeerInfo GetPeerInfo(); 19 13 20 List<PeerInfo> GetCurrentNetwork(); 21 } 14 List<PeerInfo> GetCurrentNetwork(); 15 16 void Dispose(); 17 } 22 18 } -
branches/thasling/DistributedGA/DistributedGA.Core/Interface/IMessageService.cs
r13524 r13547 1 using DistributedGA.Core.Domain; 2 using System; 3 using System.Collections.Generic; 4 using System.Linq; 5 using System.Text; 6 using System.Threading.Tasks; 1 using System; 2 using DistributedGA.Core.Domain; 7 3 8 namespace DistributedGA.Core.Interface 9 { 10 public interface IMessageService 11 { 12 /// <summary> 13 /// Initializes a WCF service and host it with another thread 14 /// </summary> 15 /// <param name="ip">current external ip address</param> 16 /// <returns>The port, on which the service was successfully hosted</returns> 17 int Init(string ip); 4 namespace DistributedGA.Core.Interface { 5 public interface IMessageService { 6 /// <summary> 7 /// Initializes a WCF service and host it with another thread 8 /// </summary> 9 /// <param name="ip">current external ip address</param> 10 /// <returns>The port, on which the service was successfully hosted</returns> 11 int Init(string ip); 18 12 19 event EventHandler<MessageRecieveEventArgs> OnPopulationRecieved; 20 } 13 void Dispose(); 14 15 event EventHandler<MessageRecieveEventArgs> OnPopulationRecieved; 16 } 21 17 }
Note: See TracChangeset
for help on using the changeset viewer.