From cd21400a6b449b322125e22cc7320f2a3a5987d7 Mon Sep 17 00:00:00 2001 From: Sam Tunnicliffe Date: Tue, 30 Jun 2026 10:03:25 +0100 Subject: [PATCH] Relocate CMS member selection policy mbean methods --- .../apache/cassandra/service/StorageService.java | 13 ------------- .../cassandra/service/StorageServiceMBean.java | 12 ------------ 2 files changed, 25 deletions(-) diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java index 2ad2a5bf27..53f0986e0c 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -1761,19 +1761,6 @@ public class StorageService extends NotificationBroadcasterSupport implements IE return pojoMapToString(snapshotAsMap, format); } - @Override - public String getCmsCommitMemberPreferencePolicy() - { - return DatabaseDescriptor.getCmsCommitMemberPreferencePolicy().name(); - } - - @Override - public void setCmsCommitMemberPreferencePolicy(String policy) - { - DatabaseDescriptor.setCmsCommitMemberPreferencePolicy(policy); - logger.info("Set cms_commit_member_preference_policy to {}", policy); - } - public Map> getConcurrency(List stageNames) { Stream stageStream = stageNames.isEmpty() ? stream(Stage.values()) : stageNames.stream().map(Stage::fromPoolName); diff --git a/src/java/org/apache/cassandra/service/StorageServiceMBean.java b/src/java/org/apache/cassandra/service/StorageServiceMBean.java index 34db8b4180..b9f47b3b2d 100644 --- a/src/java/org/apache/cassandra/service/StorageServiceMBean.java +++ b/src/java/org/apache/cassandra/service/StorageServiceMBean.java @@ -1170,18 +1170,6 @@ public interface StorageServiceMBean extends NotificationEmitter List getAccordManagedKeyspaces(); List getAccordManagedTables(); - /** Get the CMS commit member preference policy - * - * @return how to choose the cms member preference order for commits - */ - public String getCmsCommitMemberPreferencePolicy(); - - /** Update the CMS commit member preference policy - * - * @param policy see Config.CMSCommitMemberPreferencePolicy - */ - public void setCmsCommitMemberPreferencePolicy(String policy); - /** Gets the concurrency settings for processing stages*/ static class StageConcurrency implements Serializable {