fix crash if disk is offline in startMergeWalkVersionsN()

This commit is contained in:
Harshavardhana 2021-06-23 13:24:01 -07:00
parent 1aa5a642b8
commit c8fef1d994
1 changed files with 6 additions and 0 deletions

View File

@ -1007,6 +1007,12 @@ func (s *erasureSets) startMergeWalksVersionsN(ctx context.Context, bucket, pref
wg.Add(1)
go func(disk StorageAPI) {
defer wg.Done()
if disk == nil {
// disk offline, ignore it.
return
}
entryCh, err := disk.WalkVersions(GlobalContext, bucket, prefix, marker, recursive, endWalkCh)
if err != nil {
return