Simplify

Signed-off-by: Changxin Miao <miaochangxin@step.ai>

pkg/meta/base.go

@@ -26,6 +26,7 @@ import (
 	"path"
 	"reflect"
 	"runtime"
+	"slices"
 	"sort"
 	"strings"
 	"sync"
@@ -395,21 +396,18 @@ func (r *baseMeta) txBatchLock(inodes ...Ino) func() {
 		r.txLock(uint(inodes[0]))
 		return func() { r.txUnlock(uint(inodes[0])) }
 	default: // for rename and more
-		sort.Slice(inodes, func(i, j int) bool { return inodes[i]%nlocks < inodes[j]%nlocks })
-		lockedKeys := make(map[uint]struct{}, 2)
-		lockedInodes := make([]uint, 0, len(inodes))
-		for _, ino := range inodes {
-			ino := uint(ino)
-			if _, locked := lockedKeys[ino%nlocks]; locked {
-				continue // Go does not support recursive locks
-			}
-			lockedKeys[ino%nlocks] = struct{}{}
-			r.txLock(ino)
-			lockedInodes = append(lockedInodes, ino)
+		inodeSlots := make([]uint, len(inodes))
+		for i, ino := range inodes {
+			inodeSlots[i] = uint(ino) % nlocks
+		}
+		slices.Sort(inodeSlots)
+		inodeSlots = slices.Compact(inodeSlots) // Go does not support recursive locks
+		for _, idx := range inodeSlots {
+			r.txlocks[idx].Lock()
 		}
 		return func() {
-			for _, ino := range lockedInodes {
-				r.txUnlock(ino)
+			for _, idx := range inodeSlots {
+				r.txlocks[idx].Unlock()
 			}
 		}
 	}