Fix refcount update error when update lock requires ack

snower · May 18, 2024 · 27dd704 · 27dd704
1 parent 168a228
commit 27dd704
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/server/db.go b/server/db.go
@@ -2338,6 +2338,13 @@ func (self *LockDB) DoAckLock(lock *Lock, succed bool) {
 			lockData = lockManager.GetLockData()
 		}
 		lockProtocol, lockCommand := lock.protocol, lock.command
+		lock.refCount--
+		if lock.refCount == 0 {
+			lockManager.FreeLock(lock)
+			if lockManager.refCount == 0 {
+				self.RemoveLockManager(lockManager)
+			}
+		}
 		lockManager.glock.Unlock()
 
 		_ = lockProtocol.ProcessLockResultCommandLocked(lockCommand, protocol.RESULT_LOCKED_ERROR, uint16(lockManager.locked), lock.locked, lockData)