sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-05-07 01:10:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

disable read locks

Browse Source
This commit is contained in:
Pascal Fischer
2025-04-24 20:59:59 +02:00
parent b0a5696bec
commit d07c83c111
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -153,19 +153,21 @@ func (s *SqlStore) AcquireWriteLockByUID(ctx context.Context, uniqueID string) (
// AcquireReadLockByUID acquires an ID lock for writing to a resource and returns a function that releases the lock
func (s *SqlStore) AcquireReadLockByUID(ctx context.Context, uniqueID string) (unlock func()) {
log.WithContext(ctx).Tracef("acquiring read lock for ID %s", uniqueID)
// log.WithContext(ctx).Tracef("acquiring read lock for ID %s", uniqueID)
//
// start := time.Now()
// value, _ := s.resourceLocks.LoadOrStore(uniqueID, &sync.RWMutex{})
// mtx := value.(*sync.RWMutex)
// mtx.RLock()
//
// unlock = func() {
// mtx.RUnlock()
// log.WithContext(ctx).Tracef("released read lock for ID %s in %v", uniqueID, time.Since(start))
// }
start := time.Now()
value, _ := s.resourceLocks.LoadOrStore(uniqueID, &sync.RWMutex{})
mtx := value.(*sync.RWMutex)
mtx.RLock()
unlock = func() {
mtx.RUnlock()
log.WithContext(ctx).Tracef("released read lock for ID %s in %v", uniqueID, time.Since(start))
return func() {
// noop
}
return unlock
}
func (s *SqlStore) SaveAccount(ctx context.Context, account *types.Account) error {