Skip to content

Commit ed76b8b

Browse files
committed
fixed server initialization pool size
1 parent 2b83a76 commit ed76b8b

File tree

2 files changed

+3
-5
lines changed

2 files changed

+3
-5
lines changed

mooncake-transfer-engine/include/transport/coro_rpc_connector/cororpc_interface.h

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,8 +50,7 @@ class CoroRPCInterface {
5050
// Convenience methods for common use cases
5151
bool initializeClient(size_t pool_size = 10, size_t timeout_seconds = 30);
5252
bool initializeServer(const std::string& listen_address,
53-
size_t thread_count = 8, size_t timeout_seconds = 30,
54-
size_t pool_size = 4);
53+
size_t thread_count = 8, size_t timeout_seconds = 30);
5554

5655
bool startServer();
5756
bool startServerAsync();

mooncake-transfer-engine/src/transport/coro_rpc_connector/cororpc_interface.cpp

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -45,9 +45,8 @@ bool CoroRPCInterface::initializeClient(size_t pool_size, size_t timeout_seconds
4545

4646
// Convenience method for server initialization
4747
bool CoroRPCInterface::initializeServer(const std::string& listen_address,
48-
size_t thread_count, size_t timeout_seconds,
49-
size_t pool_size) {
50-
return initialize(listen_address, thread_count, timeout_seconds, pool_size);
48+
size_t thread_count, size_t timeout_seconds) {
49+
return initialize(listen_address, thread_count, timeout_seconds, 4);
5150
}
5251

5352
bool CoroRPCInterface::startServer() {

0 commit comments

Comments
 (0)