mirrors/yatm
1
0
Fork 0
mirror of https://github.com/samuelncui/yatm.git synced 2026-01-03 11:45:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: restore when tape is deleted

Browse Source
This commit is contained in:
Samuel N Cui
2023-09-27 09:57:15 +08:00
parent 80f2cb20fa
commit e14166f21e
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
executor/job_restore_param.go
View File

@@ -48,17 +48,17 @@ func (e *Executor) createRestore(ctx context.Context, job *Job, param *entity.Jo
}
}
tapeMap, err := e.lib.MGetTape(ctx, lo.Keys(tapeMapping)...)
tapes, err := e.lib.MGetTape(ctx, lo.Keys(tapeMapping)...)
if err != nil {
return err
}
for tapeID := range tapeMapping {
if tape, has := tapeMap[tapeID]; has && tape != nil {
if tape, has := tapes[tapeID]; has && tape != nil {
continue
}
logrus.WithContext(ctx).Infof("tape not found, tape_id= %d", tapeID)
delete(tapeMap, tapeID)
delete(tapeMapping, tapeID)
}
restoreTapes := make([]*entity.RestoreTape, 0, len(tapeMapping))
@@ -135,7 +135,7 @@ func (e *Executor) createRestore(ctx context.Context, job *Job, param *entity.Jo
restoreTapes = append(restoreTapes, &entity.RestoreTape{
TapeId: maxTapeID,
Barcode: tapeMap[maxTapeID].Barcode,
Barcode: tapes[maxTapeID].Barcode,
Status: entity.CopyStatus_PENDING,
Files: targets,
})