runtime: convert aix netpollWakeSig to atomic type

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>

diff --git a/src/runtime/netpoll_aix.go b/src/runtime/netpoll_aix.go
index 5247e56373a6619a95d7fb6bb44858d7304beac7..5184aad421d3b392907ca202cc0bd62bd0e74a0d 100644 (file)
--- a/src/runtime/netpoll_aix.go
+++ b/src/runtime/netpoll_aix.go
@@ -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.