Made NetMQRuntime count configurable

Closes planetarium#613
wwhurin · Dec 14, 2019 · 09ef81b · 09ef81b
1 parent ec000bd
commit 09ef81b
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 1 deletion.
diff --git a/CHANGES.md b/CHANGES.md
@@ -33,6 +33,8 @@ To be released.
     `BlockChain<T>()` constructor.  [[#688]]
  -  Removed `StateReferenceDownloadState` class.  [[#703]]
  -  Removed `BlockStateDownloadState` class.  [[#703]]
+ -  Added `workers` optional parameter into `Swarm<T>()` constructor.
+    [[#613], [#727]]
 
 ### Backward-incompatible network protocol changes
 
@@ -88,6 +90,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
@@ -105,6 +108,7 @@ To be released.
 [#709]: https://github.com/planetarium/libplanet/pull/709
 [#718]: https://github.com/planetarium/libplanet/pull/718
 [#719]: https://github.com/planetarium/libplanet/pull/719
+[#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 @@ private Swarm<T> CreateSwarm<T>(
                 appProtocolVersion,
                 tableSize,
                 bucketSize,
+                5,
                 host,
                 listenPort,
                 createdAt,

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