HDDS-11357. Datanode Usageinfo Support Display Pipelines Count.

hadoop-hdds/interface-client/src/main/proto/hdds.proto

@@ -191,6 +191,7 @@ message DatanodeUsageInfoProto {
     optional int64 containerCount = 5;
     optional int64 committed = 6;
     optional int64 freeSpaceToSpare = 7;
+    optional int64 pipelineCount = 8;
 }
 
 /**

hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/node/DatanodeUsageInfo.java

@@ -32,6 +32,7 @@ public class DatanodeUsageInfo {
   private DatanodeDetails datanodeDetails;
   private SCMNodeStat scmNodeStat;
   private int containerCount;
+  private int pipelineCount;
 
   /**
    * Constructs a DatanodeUsageInfo with DatanodeDetails and SCMNodeStat.
@@ -45,6 +46,7 @@ public DatanodeUsageInfo(
     this.datanodeDetails = datanodeDetails;
     this.scmNodeStat = scmNodeStat;
     this.containerCount = -1;
+    this.pipelineCount = -1;
   }
 
   /**
@@ -145,6 +147,14 @@ public void setContainerCount(int containerCount) {
     this.containerCount = containerCount;
   }
 
+  public int getPipelineCount() {
+    return pipelineCount;
+  }
+
+  public void setPipelineCount(int pipelineCount) {
+    this.pipelineCount = pipelineCount;
+  }
+
   /**
    * Gets Comparator that compares two DatanodeUsageInfo on the basis of
    * their utilization values. Utilization is (capacity - remaining) divided
@@ -210,6 +220,7 @@ private DatanodeUsageInfoProto.Builder toProtoBuilder(int clientVersion) {
     }
 
     builder.setContainerCount(containerCount);
+    builder.setPipelineCount(pipelineCount);
     return builder;
   }
 }

hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/node/SCMNodeManager.java

@@ -982,6 +982,7 @@ public DatanodeUsageInfo getUsageInfo(DatanodeDetails dn) {
     DatanodeUsageInfo usageInfo = new DatanodeUsageInfo(dn, stat);
     try {
       usageInfo.setContainerCount(getContainerCount(dn));
+      usageInfo.setPipelineCount(getPipeLineCount(dn));
     } catch (NodeNotFoundException ex) {
       LOG.error("Unknown datanode {}.", dn, ex);
     }
@@ -1610,6 +1611,11 @@ public int getContainerCount(DatanodeDetails datanodeDetails)
     return nodeStateManager.getContainerCount(datanodeDetails.getUuid());
   }
 
+  public int getPipeLineCount(DatanodeDetails datanodeDetails)
+      throws NodeNotFoundException {
+    return nodeStateManager.getPipelinesCount(datanodeDetails);
+  }
+
   @Override
   public void addDatanodeCommand(UUID dnId, SCMCommand command) {
     writeLock().lock();

hadoop-hdds/tools/src/main/java/org/apache/hadoop/hdds/scm/cli/datanode/UsageInfoSubcommand.java

@@ -155,6 +155,8 @@ private void printInfo(DatanodeUsage info) {
         + " B", StringUtils.byteDesc(info.getRemaining()));
     System.out.printf("%-13s: %s %n", "Remaining %",
         PERCENT_FORMAT.format(info.getRemainingRatio()));
+    System.out.printf("%-13s: %d %n", "Pipeline(s)",
+            info.getPipelineCount());
     System.out.printf("%-13s: %d %n", "Container(s)",
             info.getContainerCount());
     System.out.printf("%-24s: %s (%s) %n", "Container Pre-allocated",
@@ -192,6 +194,7 @@ private static class DatanodeUsage {
     private long committed = 0;
     private long freeSpaceToSpare = 0;
     private long containerCount = 0;
+    private long pipelineCount = 0;
 
     DatanodeUsage(HddsProtos.DatanodeUsageInfoProto proto) {
       if (proto.hasNode()) {
@@ -212,6 +215,9 @@ private static class DatanodeUsage {
       if (proto.hasContainerCount()) {
         containerCount = proto.getContainerCount();
       }
+      if (proto.hasPipelineCount()) {
+        pipelineCount = proto.getPipelineCount();
+      }
       if (proto.hasFreeSpaceToSpare()) {
         freeSpaceToSpare = proto.getFreeSpaceToSpare();
       }
@@ -277,5 +283,8 @@ public double getRemainingRatio() {
       return remaining / (double) capacity;
     }
 
+    public long getPipelineCount() {
+      return pipelineCount;
+    }
   }
 }

hadoop-hdds/tools/src/test/java/org/apache/hadoop/hdds/scm/cli/datanode/TestUsageInfoSubcommand.java

@@ -94,6 +94,7 @@ public void testCorrectJsonValuesInReport() throws IOException {
     assertEquals(80.00, json.get(0).get("remainingPercent").doubleValue(), 0.001);
 
     assertEquals(5, json.get(0).get("containerCount").longValue());
+    assertEquals(10, json.get(0).get("pipelineCount").longValue());
   }
 
   @Test
@@ -122,6 +123,7 @@ public void testOutputDataFieldsAligning() throws IOException {
     assertThat(output).contains("Remaining    :");
     assertThat(output).contains("Remaining %  :");
     assertThat(output).contains("Container(s) :");
+    assertThat(output).contains("Pipeline(s)  :");
     assertThat(output).contains("Container Pre-allocated :");
     assertThat(output).contains("Remaining Allocatable   :");
     assertThat(output).contains("Free Space To Spare     :");
@@ -135,6 +137,7 @@ private List<HddsProtos.DatanodeUsageInfoProto> getUsageProto() {
         .setRemaining(80)
         .setUsed(10)
         .setContainerCount(5)
+        .setPipelineCount(10)
         .build());
     return result;
   }