deblan-mirror/nextcloud-spreed-signaling
deblan-mirror/nextcloud-spreed-signaling
1
0
Fork 0
mirror of https://github.com/strukturag/nextcloud-spreed-signaling synced 2026-03-14 14:35:44 +01:00
Code Issues Releases Wiki Activity

Use methods on atomic class instead of custom implementation.

Browse source
This commit is contained in:
Joachim Bauch 2025-08-14 14:40:48 +02:00
commit 3d0db426fa
No known key found for this signature in database
GPG key ID: 77C1D22D53E15F02
1 changed files with 5 additions and 34 deletions
Download patch file Download diff file Expand all files Collapse all files

39
flags.go
View file

@ -30,46 +30,17 @@ type Flags struct {
}
func (f *Flags) Add(flags uint32) bool {
for {
old := f.flags.Load()
if old&flags == flags {
// Flags already set.
return false
}
newFlags := old | flags
if f.flags.CompareAndSwap(old, newFlags) {
return true
}
// Another thread updated the flags while we were checking, retry.
}
old := f.flags.Or(flags)
return old&flags != flags
}
func (f *Flags) Remove(flags uint32) bool {
for {
old := f.flags.Load()
if old&flags == 0 {
// Flags not set.
return false
}
newFlags := old & ^flags
if f.flags.CompareAndSwap(old, newFlags) {
return true
}
// Another thread updated the flags while we were checking, retry.
}
old := f.flags.And(^flags)
return old&flags != 0
}
func (f *Flags) Set(flags uint32) bool {
for {
old := f.flags.Load()
if old == flags {
return false
}
if f.flags.CompareAndSwap(old, flags) {
return true
}
}
return f.flags.Swap(flags) != flags
}
func (f *Flags) Get() uint32 {