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