| | |
| | |
| | |
| |
|
| | |
| |
|
| | package atomic |
| |
|
| | import ( |
| | "internal/cpu" |
| | "unsafe" |
| | ) |
| |
|
| | const ( |
| | offsetARMHasV7Atomics = unsafe.Offsetof(cpu.ARM.HasV7Atomics) |
| | ) |
| |
|
| | |
| | |
| | |
| | |
| | |
| |
|
| | type spinlock struct { |
| | v uint32 |
| | } |
| |
|
| | |
| | func (l *spinlock) lock() { |
| | for { |
| | if Cas(&l.v, 0, 1) { |
| | return |
| | } |
| | } |
| | } |
| |
|
| | |
| | func (l *spinlock) unlock() { |
| | Store(&l.v, 0) |
| | } |
| |
|
| | var locktab [57]struct { |
| | l spinlock |
| | pad [cpu.CacheLinePadSize - unsafe.Sizeof(spinlock{})]byte |
| | } |
| |
|
| | func addrLock(addr *uint64) *spinlock { |
| | return &locktab[(uintptr(unsafe.Pointer(addr))>>3)%uintptr(len(locktab))].l |
| | } |
| |
|
| | |
| | |
| | |
| | func Xadd(val *uint32, delta int32) uint32 { |
| | for { |
| | oval := *val |
| | nval := oval + uint32(delta) |
| | if Cas(val, oval, nval) { |
| | return nval |
| | } |
| | } |
| | } |
| |
|
| | |
| | func Xadduintptr(ptr *uintptr, delta uintptr) uintptr |
| |
|
| | |
| | func Xchg(addr *uint32, v uint32) uint32 { |
| | for { |
| | old := *addr |
| | if Cas(addr, old, v) { |
| | return old |
| | } |
| | } |
| | } |
| |
|
| | |
| | func Xchg8(addr *uint8, v uint8) uint8 |
| |
|
| | |
| | func Xchguintptr(addr *uintptr, v uintptr) uintptr { |
| | return uintptr(Xchg((*uint32)(unsafe.Pointer(addr)), uint32(v))) |
| | } |
| |
|
| | |
| | func StorepNoWB(addr unsafe.Pointer, v unsafe.Pointer) |
| |
|
| | |
| | func Store(addr *uint32, v uint32) |
| |
|
| | |
| | func StoreRel(addr *uint32, v uint32) |
| |
|
| | |
| | func StoreReluintptr(addr *uintptr, v uintptr) |
| |
|
| | |
| | func goCas64(addr *uint64, old, new uint64) bool { |
| | if uintptr(unsafe.Pointer(addr))&7 != 0 { |
| | *(*int)(nil) = 0 |
| | } |
| | _ = *addr |
| | var ok bool |
| | addrLock(addr).lock() |
| | if *addr == old { |
| | *addr = new |
| | ok = true |
| | } |
| | addrLock(addr).unlock() |
| | return ok |
| | } |
| |
|
| | |
| | func goXadd64(addr *uint64, delta int64) uint64 { |
| | if uintptr(unsafe.Pointer(addr))&7 != 0 { |
| | *(*int)(nil) = 0 |
| | } |
| | _ = *addr |
| | var r uint64 |
| | addrLock(addr).lock() |
| | r = *addr + uint64(delta) |
| | *addr = r |
| | addrLock(addr).unlock() |
| | return r |
| | } |
| |
|
| | |
| | func goXchg64(addr *uint64, v uint64) uint64 { |
| | if uintptr(unsafe.Pointer(addr))&7 != 0 { |
| | *(*int)(nil) = 0 |
| | } |
| | _ = *addr |
| | var r uint64 |
| | addrLock(addr).lock() |
| | r = *addr |
| | *addr = v |
| | addrLock(addr).unlock() |
| | return r |
| | } |
| |
|
| | |
| | func goLoad64(addr *uint64) uint64 { |
| | if uintptr(unsafe.Pointer(addr))&7 != 0 { |
| | *(*int)(nil) = 0 |
| | } |
| | _ = *addr |
| | var r uint64 |
| | addrLock(addr).lock() |
| | r = *addr |
| | addrLock(addr).unlock() |
| | return r |
| | } |
| |
|
| | |
| | func goStore64(addr *uint64, v uint64) { |
| | if uintptr(unsafe.Pointer(addr))&7 != 0 { |
| | *(*int)(nil) = 0 |
| | } |
| | _ = *addr |
| | addrLock(addr).lock() |
| | *addr = v |
| | addrLock(addr).unlock() |
| | } |
| |
|
| | |
| | func Or8(addr *uint8, v uint8) |
| |
|
| | |
| | func goOr8(addr *uint8, v uint8) { |
| | |
| | addr32 := (*uint32)(unsafe.Pointer(uintptr(unsafe.Pointer(addr)) &^ 3)) |
| | word := uint32(v) << ((uintptr(unsafe.Pointer(addr)) & 3) * 8) |
| | for { |
| | old := *addr32 |
| | if Cas(addr32, old, old|word) { |
| | return |
| | } |
| | } |
| | } |
| |
|
| | |
| | func And8(addr *uint8, v uint8) |
| |
|
| | |
| | func goAnd8(addr *uint8, v uint8) { |
| | |
| | addr32 := (*uint32)(unsafe.Pointer(uintptr(unsafe.Pointer(addr)) &^ 3)) |
| | word := uint32(v) << ((uintptr(unsafe.Pointer(addr)) & 3) * 8) |
| | mask := uint32(0xFF) << ((uintptr(unsafe.Pointer(addr)) & 3) * 8) |
| | word |= ^mask |
| | for { |
| | old := *addr32 |
| | if Cas(addr32, old, old&word) { |
| | return |
| | } |
| | } |
| | } |
| |
|
| | |
| | func Or(addr *uint32, v uint32) { |
| | for { |
| | old := *addr |
| | if Cas(addr, old, old|v) { |
| | return |
| | } |
| | } |
| | } |
| |
|
| | |
| | func And(addr *uint32, v uint32) { |
| | for { |
| | old := *addr |
| | if Cas(addr, old, old&v) { |
| | return |
| | } |
| | } |
| | } |
| |
|
| | |
| | func armcas(ptr *uint32, old, new uint32) bool |
| |
|
| | |
| | func Load(addr *uint32) uint32 |
| |
|
| | |
| | func Loadp(addr unsafe.Pointer) unsafe.Pointer |
| |
|
| | |
| | func Load8(addr *uint8) uint8 |
| |
|
| | |
| | func LoadAcq(addr *uint32) uint32 |
| |
|
| | |
| | func LoadAcquintptr(ptr *uintptr) uintptr |
| |
|
| | |
| | func Cas64(addr *uint64, old, new uint64) bool |
| |
|
| | |
| | func CasRel(addr *uint32, old, new uint32) bool |
| |
|
| | |
| | func Xadd64(addr *uint64, delta int64) uint64 |
| |
|
| | |
| | func Xchg64(addr *uint64, v uint64) uint64 |
| |
|
| | |
| | func Load64(addr *uint64) uint64 |
| |
|
| | |
| | func Store8(addr *uint8, v uint8) |
| |
|
| | |
| | func Store64(addr *uint64, v uint64) |
| |
|