natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

set managmen pool as 1 when it is not defined

This commit is contained in:
Maxim Muzafarov 2026-07-11 13:41:21 +02:00
parent 4d2cd4d771
commit a0e0598c10
No known key found for this signature in database
GPG Key ID: 7FEC714D84388C16
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/java/org/apache/cassandra/transport/Dispatcher.java
View File

@ -108,9 +108,12 @@ public class Dispatcher implements CQLMessageHandler.MessageConsumer<Message.Req
* <p>Management connections are established through the management transport server
* (see {@link org.apache.cassandra.service.NativeTransportManagementService}), which listens
* on a separate port from the regular native transport.
*
* <p>Unlike auth requests, management requests have no fallback executor, so values
* less than 1 are treated as 1: a zero-sized pool would queue management requests forever.
*/
@VisibleForTesting
static final LocalAwareExecutorPlus managementExecutor = SHARED.newExecutor(DatabaseDescriptor.getNativeTransportManagementMaxThreads(),
static final LocalAwareExecutorPlus managementExecutor = SHARED.newExecutor(Math.max(1, DatabaseDescriptor.getNativeTransportManagementMaxThreads()),
DatabaseDescriptor::setNativeTransportManagementMaxThreads,
"transport",
"Native-Transport-Management-Tasks");