This is an automated email from the ASF dual-hosted git repository.
laiyingchun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
The following commit(s) were added to refs/heads/master by this push:
new 600b34f88 fix(learn): avoid learn use DEFAULT_POOL (#2126)
600b34f88 is described below
commit 600b34f88a8af2297783e05ed88f4bc0cfc195b0
Author: Pengfan Lu <[email protected]>
AuthorDate: Mon Apr 21 17:38:40 2025 +0800
fix(learn): avoid learn use DEFAULT_POOL (#2126)
FLAGS_max_copy_rate_megabytes_per_disk will use `sleep_for` function
to block THREAD_POOL_DEFAULT.
It's cause replica server cannot deal `remote command`. This modify is
same as FLAGS_max_send_rate_megabytes_per_disk, only use
THREAD_POOL_BLOCK_SERVICE to sleep.
---
src/block_service/block_service.h | 4 +---
src/block_service/hdfs/hdfs_service.cpp | 5 +++--
src/block_service/local/local_service.cpp | 3 ++-
src/nfs/nfs_code_definition.h | 19 +++++++++----------
src/nfs/test/config.ini | 12 +++++++++++-
src/replica/storage/simple_kv/test/case-000.ini | 4 ++--
src/replica/storage/simple_kv/test/case-001.ini | 2 +-
src/replica/storage/simple_kv/test/case-002.ini | 2 +-
src/replica/storage/simple_kv/test/case-003.ini | 2 +-
src/replica/storage/simple_kv/test/case-004.ini | 2 +-
src/replica/storage/simple_kv/test/case-005.ini | 2 +-
src/replica/storage/simple_kv/test/case-006.ini | 2 +-
src/replica/storage/simple_kv/test/case-100.ini | 2 +-
src/replica/storage/simple_kv/test/case-101.ini | 2 +-
src/replica/storage/simple_kv/test/case-102.ini | 2 +-
src/replica/storage/simple_kv/test/case-103.ini | 2 +-
src/replica/storage/simple_kv/test/case-104.ini | 2 +-
src/replica/storage/simple_kv/test/case-105.ini | 2 +-
src/replica/storage/simple_kv/test/case-106.ini | 2 +-
src/replica/storage/simple_kv/test/case-107.ini | 2 +-
src/replica/storage/simple_kv/test/case-108.ini | 2 +-
src/replica/storage/simple_kv/test/case-109.ini | 2 +-
src/replica/storage/simple_kv/test/case-200.ini | 2 +-
src/replica/storage/simple_kv/test/case-201.ini | 2 +-
src/replica/storage/simple_kv/test/case-202-0.ini | 2 +-
src/replica/storage/simple_kv/test/case-202-1.ini | 2 +-
src/replica/storage/simple_kv/test/case-203-0.ini | 2 +-
src/replica/storage/simple_kv/test/case-204.ini | 2 +-
src/replica/storage/simple_kv/test/case-205.ini | 2 +-
src/replica/storage/simple_kv/test/case-206.ini | 2 +-
src/replica/storage/simple_kv/test/case-207.ini | 2 +-
src/replica/storage/simple_kv/test/case-208.ini | 2 +-
src/replica/storage/simple_kv/test/case-209.ini | 2 +-
src/replica/storage/simple_kv/test/case-210.ini | 2 +-
src/replica/storage/simple_kv/test/case-211.ini | 2 +-
src/replica/storage/simple_kv/test/case-212.ini | 2 +-
src/replica/storage/simple_kv/test/case-213.ini | 2 +-
src/replica/storage/simple_kv/test/case-214.ini | 2 +-
src/replica/storage/simple_kv/test/case-215.ini | 2 +-
src/replica/storage/simple_kv/test/case-216.ini | 2 +-
src/replica/storage/simple_kv/test/case-300-0.ini | 2 +-
src/replica/storage/simple_kv/test/case-300-1.ini | 2 +-
src/replica/storage/simple_kv/test/case-300-2.ini | 2 +-
src/replica/storage/simple_kv/test/case-301.ini | 2 +-
src/replica/storage/simple_kv/test/case-302.ini | 2 +-
src/replica/storage/simple_kv/test/case-303.ini | 2 +-
src/replica/storage/simple_kv/test/case-304.ini | 2 +-
src/replica/storage/simple_kv/test/case-305.ini | 2 +-
src/replica/storage/simple_kv/test/case-306.ini | 2 +-
src/replica/storage/simple_kv/test/case-307.ini | 2 +-
src/replica/storage/simple_kv/test/case-400.ini | 2 +-
src/replica/storage/simple_kv/test/case-401.ini | 2 +-
src/replica/storage/simple_kv/test/case-402.ini | 2 +-
src/replica/storage/simple_kv/test/case-600.ini | 2 +-
src/replica/storage/simple_kv/test/case-601.ini | 2 +-
src/replica/storage/simple_kv/test/case-602.ini | 2 +-
src/replica/storage/simple_kv/test/case-603.ini | 2 +-
src/replica/storage/simple_kv/test/config.ini | 2 +-
src/utils/threadpool_code.h | 1 +
59 files changed, 81 insertions(+), 71 deletions(-)
diff --git a/src/block_service/block_service.h
b/src/block_service/block_service.h
index aa6b4b26c..f88ddbe20 100644
--- a/src/block_service/block_service.h
+++ b/src/block_service/block_service.h
@@ -43,10 +43,8 @@ namespace dsn {
namespace dist {
namespace block_service {
-DEFINE_THREAD_POOL_CODE(THREAD_POOL_BLOCK_SERVICE)
-
class block_file;
-typedef dsn::ref_ptr<block_file> block_file_ptr;
+using block_file_ptr = dsn::ref_ptr<block_file>;
/**
* @brief The ls_request struct, use to list all the files and directories
under the dir_name
diff --git a/src/block_service/hdfs/hdfs_service.cpp
b/src/block_service/hdfs/hdfs_service.cpp
index 987195314..eb2afcb24 100644
--- a/src/block_service/hdfs/hdfs_service.cpp
+++ b/src/block_service/hdfs/hdfs_service.cpp
@@ -41,11 +41,12 @@
#include "utils/fmt_logging.h"
#include "utils/safe_strerror_posix.h"
#include "utils/strings.h"
+#include "utils/threadpool_code.h"
#include "utils/utils.h"
DSN_DEFINE_uint64(replication,
hdfs_read_batch_size_bytes,
- 64 << 20,
+ 64U << 20U,
"hdfs read batch size, the default value is 64MB");
DSN_TAG_VARIABLE(hdfs_read_batch_size_bytes, FT_MUTABLE);
@@ -57,7 +58,7 @@ DSN_TAG_VARIABLE(hdfs_write_limit_rate_mb_per_sec,
FT_MUTABLE);
DSN_DEFINE_uint64(replication,
hdfs_write_batch_size_bytes,
- 64 << 20,
+ 64U << 20U,
"hdfs write batch size, the default value is 64MB");
DSN_TAG_VARIABLE(hdfs_write_batch_size_bytes, FT_MUTABLE);
diff --git a/src/block_service/local/local_service.cpp
b/src/block_service/local/local_service.cpp
index d7aa4e9ca..5e88453f3 100644
--- a/src/block_service/local/local_service.cpp
+++ b/src/block_service/local/local_service.cpp
@@ -18,10 +18,10 @@
#include <rocksdb/env.h>
#include <memory>
#include <set>
+#include <string_view>
#include <type_traits>
#include <utility>
-#include <string_view>
#include "local_service.h"
#include "nlohmann/json.hpp"
#include "rocksdb/slice.h"
@@ -37,6 +37,7 @@
#include "utils/fmt_logging.h"
#include "utils/load_dump_object.h"
#include "utils/strings.h"
+#include "utils/threadpool_code.h"
DSN_DECLARE_bool(enable_direct_io);
diff --git a/src/nfs/nfs_code_definition.h b/src/nfs/nfs_code_definition.h
index a848cf902..450a91c80 100644
--- a/src/nfs/nfs_code_definition.h
+++ b/src/nfs/nfs_code_definition.h
@@ -24,21 +24,20 @@
* THE SOFTWARE.
*/
+#include "task/task_code.h"
#pragma once
-namespace dsn {
-namespace service {
+namespace dsn::service {
// define RPC task code for service 'nfs'
-DEFINE_TASK_CODE_RPC(RPC_NFS_COPY, TASK_PRIORITY_COMMON,
::dsn::THREAD_POOL_DEFAULT)
-DEFINE_TASK_CODE_RPC(RPC_NFS_GET_FILE_SIZE, TASK_PRIORITY_COMMON,
::dsn::THREAD_POOL_DEFAULT)
+DEFINE_TASK_CODE_RPC(RPC_NFS_COPY, TASK_PRIORITY_COMMON,
::dsn::THREAD_POOL_BLOCK_SERVICE)
+DEFINE_TASK_CODE_RPC(RPC_NFS_GET_FILE_SIZE, TASK_PRIORITY_COMMON,
::dsn::THREAD_POOL_BLOCK_SERVICE)
// test timer task code
DEFINE_TASK_CODE(LPC_NFS_REQUEST_TIMER, TASK_PRIORITY_COMMON,
::dsn::THREAD_POOL_DEFAULT)
-DEFINE_TASK_CODE_AIO(LPC_NFS_READ, TASK_PRIORITY_COMMON, THREAD_POOL_DEFAULT)
-DEFINE_TASK_CODE(LPC_NFS_FILE_CLOSE_TIMER, TASK_PRIORITY_COMMON,
THREAD_POOL_DEFAULT)
+DEFINE_TASK_CODE_AIO(LPC_NFS_READ, TASK_PRIORITY_COMMON,
::dsn::THREAD_POOL_BLOCK_SERVICE)
+DEFINE_TASK_CODE(LPC_NFS_FILE_CLOSE_TIMER, TASK_PRIORITY_COMMON,
::dsn::THREAD_POOL_DEFAULT)
-DEFINE_TASK_CODE_AIO(LPC_NFS_WRITE, TASK_PRIORITY_COMMON, THREAD_POOL_DEFAULT)
+DEFINE_TASK_CODE_AIO(LPC_NFS_WRITE, TASK_PRIORITY_COMMON,
::dsn::THREAD_POOL_BLOCK_SERVICE)
-DEFINE_TASK_CODE_AIO(LPC_NFS_COPY_FILE, TASK_PRIORITY_COMMON,
THREAD_POOL_DEFAULT)
-} // namespace service
-} // namespace dsn
+DEFINE_TASK_CODE_AIO(LPC_NFS_COPY_FILE, TASK_PRIORITY_COMMON,
::dsn::THREAD_POOL_BLOCK_SERVICE)
+} // namespace dsn::service
diff --git a/src/nfs/test/config.ini b/src/nfs/test/config.ini
index 214ae2f43..b22247dc1 100644
--- a/src/nfs/test/config.ini
+++ b/src/nfs/test/config.ini
@@ -30,7 +30,7 @@ count = 1
type = dsn.app.mimic
arguments =
ports = 20101
-pools = THREAD_POOL_DEFAULT
+pools = THREAD_POOL_BLOCK_SERVICE, THREAD_POOL_DEFAULT
run = true
count = 1
@@ -40,3 +40,13 @@ tool = nativerun
pause_on_start = false
logging_start_level = LOG_LEVEL_DEBUG
logging_factory_name = dsn::tools::simple_logger
+
+[threadpool..default]
+worker_count = 2
+worker_priority = THREAD_xPRIORITY_LOWEST
+
+[threadpool.THREAD_POOL_BLOCK_SERVICE]
+ name = block_service
+ partitioned = false
+ worker_priority = THREAD_xPRIORITY_NORMAL
+ worker_count = 3
diff --git a/src/replica/storage/simple_kv/test/case-000.ini
b/src/replica/storage/simple_kv/test/case-000.ini
index 34d18892f..fc03cda30 100644
--- a/src/replica/storage/simple_kv/test/case-000.ini
+++ b/src/replica/storage/simple_kv/test/case-000.ini
@@ -36,7 +36,7 @@ arguments =
ports = 34601
run = true
count = 1
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_META_SERVER,THREAD_POOL_FD,THREAD_POOL_META_STATE
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_META_SERVER,THREAD_POOL_FD,THREAD_POOL_META_STATE,THREAD_POOL_BLOCK_SERVICE
[apps.r]
type = replica
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-001.ini
b/src/replica/storage/simple_kv/test/case-001.ini
index edf1d69f4..a9ae0352f 100644
--- a/src/replica/storage/simple_kv/test/case-001.ini
+++ b/src/replica/storage/simple_kv/test/case-001.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-002.ini
b/src/replica/storage/simple_kv/test/case-002.ini
index d3012ab43..5766528d4 100644
--- a/src/replica/storage/simple_kv/test/case-002.ini
+++ b/src/replica/storage/simple_kv/test/case-002.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-003.ini
b/src/replica/storage/simple_kv/test/case-003.ini
index 86e91c534..e7dde0e25 100644
--- a/src/replica/storage/simple_kv/test/case-003.ini
+++ b/src/replica/storage/simple_kv/test/case-003.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-004.ini
b/src/replica/storage/simple_kv/test/case-004.ini
index e523a8d64..454d2ebde 100644
--- a/src/replica/storage/simple_kv/test/case-004.ini
+++ b/src/replica/storage/simple_kv/test/case-004.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-005.ini
b/src/replica/storage/simple_kv/test/case-005.ini
index 8e28e7b89..05de4924b 100644
--- a/src/replica/storage/simple_kv/test/case-005.ini
+++ b/src/replica/storage/simple_kv/test/case-005.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-006.ini
b/src/replica/storage/simple_kv/test/case-006.ini
index 386433359..68a5a986b 100644
--- a/src/replica/storage/simple_kv/test/case-006.ini
+++ b/src/replica/storage/simple_kv/test/case-006.ini
@@ -36,7 +36,7 @@ arguments =
ports = 34601
run = true
count = 1
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_META_SERVER,THREAD_POOL_FD,THREAD_POOL_META_STATE
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_META_SERVER,THREAD_POOL_FD,THREAD_POOL_META_STATE,THREAD_POOL_BLOCK_SERVICE
[apps.r]
type = replica
diff --git a/src/replica/storage/simple_kv/test/case-100.ini
b/src/replica/storage/simple_kv/test/case-100.ini
index fb366b244..15e8371a0 100644
--- a/src/replica/storage/simple_kv/test/case-100.ini
+++ b/src/replica/storage/simple_kv/test/case-100.ini
@@ -36,7 +36,7 @@ arguments =
ports = 34601
run = true
count = 1
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_META_SERVER,THREAD_POOL_FD,THREAD_POOL_META_STATE
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_META_SERVER,THREAD_POOL_FD,THREAD_POOL_META_STATE,THREAD_POOL_BLOCK_SERVICE
[apps.r]
type = replica
diff --git a/src/replica/storage/simple_kv/test/case-101.ini
b/src/replica/storage/simple_kv/test/case-101.ini
index 2c840a892..a1df05bdf 100644
--- a/src/replica/storage/simple_kv/test/case-101.ini
+++ b/src/replica/storage/simple_kv/test/case-101.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-102.ini
b/src/replica/storage/simple_kv/test/case-102.ini
index 99392e805..1624c590b 100644
--- a/src/replica/storage/simple_kv/test/case-102.ini
+++ b/src/replica/storage/simple_kv/test/case-102.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-103.ini
b/src/replica/storage/simple_kv/test/case-103.ini
index 10b312756..655359c60 100644
--- a/src/replica/storage/simple_kv/test/case-103.ini
+++ b/src/replica/storage/simple_kv/test/case-103.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-104.ini
b/src/replica/storage/simple_kv/test/case-104.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-104.ini
+++ b/src/replica/storage/simple_kv/test/case-104.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-105.ini
b/src/replica/storage/simple_kv/test/case-105.ini
index 3019495bc..d1ec1cdd7 100644
--- a/src/replica/storage/simple_kv/test/case-105.ini
+++ b/src/replica/storage/simple_kv/test/case-105.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-106.ini
b/src/replica/storage/simple_kv/test/case-106.ini
index 2c840a892..a1df05bdf 100644
--- a/src/replica/storage/simple_kv/test/case-106.ini
+++ b/src/replica/storage/simple_kv/test/case-106.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-107.ini
b/src/replica/storage/simple_kv/test/case-107.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-107.ini
+++ b/src/replica/storage/simple_kv/test/case-107.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-108.ini
b/src/replica/storage/simple_kv/test/case-108.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-108.ini
+++ b/src/replica/storage/simple_kv/test/case-108.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-109.ini
b/src/replica/storage/simple_kv/test/case-109.ini
index d489c0292..402b22bf0 100644
--- a/src/replica/storage/simple_kv/test/case-109.ini
+++ b/src/replica/storage/simple_kv/test/case-109.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-200.ini
b/src/replica/storage/simple_kv/test/case-200.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-200.ini
+++ b/src/replica/storage/simple_kv/test/case-200.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-201.ini
b/src/replica/storage/simple_kv/test/case-201.ini
index b6801a064..6563858ac 100644
--- a/src/replica/storage/simple_kv/test/case-201.ini
+++ b/src/replica/storage/simple_kv/test/case-201.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-202-0.ini
b/src/replica/storage/simple_kv/test/case-202-0.ini
index a0fa07b3f..d4dd36f22 100644
--- a/src/replica/storage/simple_kv/test/case-202-0.ini
+++ b/src/replica/storage/simple_kv/test/case-202-0.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-202-1.ini
b/src/replica/storage/simple_kv/test/case-202-1.ini
index e523a8d64..454d2ebde 100644
--- a/src/replica/storage/simple_kv/test/case-202-1.ini
+++ b/src/replica/storage/simple_kv/test/case-202-1.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-203-0.ini
b/src/replica/storage/simple_kv/test/case-203-0.ini
index a0fa07b3f..d4dd36f22 100644
--- a/src/replica/storage/simple_kv/test/case-203-0.ini
+++ b/src/replica/storage/simple_kv/test/case-203-0.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-204.ini
b/src/replica/storage/simple_kv/test/case-204.ini
index 7ddbb8db2..564fdf628 100644
--- a/src/replica/storage/simple_kv/test/case-204.ini
+++ b/src/replica/storage/simple_kv/test/case-204.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-205.ini
b/src/replica/storage/simple_kv/test/case-205.ini
index 602794b67..06141e006 100644
--- a/src/replica/storage/simple_kv/test/case-205.ini
+++ b/src/replica/storage/simple_kv/test/case-205.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-206.ini
b/src/replica/storage/simple_kv/test/case-206.ini
index 28d2c4aaf..8b90a458f 100644
--- a/src/replica/storage/simple_kv/test/case-206.ini
+++ b/src/replica/storage/simple_kv/test/case-206.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-207.ini
b/src/replica/storage/simple_kv/test/case-207.ini
index 7ddbb8db2..564fdf628 100644
--- a/src/replica/storage/simple_kv/test/case-207.ini
+++ b/src/replica/storage/simple_kv/test/case-207.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-208.ini
b/src/replica/storage/simple_kv/test/case-208.ini
index 7ddbb8db2..564fdf628 100644
--- a/src/replica/storage/simple_kv/test/case-208.ini
+++ b/src/replica/storage/simple_kv/test/case-208.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-209.ini
b/src/replica/storage/simple_kv/test/case-209.ini
index 7ddbb8db2..564fdf628 100644
--- a/src/replica/storage/simple_kv/test/case-209.ini
+++ b/src/replica/storage/simple_kv/test/case-209.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-210.ini
b/src/replica/storage/simple_kv/test/case-210.ini
index 2652fed83..705b7369e 100644
--- a/src/replica/storage/simple_kv/test/case-210.ini
+++ b/src/replica/storage/simple_kv/test/case-210.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-211.ini
b/src/replica/storage/simple_kv/test/case-211.ini
index d07b7fcb8..4f9a111d6 100644
--- a/src/replica/storage/simple_kv/test/case-211.ini
+++ b/src/replica/storage/simple_kv/test/case-211.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-212.ini
b/src/replica/storage/simple_kv/test/case-212.ini
index 1b3c09bd1..1ad913914 100644
--- a/src/replica/storage/simple_kv/test/case-212.ini
+++ b/src/replica/storage/simple_kv/test/case-212.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-213.ini
b/src/replica/storage/simple_kv/test/case-213.ini
index 3098910b7..5cd3e1fcf 100644
--- a/src/replica/storage/simple_kv/test/case-213.ini
+++ b/src/replica/storage/simple_kv/test/case-213.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-214.ini
b/src/replica/storage/simple_kv/test/case-214.ini
index 602794b67..06141e006 100644
--- a/src/replica/storage/simple_kv/test/case-214.ini
+++ b/src/replica/storage/simple_kv/test/case-214.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-215.ini
b/src/replica/storage/simple_kv/test/case-215.ini
index 28d2c4aaf..8b90a458f 100644
--- a/src/replica/storage/simple_kv/test/case-215.ini
+++ b/src/replica/storage/simple_kv/test/case-215.ini
@@ -45,7 +45,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-216.ini
b/src/replica/storage/simple_kv/test/case-216.ini
index 7ddbb8db2..564fdf628 100644
--- a/src/replica/storage/simple_kv/test/case-216.ini
+++ b/src/replica/storage/simple_kv/test/case-216.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-300-0.ini
b/src/replica/storage/simple_kv/test/case-300-0.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-300-0.ini
+++ b/src/replica/storage/simple_kv/test/case-300-0.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-300-1.ini
b/src/replica/storage/simple_kv/test/case-300-1.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-300-1.ini
+++ b/src/replica/storage/simple_kv/test/case-300-1.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-300-2.ini
b/src/replica/storage/simple_kv/test/case-300-2.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-300-2.ini
+++ b/src/replica/storage/simple_kv/test/case-300-2.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-301.ini
b/src/replica/storage/simple_kv/test/case-301.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-301.ini
+++ b/src/replica/storage/simple_kv/test/case-301.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-302.ini
b/src/replica/storage/simple_kv/test/case-302.ini
index fcab05e78..6b67c041d 100644
--- a/src/replica/storage/simple_kv/test/case-302.ini
+++ b/src/replica/storage/simple_kv/test/case-302.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-303.ini
b/src/replica/storage/simple_kv/test/case-303.ini
index e3fefc0fb..e4bc2cb2e 100644
--- a/src/replica/storage/simple_kv/test/case-303.ini
+++ b/src/replica/storage/simple_kv/test/case-303.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-304.ini
b/src/replica/storage/simple_kv/test/case-304.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-304.ini
+++ b/src/replica/storage/simple_kv/test/case-304.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-305.ini
b/src/replica/storage/simple_kv/test/case-305.ini
index e3fefc0fb..e4bc2cb2e 100644
--- a/src/replica/storage/simple_kv/test/case-305.ini
+++ b/src/replica/storage/simple_kv/test/case-305.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-306.ini
b/src/replica/storage/simple_kv/test/case-306.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-306.ini
+++ b/src/replica/storage/simple_kv/test/case-306.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-307.ini
b/src/replica/storage/simple_kv/test/case-307.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-307.ini
+++ b/src/replica/storage/simple_kv/test/case-307.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-400.ini
b/src/replica/storage/simple_kv/test/case-400.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-400.ini
+++ b/src/replica/storage/simple_kv/test/case-400.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-401.ini
b/src/replica/storage/simple_kv/test/case-401.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-401.ini
+++ b/src/replica/storage/simple_kv/test/case-401.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-402.ini
b/src/replica/storage/simple_kv/test/case-402.ini
index fb366b244..d8977812b 100644
--- a/src/replica/storage/simple_kv/test/case-402.ini
+++ b/src/replica/storage/simple_kv/test/case-402.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-600.ini
b/src/replica/storage/simple_kv/test/case-600.ini
index 386433359..f525c13c1 100644
--- a/src/replica/storage/simple_kv/test/case-600.ini
+++ b/src/replica/storage/simple_kv/test/case-600.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-601.ini
b/src/replica/storage/simple_kv/test/case-601.ini
index f9e2f3b96..c045e1558 100644
--- a/src/replica/storage/simple_kv/test/case-601.ini
+++ b/src/replica/storage/simple_kv/test/case-601.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-602.ini
b/src/replica/storage/simple_kv/test/case-602.ini
index 386433359..f525c13c1 100644
--- a/src/replica/storage/simple_kv/test/case-602.ini
+++ b/src/replica/storage/simple_kv/test/case-602.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/case-603.ini
b/src/replica/storage/simple_kv/test/case-603.ini
index dd29d532d..d94c913e7 100644
--- a/src/replica/storage/simple_kv/test/case-603.ini
+++ b/src/replica/storage/simple_kv/test/case-603.ini
@@ -46,7 +46,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
[apps.c]
type = client
diff --git a/src/replica/storage/simple_kv/test/config.ini
b/src/replica/storage/simple_kv/test/config.ini
index 5622b9ff0..9f56c25d2 100644
--- a/src/replica/storage/simple_kv/test/config.ini
+++ b/src/replica/storage/simple_kv/test/config.ini
@@ -52,7 +52,7 @@ arguments =
ports = 34801
run = true
count = 3
-pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG
+pools =
THREAD_POOL_DEFAULT,THREAD_POOL_REPLICATION_LONG,THREAD_POOL_REPLICATION,THREAD_POOL_FD,THREAD_POOL_LOCAL_APP,THREAD_POOL_PLOG,THREAD_POOL_BLOCK_SERVICE
hosted_app_type_name = simple_kv
hosted_app_arguments =
diff --git a/src/utils/threadpool_code.h b/src/utils/threadpool_code.h
index cd3eac2db..8edac24b2 100644
--- a/src/utils/threadpool_code.h
+++ b/src/utils/threadpool_code.h
@@ -66,6 +66,7 @@ private:
DEFINE_THREAD_POOL_CODE(THREAD_POOL_INVALID)
DEFINE_THREAD_POOL_CODE(THREAD_POOL_DEFAULT)
+DEFINE_THREAD_POOL_CODE(THREAD_POOL_BLOCK_SERVICE)
} // namespace dsn
USER_DEFINED_STRUCTURE_FORMATTER(::dsn::threadpool_code);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
