mirror of
https://github.com/golang/go
synced 2024-11-02 11:50:30 +00:00
runtime: convert profbuf.eof to atomic type
Updates #53821 Change-Id: I271faaedbf8b8efca5fc765496eaf45c94927edf Reviewed-on: https://go-review.googlesource.com/c/go/+/423891 Reviewed-by: Keith Randall <khr@google.com> Run-TryBot: Cuong Manh Le <cuong.manhle.vn@gmail.com> TryBot-Result: Gopher Robot <gobot@golang.org> Auto-Submit: Cuong Manh Le <cuong.manhle.vn@gmail.com> Reviewed-by: Michael Pratt <mpratt@google.com>
This commit is contained in:
parent
04d3d6bf48
commit
5b1658d691
1 changed files with 4 additions and 4 deletions
|
@ -89,7 +89,7 @@ type profBuf struct {
|
|||
r, w profAtomic
|
||||
overflow atomic.Uint64
|
||||
overflowTime atomic.Uint64
|
||||
eof uint32
|
||||
eof atomic.Uint32
|
||||
|
||||
// immutable (excluding slice content)
|
||||
hdrsize uintptr
|
||||
|
@ -394,10 +394,10 @@ func (b *profBuf) write(tagPtr *unsafe.Pointer, now int64, hdr []uint64, stk []u
|
|||
// close signals that there will be no more writes on the buffer.
|
||||
// Once all the data has been read from the buffer, reads will return eof=true.
|
||||
func (b *profBuf) close() {
|
||||
if atomic.Load(&b.eof) > 0 {
|
||||
if b.eof.Load() > 0 {
|
||||
throw("runtime: profBuf already closed")
|
||||
}
|
||||
atomic.Store(&b.eof, 1)
|
||||
b.eof.Store(1)
|
||||
b.wakeupExtra()
|
||||
}
|
||||
|
||||
|
@ -475,7 +475,7 @@ Read:
|
|||
dst[2+b.hdrsize] = uint64(count)
|
||||
return dst[:2+b.hdrsize+1], overflowTag[:1], false
|
||||
}
|
||||
if atomic.Load(&b.eof) > 0 {
|
||||
if b.eof.Load() > 0 {
|
||||
// No data, no overflow, EOF set: done.
|
||||
return nil, nil, true
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue