qbit/go
1
0
Fork 0
mirror of https://github.com/golang/go synced 2024-09-30 00:04:28 -06:00
Code Releases Activity

runtime: convert aix netpollWakeSig to atomic type

Browse Source 
Updates #53821

Change-Id: Ic073871ed2638ca22e6cb057dd8297f27582e78f
Reviewed-on: https://go-review.googlesource.com/c/go/+/423877
Reviewed-by: Michael Pratt <mpratt@google.com>
Run-TryBot: Cuong Manh Le <cuong.manhle.vn@gmail.com>
Auto-Submit: Cuong Manh Le <cuong.manhle.vn@gmail.com>
TryBot-Result: Gopher Robot <gobot@golang.org>
Reviewed-by: Keith Randall <khr@google.com>
This commit is contained in:
Cuong Manh Le 2022-08-17 16:18:07 +07:00
parent 901b9233e6
commit ce7aae5095
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/runtime/netpoll_aix.go
View File

@ -45,7 +45,7 @@ var (
wrwake int32
pendingUpdates int32
netpollWakeSig uint32 // used to avoid duplicate calls of netpollBreak
netpollWakeSig atomic.Uint32 // used to avoid duplicate calls of netpollBreak
)
func netpollinit() {
@ -136,7 +136,7 @@ func netpollarm(pd *pollDesc, mode int) {
// netpollBreak interrupts a poll.
func netpollBreak() {
// Failing to cas indicates there is an in-flight wakeup, so we're done here.
if !atomic.Cas(&netpollWakeSig, 0, 1) {
if !netpollWakeSig.CompareAndSwap(0, 1) {
return
}
@ -196,7 +196,7 @@ retry:
var b [1]byte
for read(rdwake, unsafe.Pointer(&b[0]), 1) == 1 {
}
atomic.Store(&netpollWakeSig, 0)
netpollWakeSig.Store(0)
}
// Still look at the other fds even if the mode may have
// changed, as netpollBreak might have been called.