diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-01-17 16:25:23 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-01-17 16:29:17 +0000 |
commit | 1592294bd9335fbb511217c64af09378607a46da (patch) | |
tree | 1fedc10edd194f947809a663ecff3763fbcdc627 | |
parent | b99db83c92490cc5678ecac778a28efd4acf2130 (diff) |
GC unused useDirectStoarageApiRpc flag
5 files changed, 1 insertions, 7 deletions
diff --git a/config-model-api/src/main/java/com/yahoo/config/model/api/ModelContext.java b/config-model-api/src/main/java/com/yahoo/config/model/api/ModelContext.java index 2c414275571..cecfb071e64 100644 --- a/config-model-api/src/main/java/com/yahoo/config/model/api/ModelContext.java +++ b/config-model-api/src/main/java/com/yahoo/config/model/api/ModelContext.java @@ -70,7 +70,6 @@ public interface ModelContext { @ModelFeatureFlag(owners = {"bjorncs", "jonmv"}) default double reindexerWindowSizeIncrement() { return 0.2; } @ModelFeatureFlag(owners = {"baldersheim"}, comment = "Revisit in May or June 2020") default double defaultTermwiseLimit() { throw new UnsupportedOperationException("TODO specify default value"); } @ModelFeatureFlag(owners = {"vekterli"}) default boolean useThreePhaseUpdates() { throw new UnsupportedOperationException("TODO specify default value"); } - @ModelFeatureFlag(owners = {"geirst"}, comment = "Remove when 7.336 is no longer in use") default boolean useDirectStorageApiRpc() { return true; } @ModelFeatureFlag(owners = {"baldersheim"}, comment = "Select sequencer type use while feeding") default String feedSequencerType() { throw new UnsupportedOperationException("TODO specify default value"); } @ModelFeatureFlag(owners = {"baldersheim"}) default String responseSequencerType() { throw new UnsupportedOperationException("TODO specify default value"); } @ModelFeatureFlag(owners = {"baldersheim"}) default int defaultNumResponseThreads() { return 2; } diff --git a/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java b/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java index 521b8f6998d..9e8e9656e90 100644 --- a/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java +++ b/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java @@ -72,7 +72,6 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea @Override public Optional<EndpointCertificateSecrets> endpointCertificateSecrets() { return endpointCertificateSecrets; } @Override public double defaultTermwiseLimit() { return defaultTermwiseLimit; } @Override public boolean useThreePhaseUpdates() { return useThreePhaseUpdates; } - @Override public boolean useDirectStorageApiRpc() { return true; } @Override public Optional<AthenzDomain> athenzDomain() { return Optional.ofNullable(athenzDomain); } @Override public Optional<ApplicationRoles> applicationRoles() { return Optional.ofNullable(applicationRoles); } @Override public String responseSequencerType() { return responseSequencerType; } diff --git a/config-model/src/main/java/com/yahoo/vespa/model/content/ContentNode.java b/config-model/src/main/java/com/yahoo/vespa/model/content/ContentNode.java index 736424e263d..705d2dc668d 100644 --- a/config-model/src/main/java/com/yahoo/vespa/model/content/ContentNode.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/content/ContentNode.java @@ -27,7 +27,6 @@ public abstract class ContentNode extends AbstractService private final boolean skipCommunicationManagerThread; private final boolean skipMbusRequestThread; private final boolean skipMbusReplyThread; - private final boolean useDirectStorageApiRpc; public ContentNode(ModelContext.FeatureFlags featureFlags, AbstractConfigProducer<?> parent, String clusterName, String rootDirectory, int distributionKey) { super(parent, "" + distributionKey); @@ -36,7 +35,6 @@ public abstract class ContentNode extends AbstractService this.skipMbusRequestThread = featureFlags.skipMbusRequestThread(); this.skipMbusReplyThread = featureFlags.skipMbusReplyThread(); this.rootDirectory = rootDirectory; - this.useDirectStorageApiRpc = featureFlags.useDirectStorageApiRpc(); initialize(); setProp("clustertype", "content"); @@ -83,7 +81,6 @@ public abstract class ContentNode extends AbstractService builder.skip_thread(skipCommunicationManagerThread); builder.mbus.skip_request_thread(skipMbusRequestThread); builder.mbus.skip_reply_thread(skipMbusReplyThread); - builder.use_direct_storageapi_rpc(useDirectStorageApiRpc); } @Override diff --git a/searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp b/searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp index a8c5912aadd..861b2ad5307 100644 --- a/searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp +++ b/searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp @@ -494,7 +494,6 @@ struct MyStorageConfig stor_server.rootFolder = "storage"; } make_slobroks_config(slobroks, slobrok_port); - stor_communicationmanager.useDirectStorageapiRpc = true; stor_communicationmanager.rpc.numNetworkThreads = params.get_rpc_network_threads(); stor_communicationmanager.rpc.eventsBeforeWakeup = params.get_rpc_events_before_wakup(); stor_communicationmanager.rpc.numTargetsPerNode = params.get_rpc_targets_per_node(); diff --git a/storage/src/vespa/storage/config/stor-communicationmanager.def b/storage/src/vespa/storage/config/stor-communicationmanager.def index 799490ba114..c7bc2a00952 100644 --- a/storage/src/vespa/storage/config/stor-communicationmanager.def +++ b/storage/src/vespa/storage/config/stor-communicationmanager.def @@ -58,7 +58,7 @@ skip_thread bool default=false ## Whether to use direct P2P RPC protocol for all StorageAPI communication ## instead of going via MessageBus. -## Deprecated, and will soon be gone as it is default on. +## Deprecated and ignored as it is default on. Will soon be removed. use_direct_storageapi_rpc bool default=true ## The number of network (FNET) threads used by the shared rpc resource. |