Changeset 13956 for branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfMessageSender.cs
- Timestamp:
- 06/29/16 15:28:47 (8 years ago)
- Location:
- branches/thasling/DistributedGA/DistributedGA.Core
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/thasling/DistributedGA/DistributedGA.Core
- Property svn:ignore
-
old new 1 1 bin 2 2 obj 3 DistributedGA.Core.csproj.user
-
- Property svn:ignore
-
branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfMessageSender.cs
r13947 r13956 20 20 private Object timerLock = new Object(); 21 21 22 public void Init(PeerInfo source ) {22 public void Init(PeerInfo source, int messageCacheCapacity) { 23 23 myself = source; 24 24 bufferedMessages = new SizedConcurrentQueue<KeyValuePair<PeerInfo, byte[][]>>(); 25 bufferedMessages.Limit = 100000;25 bufferedMessages.Limit = messageCacheCapacity; 26 26 timer = new Timer(1000 * 60); //each 5 minutes 27 27 timer.Elapsed += GenerateSendingTasks; … … 72 72 } 73 73 } 74 74 75 } 75 76 }
Note: See TracChangeset
for help on using the changeset viewer.