sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-05-06 17:08:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

disable write locks

Browse Source
This commit is contained in:
Pascal Fischer
2025-04-24 20:48:22 +02:00
parent dc24b9e276
commit b0a5696bec
1 changed files with 15 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
management/server/store/sql_store.go
View File

@@ -133,19 +133,22 @@ func (s *SqlStore) AcquireGlobalLock(ctx context.Context) (unlock func()) {
// AcquireWriteLockByUID acquires an ID lock for writing to a resource and returns a function that releases the lock
func (s *SqlStore) AcquireWriteLockByUID(ctx context.Context, uniqueID string) (unlock func()) {
log.WithContext(ctx).Tracef("acquiring write lock for ID %s", uniqueID)
start := time.Now()
value, _ := s.resourceLocks.LoadOrStore(uniqueID, &sync.RWMutex{})
mtx := value.(*sync.RWMutex)
mtx.Lock()
unlock = func() {
mtx.Unlock()
log.WithContext(ctx).Tracef("released write lock for ID %s in %v", uniqueID, time.Since(start))
// log.WithContext(ctx).Tracef("acquiring write lock for ID %s", uniqueID)
//
// start := time.Now()
// value, _ := s.resourceLocks.LoadOrStore(uniqueID, &sync.RWMutex{})
// mtx := value.(*sync.RWMutex)
// mtx.Lock()
//
// unlock = func() {
// mtx.Unlock()
// log.WithContext(ctx).Tracef("released write lock for ID %s in %v", uniqueID, time.Since(start))
// }
//
// return unlock
return func() {
// noop
}
return unlock
}
// AcquireReadLockByUID acquires an ID lock for writing to a resource and returns a function that releases the lock