diff options
author | Cuong Manh Le <cuong.manhle.vn@gmail.com> | 2022-08-17 16:22:13 +0700 |
---|---|---|
committer | Cuong Manh Le <cuong.manhle.vn@gmail.com> | 2022-08-17 17:39:58 +0000 |
commit | 04d8c2327d5a2788757f22fd0e23198f7045c20f (patch) | |
tree | 9fb7dffc48070bee1ca1045acb9aca9a3d2b6e74 /src/runtime/netpoll_kqueue.go | |
parent | 9b988c9094df18a75537f5c4ae12449062550290 (diff) | |
download | go-04d8c2327d5a2788757f22fd0e23198f7045c20f.tar.gz go-04d8c2327d5a2788757f22fd0e23198f7045c20f.zip |
runtime: convert kqueue netpollWakeSig to atomic type
Updates #53821
Change-Id: I85d7444be36967e1e7e0ff2ce2f19b73581ecdde
Reviewed-on: https://go-review.googlesource.com/c/go/+/423880
Run-TryBot: Cuong Manh Le <cuong.manhle.vn@gmail.com>
Reviewed-by: Michael Pratt <mpratt@google.com>
Reviewed-by: Keith Randall <khr@google.com>
TryBot-Result: Gopher Robot <gobot@golang.org>
Auto-Submit: Cuong Manh Le <cuong.manhle.vn@gmail.com>
Diffstat (limited to 'src/runtime/netpoll_kqueue.go')
-rw-r--r-- | src/runtime/netpoll_kqueue.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/runtime/netpoll_kqueue.go b/src/runtime/netpoll_kqueue.go index 78d1663ad9..5ae77b57f2 100644 --- a/src/runtime/netpoll_kqueue.go +++ b/src/runtime/netpoll_kqueue.go @@ -18,7 +18,7 @@ var ( netpollBreakRd, netpollBreakWr uintptr // for netpollBreak - netpollWakeSig uint32 // used to avoid duplicate calls of netpollBreak + netpollWakeSig atomic.Uint32 // used to avoid duplicate calls of netpollBreak ) func netpollinit() { @@ -84,7 +84,7 @@ func netpollarm(pd *pollDesc, mode int) { // netpollBreak interrupts a kevent. 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 } @@ -155,7 +155,7 @@ retry: // if blocking. var tmp [16]byte read(int32(netpollBreakRd), noescape(unsafe.Pointer(&tmp[0])), int32(len(tmp))) - atomic.Store(&netpollWakeSig, 0) + netpollWakeSig.Store(0) } continue } |