This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new b80da2914d HDDS-8680. Optimize getting open pipelines from
pipelineManager (#4765)
b80da2914d is described below
commit b80da2914d64ea59f7dcfe29182d4d90b466f736
Author: Stephen O'Donnell <[email protected]>
AuthorDate: Wed May 24 14:20:24 2023 +0100
HDDS-8680. Optimize getting open pipelines from pipelineManager (#4765)
---
.../java/org/apache/hadoop/hdds/scm/pipeline/PipelineStateMap.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineStateMap.java
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineStateMap.java
index a2c9488eef..3e8d545c54 100644
---
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineStateMap.java
+++
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineStateMap.java
@@ -276,6 +276,9 @@ class PipelineStateMap {
if (state == PipelineState.OPEN) {
pipelines = new ArrayList<>(query2OpenPipelines.getOrDefault(
replicationConfig, Collections.emptyList()));
+ if (excludeDns.isEmpty() && excludePipelines.isEmpty()) {
+ return pipelines;
+ }
} else {
pipelines = new ArrayList<>(pipelineMap.values());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
