Merge 6ddca90 into 4bd9866

formancehq · Jan 26, 2022 · a33d4f1 · a33d4f1
2 parents 4bd9866 + 6ddca90
commit a33d4f1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/pkg/ledger/lock.go b/pkg/ledger/lock.go
@@ -10,7 +10,7 @@ type Locker interface {
 
 type InMemoryLocker struct {
 	globalLock sync.RWMutex
-	locks      map[string]sync.Mutex
+	locks      map[string]*sync.Mutex
 }
 
 func (d *InMemoryLocker) Lock(ledger string) (Unlock, error) {
@@ -24,6 +24,7 @@ func (d *InMemoryLocker) Lock(ledger string) (Unlock, error) {
 	d.globalLock.Lock()
 	lock, ok = d.locks[ledger] // Double check, the lock can have been acquired by another go routing between RUnlock and Lock
 	if !ok {
+		lock = &sync.Mutex{}
 		d.locks[ledger] = lock
 	}
 	d.globalLock.Unlock()
@@ -34,6 +35,6 @@ ret:
 
 func NewInMemoryLocker() *InMemoryLocker {
 	return &InMemoryLocker{
-		locks: map[string]sync.Mutex{},
+		locks: map[string]*sync.Mutex{},
 	}
 }