mleku/orly
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: correct RWMutex usage in relay lists for proper concurrency handling

Browse Source 
- pkg/app/relay/lists.go
  - Replaced incorrect `Unlock` calls with `RUnlock` in read operations.
This commit is contained in:
mleku
2025-08-18 13:34:01 +01:00
parent b8a12d7a11
commit af1e898191
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/app/relay/lists.go
View File

@@ -25,14 +25,14 @@ type Lists struct {
func (l *Lists) LenOwnersPubkeys() (ll int) { func (l *Lists) LenOwnersPubkeys() (ll int) {
l.RLock() l.RLock()
defer l.Unlock() defer l.RUnlock()
ll = len(l.ownersPubkeys) ll = len(l.ownersPubkeys)
return return
} }
func (l *Lists) OwnersPubkeys() (pks [][]byte) { func (l *Lists) OwnersPubkeys() (pks [][]byte) {
l.RLock() l.RLock()
defer l.Unlock() defer l.RUnlock()
pks = append(pks, l.ownersPubkeys...) pks = append(pks, l.ownersPubkeys...)
return return
} }
@@ -46,14 +46,14 @@ func (l *Lists) SetOwnersPubkeys(pks [][]byte) {
func (l *Lists) LenOwnersFollowed() (ll int) { func (l *Lists) LenOwnersFollowed() (ll int) {
l.RLock() l.RLock()
defer l.Unlock() defer l.RUnlock()
ll = len(l.ownersFollowed) ll = len(l.ownersFollowed)
return return
} }
func (l *Lists) OwnersFollowed() (pks [][]byte) { func (l *Lists) OwnersFollowed() (pks [][]byte) {
l.RLock() l.RLock()
defer l.Unlock() defer l.RUnlock()
pks = append(pks, l.ownersFollowed...) pks = append(pks, l.ownersFollowed...)
return return
} }
@@ -67,14 +67,14 @@ func (l *Lists) SetOwnersFollowed(pks [][]byte) {
func (l *Lists) LenFollowedFollows() (ll int) { func (l *Lists) LenFollowedFollows() (ll int) {
l.RLock() l.RLock()
defer l.Unlock() defer l.RUnlock()
ll = len(l.followedFollows) ll = len(l.followedFollows)
return return
} }
func (l *Lists) FollowedFollows() (pks [][]byte) { func (l *Lists) FollowedFollows() (pks [][]byte) {
l.RLock() l.RLock()
defer l.Unlock() defer l.RUnlock()
pks = append(pks, l.followedFollows...) pks = append(pks, l.followedFollows...)
return return
} }
@@ -88,14 +88,14 @@ func (l *Lists) SetFollowedFollows(pks [][]byte) {
func (l *Lists) LenOwnersMuted() (ll int) { func (l *Lists) LenOwnersMuted() (ll int) {
l.RLock() l.RLock()
defer l.Unlock() defer l.RUnlock()
ll = len(l.ownersMuted) ll = len(l.ownersMuted)
return return
} }
func (l *Lists) OwnersMuted() (pks [][]byte) { func (l *Lists) OwnersMuted() (pks [][]byte) {
l.RLock() l.RLock()
defer l.Unlock() defer l.RUnlock()
pks = append(pks, l.ownersMuted...) pks = append(pks, l.ownersMuted...)
return return
} }