From 13f6ec1c4e7737c1e6aaa486a80247b7cabf0448 Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Tue, 8 Feb 2022 01:50:05 -0800
Subject: [PATCH] test checking ec distribution

---
 weed/shell/command_ec_encode_test.go   | 30 ++++++++++++++++++++++++++
 weed/shell/command_volume_list_test.go |  3 +++
 2 files changed, 33 insertions(+)
 create mode 100644 weed/shell/command_ec_encode_test.go

diff --git a/weed/shell/command_ec_encode_test.go b/weed/shell/command_ec_encode_test.go
new file mode 100644
index 000000000..d5e341e5b
--- /dev/null
+++ b/weed/shell/command_ec_encode_test.go
@@ -0,0 +1,30 @@
+package shell
+
+import (
+	"fmt"
+	"github.com/chrislusf/seaweedfs/weed/storage/erasure_coding"
+	"testing"
+)
+
+func TestEcDistribution(t *testing.T) {
+
+	topologyInfo := parseOutput(topoData)
+
+	// find out all volume servers with one slot left.
+	ecNodes, totalFreeEcSlots := collectEcVolumeServersByDc(topologyInfo, "")
+
+	sortEcNodesByFreeslotsDecending(ecNodes)
+
+	if totalFreeEcSlots < erasure_coding.TotalShardsCount {
+		println("not enough free ec shard slots", totalFreeEcSlots)
+	}
+	allocatedDataNodes := ecNodes
+	if len(allocatedDataNodes) > erasure_coding.TotalShardsCount {
+		allocatedDataNodes = allocatedDataNodes[:erasure_coding.TotalShardsCount]
+	}
+
+	for _, dn := range allocatedDataNodes {
+		fmt.Printf("info %+v %+v\n", dn.info, dn)
+	}
+
+}
diff --git a/weed/shell/command_volume_list_test.go b/weed/shell/command_volume_list_test.go
index 109eb5cd6..0bcbb1713 100644
--- a/weed/shell/command_volume_list_test.go
+++ b/weed/shell/command_volume_list_test.go
@@ -65,11 +65,14 @@ func parseOutput(output string) *master_pb.TopologyInfo {
 		case "Disk":
 			if disk == nil {
 				diskType := parts[1][:strings.Index(parts[1], "(")]
+				volumeCountStr := parts[1][strings.Index(parts[1], ":")+1 : strings.Index(parts[1], "/")]
 				maxVolumeCountStr := parts[1][strings.Index(parts[1], "/")+1:]
 				maxVolumeCount, _ := strconv.Atoi(maxVolumeCountStr)
+				volumeCount, _ := strconv.Atoi(volumeCountStr)
 				disk = &master_pb.DiskInfo{
 					Type:           diskType,
 					MaxVolumeCount: int64(maxVolumeCount),
+					VolumeCount:    int64(volumeCount),
 				}
 				dn.DiskInfos[types.ToDiskType(diskType).String()] = disk
 			} else {