fixup

Author: defbin

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) {

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

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
 		}

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()