Made NetMQRuntime count configurable

Closes #613
planetarium · Dec 14, 2019 · e08a220 · e08a220
1 parent 243f4a0
commit e08a220
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 2 deletions.
diff --git a/CHANGES.md b/CHANGES.md
@@ -33,8 +33,10 @@ To be released.
     `BlockChain<T>()` constructor.  [[#688]]
  -  Removed `StateReferenceDownloadState` class.  [[#703]]
  -  Removed `BlockStateDownloadState` class.  [[#703]]
- -  Removed `TxReceived`, `BlockReceived` `AsyncAutoResetEvent`
+ -  Removed `TxReceived` and `BlockReceived` `AsyncAutoResetEvent`s
     from `Swarm<T>`.  [[#705], [#725]]
+ -  Added `workers` optional parameter into `Swarm<T>()` constructor.
+    [[#613], [#727]]
 
 ### Backward-incompatible network protocol changes
 
@@ -90,6 +92,7 @@ To be released.
     nonce.  [[#718]]
  -  Fixed a bug where mined transactions were staged again.  [[#719]]
 
+[#613]: https://github.com/planetarium/libplanet/issues/613
 [#662]: https://github.com/planetarium/libplanet/pull/662
 [#665]: https://github.com/planetarium/libplanet/pull/665
 [#675]: https://github.com/planetarium/libplanet/pull/675
@@ -109,6 +112,7 @@ To be released.
 [#718]: https://github.com/planetarium/libplanet/pull/718
 [#719]: https://github.com/planetarium/libplanet/pull/719
 [#725]: https://github.com/planetarium/libplanet/pull/725
+[#727]: https://github.com/planetarium/libplanet/pull/727
 
 
 Version 0.7.0

diff --git a/Libplanet.Tests/Net/SwarmTest.cs b/Libplanet.Tests/Net/SwarmTest.cs
@@ -2543,6 +2543,7 @@ public async Task DoNotReceiveBlockFromNodeHavingDifferenceGenesisBlock()
                 appProtocolVersion,
                 tableSize,
                 bucketSize,
+                5,
                 host,
                 listenPort,
                 createdAt,

diff --git a/Libplanet/Net/Swarm.cs b/Libplanet/Net/Swarm.cs
@@ -84,6 +84,7 @@ static Swarm()
             BlockChain<T> blockChain,
             PrivateKey privateKey,
             int appProtocolVersion,
+            int workers = 5,
             string host = null,
             int? listenPort = null,
             DateTimeOffset? createdAt = null,
@@ -96,6 +97,7 @@ static Swarm()
                 appProtocolVersion,
                 null,
                 null,
+                workers,
                 host,
                 listenPort,
                 createdAt,
@@ -110,6 +112,7 @@ static Swarm()
             int appProtocolVersion,
             int? tableSize,
             int? bucketSize,
+            int workers = 5,
             string host = null,
             int? listenPort = null,
             DateTimeOffset? createdAt = null,
@@ -174,7 +177,6 @@ static Swarm()
                 {
                     using (var runtime = new NetMQRuntime())
                     {
-                        const int workers = 5;
                         Task[] workerTasks = new Task[workers];
 
                         for (int i = 0; i < workers; i++)