mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
31 lines
747 B
Go
31 lines
747 B
Go
|
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)
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|