From dad8a161ca77fd974467599b227e7ef5e34b0dd6 Mon Sep 17 00:00:00 2001
From: Dmytro Zghoba <dmytro.zghoba@percona.com>
Date: Thu, 25 Jan 2024 21:29:55 +0100
Subject: [PATCH] fixup

---
 cmd/pbm-agent/agent.go      | 2 --
 internal/backup/logical.go  | 2 +-
 internal/restore/logical.go | 7 ++++---
 internal/slicer/slicer.go   | 7 +++----
 4 files changed, 8 insertions(+), 10 deletions(-)

diff --git a/cmd/pbm-agent/agent.go b/cmd/pbm-agent/agent.go
index 812733c8b..c8d906d98 100644
--- a/cmd/pbm-agent/agent.go
+++ b/cmd/pbm-agent/agent.go
@@ -215,8 +215,6 @@ func (a *Agent) Resync(ctx context.Context, opid ctrl.OPID, ep config.Epoch) {
 	l.Debug("epoch set to %v", epch)
 }
 
-type lockAquireFn func(context.Context) (bool, error)
-
 // acquireLock tries to acquire the lock. If there is a stale lock
 // it tries to mark op that held the lock (backup, [pitr]restore) as failed.
 func (a *Agent) acquireLock(ctx context.Context, l *lock.Lock, lg log.LogEvent) (bool, error) {
diff --git a/internal/backup/logical.go b/internal/backup/logical.go
index 27bd3a252..09832085a 100644
--- a/internal/backup/logical.go
+++ b/internal/backup/logical.go
@@ -96,7 +96,7 @@ func (b *Backup) doLogical(
 			return storage.Upload(ctx, w, stg, bcp.Compression, bcp.CompressionLevel, filename, -1)
 		})
 	// ensure slicer is stopped in any case (done, error or canceled)
-	defer stopOplogSlicer()
+	defer stopOplogSlicer() //nolint:errcheck
 
 	if !util.IsSelective(bcp.Namespaces) {
 		// Save users and roles to the tmp collections so the restore would copy that data
diff --git a/internal/restore/logical.go b/internal/restore/logical.go
index 654018be6..f352e1708 100644
--- a/internal/restore/logical.go
+++ b/internal/restore/logical.go
@@ -547,9 +547,10 @@ func (r *Restore) snapshotObjects(bcp *backup.BackupMeta) (string, []oplog.Oplog
 	var ok bool
 	var rsMeta *backup.BackupReplset
 	revRSName := util.MakeReverseRSMapFunc(r.rsMap)(r.nodeInfo.SetName)
-	for _, v := range bcp.Replsets {
-		if v.Name == revRSName {
-			rsMeta = &v
+	for i := range bcp.Replsets {
+		r := &bcp.Replsets[i]
+		if r.Name == revRSName {
+			rsMeta = r
 			ok = true
 			break
 		}
diff --git a/internal/slicer/slicer.go b/internal/slicer/slicer.go
index 6b42bcd63..fa65e3452 100644
--- a/internal/slicer/slicer.go
+++ b/internal/slicer/slicer.go
@@ -342,7 +342,6 @@ func (s *Slicer) Stream(
 		Type:    ctrl.CmdPITR,
 	}
 
-	bcp := ctrl.NilOPID
 	for {
 		sliceTo := primitive.Timestamp{}
 		// waiting for a trigger
@@ -353,13 +352,13 @@ func (s *Slicer) Stream(
 			s.l.Info("got done signal, stopping")
 			lastSlice = true
 		// on wakeup or tick whatever comes first do the job
-		case bcp = <-backupSig:
+		case bcp := <-backupSig:
 			s.l.Info("got wake_up signal")
 			if bcp != ctrl.NilOPID {
 				opid := bcp.String()
 				s.l.Info("wake_up for bcp %s", opid)
 
-				sliceTo, err = s.backupStartTS(ctx, opid, s.rs, timeouts.StartingStatus())
+				sliceTo, err = s.backupStartTS(ctx, opid, timeouts.StartingStatus())
 				if err != nil {
 					return errors.Wrap(err, "get backup start TS")
 				}
@@ -531,7 +530,7 @@ func (s *Slicer) getOpLock(ctx context.Context, l *lock.LockHeader, t time.Durat
 	return lck, nil
 }
 
-func (s *Slicer) backupStartTS(ctx context.Context, opid, rs string, t time.Duration) (primitive.Timestamp, error) {
+func (s *Slicer) backupStartTS(ctx context.Context, opid string, t time.Duration) (primitive.Timestamp, error) {
 	var ts primitive.Timestamp
 	tk := time.NewTicker(time.Second)
 	defer tk.Stop()