diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-05-26 01:01:04 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-05-26 01:01:04 -0700 |
| commit | ac14cd5ad0615271c514966fa69618e78797d753 (patch) | |
| tree | ec5fc72b5ece7eca90794f9e5af92f84f905d8c4 | |
| parent | b58e25e5883c3a53f65cf669d0ac1fc7d3354d35 (diff) | |
| download | seaweedfs-ac14cd5ad0615271c514966fa69618e78797d753.tar.xz seaweedfs-ac14cd5ad0615271c514966fa69618e78797d753.zip | |
wdclient need to have ec shard info on initial dump
| -rw-r--r-- | weed/topology/topology_map.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/topology/topology_map.go b/weed/topology/topology_map.go index 7db11ea14..37a88c9ed 100644 --- a/weed/topology/topology_map.go +++ b/weed/topology/topology_map.go @@ -68,6 +68,9 @@ func (t *Topology) ToVolumeLocations() (volumeLocations []*master_pb.VolumeLocat for _, v := range dn.GetVolumes() { volumeLocation.NewVids = append(volumeLocation.NewVids, uint32(v.Id)) } + for _, s := range dn.GetEcShards() { + volumeLocation.NewVids = append(volumeLocation.NewVids, uint32(s.VolumeId)) + } volumeLocations = append(volumeLocations, volumeLocation) } } |