fix Download and Upload command proper close resumable state to avoid infinite bolt lock in server mode when upload or download command failed, fix #1304

Signed-off-by: Slach <bloodjazman@gmail.com>

Author: Slach

pkg/backup/download.go

@@ -164,6 +164,7 @@ func (b *Backuper) Download(backupName string, tablePattern string, partitions [
 			"partitions":   partitions,
 			"schemaOnly":   schemaOnly,
 		})
+		defer b.resumableState.Close()
 	}
 
 	log.Debug().Str("backup", backupName).Msgf("prepare table METADATA concurrent semaphore with concurrency=%d len(tablesForDownload)=%d", b.cfg.General.DownloadConcurrency, len(tablesForDownload))
@@ -294,10 +295,6 @@ func (b *Backuper) Download(backupName string, tablePattern string, partitions [
 		}
 	}
 
-	if b.resume {
-		b.resumableState.Close()
-	}
-
 	//clean partially downloaded requiredBackup
 	if remoteBackup.RequiredBackup != "" {
 		if err = b.cleanPartialRequiredBackup(ctx, disks, remoteBackup.BackupName); err != nil {

pkg/backup/upload.go

@@ -135,6 +135,7 @@ func (b *Backuper) Upload(backupName string, deleteSource bool, diffFrom, diffFr
 			"partitions":     partitions,
 			"schemaOnly":     schemaOnly,
 		})
+		defer b.resumableState.Close()
 	}
 
 	compressedDataSize := int64(0)
@@ -257,9 +258,6 @@ func (b *Backuper) Upload(backupName string, deleteSource bool, diffFrom, diffFr
 			return errors.Wrapf(err, "can't upload %s", remoteBackupMetaFile)
 		}
 	}
-	if b.resume {
-		b.resumableState.Close()
-	}
 	log.Info().Fields(map[string]interface{}{
 		"backup":           backupName,
 		"operation":        "upload",