gian/seaweedfs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

address review: use comma-ok when reading destination shard inventory

Browse Source
This commit is contained in:
Chris Lu 2026-06-07 20:50:49 -07:00
parent ae21b05bfb
commit e59dcf31e8
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
weed/worker/tasks/ec_balance/ec_balance_task.go
View File

@ -194,7 +194,10 @@ func (t *ECBalanceTask) unmountShard(ctx context.Context, volumeID uint32, addr
// shardIDs for volumeID, so the caller can safely delete the source copies.
func (t *ECBalanceTask) verifyShardsOnDestination(ctx context.Context, volumeID uint32, targetAddr pb.ServerAddress, shardIDs []uint32) error {
_, perServer := erasure_coding.VerifyShardsAcrossServers(ctx, volumeID, []string{string(targetAddr)}, t.grpcDialOption)
inv := perServer[string(targetAddr)]
inv, ok := perServer[string(targetAddr)]
if !ok {
return fmt.Errorf("verify shard(s) on destination %s for volume %d: no inventory returned", targetAddr, volumeID)
}
if inv.QueryError != nil {
return fmt.Errorf("verify shard(s) on destination %s for volume %d: %v", targetAddr, volumeID, inv.QueryError)
}