Changeset 13937 for branches/thasling/DistributedGA/DistributedGA.Core/Implementation/PeerNetworkMessageHandler.cs
- Timestamp:
- 06/24/16 21:23:47 (8 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/thasling/DistributedGA/DistributedGA.Core/Implementation/PeerNetworkMessageHandler.cs
r13924 r13937 6 6 using DistributedGA.Core.Domain; 7 7 using DistributedGA.Core.Interface; 8 using DistributedGA.Core.Util; 8 9 9 10 namespace DistributedGA.Core.Implementation { … … 21 22 //to queues are used to gather and and provide population more efficiently 22 23 private object activeQueueLocker = new object(); 23 private ConcurrentQueue<byte[]> writeQueue;24 private ConcurrentQueue<byte[]> readQueue;24 private SizedConcurrentQueue<byte[]> writeQueue; 25 private SizedConcurrentQueue<byte[]> readQueue; 25 26 26 27 //uses IMessageService for recieving population from one peer at once … … 37 38 }; // TODO: get own peerinfo 38 39 39 writeQueue = new ConcurrentQueue<byte[]>(); 40 readQueue = new ConcurrentQueue<byte[]>(); 41 40 writeQueue = new SizedConcurrentQueue<byte[]>(); 41 readQueue = new SizedConcurrentQueue<byte[]>(); 42 writeQueue.Limit = 1000; 43 readQueue.Limit = writeQueue.Limit; 42 44 43 45 host = new WcfMessageService(); 44 46 ownInstance.Port = host.Init(ownInstance.IpAddress); //getting port, on which service is hostet 45 host.OnDataRecieved += new EventHandler<MessageRecieveEventArgs>(On PopulationRecieved);47 host.OnDataRecieved += new EventHandler<MessageRecieveEventArgs>(OnDataRecieved); 46 48 47 49 peerListManager = new WcfPeerListManager(); … … 131 133 } 132 134 133 private void On PopulationRecieved(object sender, MessageRecieveEventArgs e) {135 private void OnDataRecieved(object sender, MessageRecieveEventArgs e) { 134 136 if (e != null) { 135 137 lock (activeQueueLocker) {
Note: See TracChangeset
for help on using the changeset viewer.