gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(access): remove marker of listing broken disk

Browse Source 
. #23065780

Signed-off-by: slasher <shenjie1@oppo.com>
This commit is contained in:
slasher 2025-02-27 10:43:49 +08:00
parent 6ad085725c
commit f7472eeb2d
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
blobstore/access/controller/service.go
View File

@ -257,13 +257,12 @@ func (s *serviceControllerImpl) processBrokenDisks(
args := &clustermgr.ListOptionArgs{Status: st, Count: 1 << 10}
for {
list, err := s.cmClient.ListDisk(ctx, args)
err = fn(ctx, args, brokenDiskIDs)
err := fn(ctx, args, brokenDiskIDs)
if err != nil {
span.Errorf("load disks of cluster %d, err:%+v", s.config.ClusterID, err)
return
}
if args.Marker = list.Marker; args.Marker <= proto.InvalidDiskID {
if args.Marker <= proto.InvalidDiskID {
break
}
}