mirror/kopia
1
0 Fork 0
mirror of https://github.com/kopia/kopia.git synced 2026-10-24 15:18:48 -04:00
Code Issues Packages Projects Releases Wiki Activity

cli: fixed linter issues

Browse Source
This commit is contained in:
Jarek Kowalski committed 2019-01-21 14:26:21 -08:00
1 parent 5fc463f479
commit c0fc0c7a57
1 file changed
+40 -31
Download Patch File Download Diff File Expand all files Collapse all files
cli/command_snapshot_migrate.go
+40 -31
View File
@@ -44,7 +44,7 @@ func runMigrateCommand(ctx context.Context, destRepo *repo.Repository) error {
onCtrlC(func() {
mu.Lock()
mu.Unlock()
defer mu.Unlock()
if !cancelled {
cancelled = true
@@ -124,45 +124,54 @@ func migrateSingleSource(ctx context.Context, uploader *snapshotfs.Uploader, sou
if uploader.IsCancelled() {
break
}
if m.IncompleteReason != "" {
log.Infof("ignoring incomplete %v at %v", s, formatTimestamp(m.StartTime))
continue
}
sourceEntry := snapshotfs.DirectoryEntry(sourceRepo, m.RootObjectID(), nil)
existing, err := findPreviousSnapshotManifestWithStartTime(ctx, destRepo, m.Source, m.StartTime)
if err != nil {
return err
}
if existing != nil {
log.Infof("already migrated %v at %v", s, formatTimestamp(m.StartTime))
continue
}
log.Infof("migrating snapshot of %v at %v", s, formatTimestamp(m.StartTime))
previousManifest, err := findPreviousSnapshotManifest(ctx, destRepo, m.Source, &m.StartTime)
if err != nil {
if err := migrateSingleSourceSnapshot(ctx, uploader, sourceRepo, destRepo, s, m); err != nil {
return err
}
newm, err := uploader.Upload(ctx, sourceEntry, m.Source, previousManifest)
if err != nil {
return fmt.Errorf("error migrating shapshot %v @ %v: %v", m.Source, m.StartTime, err)
}
newm.StartTime = m.StartTime
newm.EndTime = m.EndTime
newm.Description = m.Description
if newm.IncompleteReason == "" {
if _, err := snapshot.SaveSnapshot(ctx, destRepo, newm); err != nil {
return fmt.Errorf("cannot save manifest: %v", err)
}
}
}
return nil
}
func migrateSingleSourceSnapshot(ctx context.Context, uploader *snapshotfs.Uploader, sourceRepo, destRepo *repo.Repository, s snapshot.SourceInfo, m *snapshot.Manifest) error {
if m.IncompleteReason != "" {
log.Infof("ignoring incomplete %v at %v", s, formatTimestamp(m.StartTime))
return nil
}
sourceEntry := snapshotfs.DirectoryEntry(sourceRepo, m.RootObjectID(), nil)
existing, err := findPreviousSnapshotManifestWithStartTime(ctx, destRepo, m.Source, m.StartTime)
if err != nil {
return err
}
if existing != nil {
log.Infof("already migrated %v at %v", s, formatTimestamp(m.StartTime))
return nil
}
log.Infof("migrating snapshot of %v at %v", s, formatTimestamp(m.StartTime))
previousManifest, err := findPreviousSnapshotManifest(ctx, destRepo, m.Source, &m.StartTime)
if err != nil {
return err
}
newm, err := uploader.Upload(ctx, sourceEntry, m.Source, previousManifest)
if err != nil {
return fmt.Errorf("error migrating shapshot %v @ %v: %v", m.Source, m.StartTime, err)
}
newm.StartTime = m.StartTime
newm.EndTime = m.EndTime
newm.Description = m.Description
if newm.IncompleteReason == "" {
if _, err := snapshot.SaveSnapshot(ctx, destRepo, newm); err != nil {
return fmt.Errorf("cannot save manifest: %v", err)
}
}
return nil
}
func filterSnapshotsToMigrate(s []*snapshot.Manifest) []*snapshot.Manifest {
if *migrateLatestOnly && len(s) > 0 {
s = s[0:1]