diff options
Diffstat (limited to 'weed/topology/topology_ec.go')
| -rw-r--r-- | weed/topology/topology_ec.go | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/weed/topology/topology_ec.go b/weed/topology/topology_ec.go index 53762b49a..0ad028625 100644 --- a/weed/topology/topology_ec.go +++ b/weed/topology/topology_ec.go @@ -23,7 +23,8 @@ func (t *Topology) SyncDataNodeEcShards(shardInfos []*master_pb.VolumeEcShardInf shardInfo.Collection, needle.VolumeId(shardInfo.Id), erasure_coding.ShardBits(shardInfo.EcIndexBits), - shardInfo.ExpireAtSec)) + shardInfo.ExpireAtSec, + shardInfo.DiskId)) } // find out the delta volumes newShards, deletedShards = dn.UpdateEcShards(shards) @@ -45,7 +46,9 @@ func (t *Topology) IncrementalSyncDataNodeEcShards(newEcShards, deletedEcShards shardInfo.DiskType, shardInfo.Collection, needle.VolumeId(shardInfo.Id), - erasure_coding.ShardBits(shardInfo.EcIndexBits), shardInfo.ExpireAtSec)) + erasure_coding.ShardBits(shardInfo.EcIndexBits), + shardInfo.ExpireAtSec, + shardInfo.DiskId)) } for _, shardInfo := range deletedEcShards { deletedShards = append(deletedShards, @@ -53,7 +56,9 @@ func (t *Topology) IncrementalSyncDataNodeEcShards(newEcShards, deletedEcShards shardInfo.DiskType, shardInfo.Collection, needle.VolumeId(shardInfo.Id), - erasure_coding.ShardBits(shardInfo.EcIndexBits), shardInfo.ExpireAtSec)) + erasure_coding.ShardBits(shardInfo.EcIndexBits), + shardInfo.ExpireAtSec, + shardInfo.DiskId)) } dn.DeltaUpdateEcShards(newShards, deletedShards) |