mirror of
git://gcc.gnu.org/git/gcc.git
synced 2025-04-28 07:50:26 +08:00
ca56d57624
NetBSD's semaphores use the underlying lighweight process mechanism (LWP) on NetBSD, rather than pthreads. This means the m.prodcid needs to be set to the LWP ID rather than the pthread ID in order for unpark notifications to get sent to the right place. Introduce a new getProcID() method that selects the correct ID for the platform. Reviewed-on: https://go-review.googlesource.com/c/gofrontend/+/261742
150 lines
2.9 KiB
Go
150 lines
2.9 KiB
Go
// Copyright 2018 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
// +build aix
|
|
|
|
package runtime
|
|
|
|
import (
|
|
"internal/cpu"
|
|
"unsafe"
|
|
)
|
|
|
|
//extern sysconf
|
|
func sysconf(int32) _C_long
|
|
|
|
//extern getsystemcfg
|
|
func getsystemcfg(int32) uint64
|
|
|
|
type mOS struct {
|
|
waitsema uintptr // semaphore for parking on locks
|
|
}
|
|
|
|
func getProcID() uint64 {
|
|
return uint64(gettid())
|
|
}
|
|
|
|
//extern malloc
|
|
func libc_malloc(uintptr) unsafe.Pointer
|
|
|
|
//go:noescape
|
|
//extern sem_init
|
|
func sem_init(sem *semt, pshared int32, value uint32) int32
|
|
|
|
//go:noescape
|
|
//extern sem_wait
|
|
func sem_wait(sem *semt) int32
|
|
|
|
//go:noescape
|
|
//extern sem_post
|
|
func sem_post(sem *semt) int32
|
|
|
|
//go:noescape
|
|
//extern sem_timedwait
|
|
func sem_timedwait(sem *semt, timeout *timespec) int32
|
|
|
|
//go:noescape
|
|
//extern clock_gettime
|
|
func clock_gettime(clock_id int64, timeout *timespec) int32
|
|
|
|
//go:nosplit
|
|
func semacreate(mp *m) {
|
|
if mp.waitsema != 0 {
|
|
return
|
|
}
|
|
|
|
var sem *semt
|
|
|
|
// Call libc's malloc rather than malloc. This will
|
|
// allocate space on the C heap. We can't call malloc
|
|
// here because it could cause a deadlock.
|
|
sem = (*semt)(libc_malloc(unsafe.Sizeof(*sem)))
|
|
if sem_init(sem, 0, 0) != 0 {
|
|
throw("sem_init")
|
|
}
|
|
mp.waitsema = uintptr(unsafe.Pointer(sem))
|
|
}
|
|
|
|
//go:nosplit
|
|
func semasleep(ns int64) int32 {
|
|
_m_ := getg().m
|
|
if ns >= 0 {
|
|
var ts timespec
|
|
|
|
if clock_gettime(_CLOCK_REALTIME, &ts) != 0 {
|
|
throw("clock_gettime")
|
|
}
|
|
|
|
sec := int64(ts.tv_sec) + ns/1e9
|
|
nsec := int64(ts.tv_nsec) + ns%1e9
|
|
if nsec >= 1e9 {
|
|
sec++
|
|
nsec -= 1e9
|
|
}
|
|
if sec != int64(timespec_sec_t(sec)) {
|
|
// Handle overflows (timespec_sec_t is 32-bit in 32-bit applications)
|
|
sec = 1<<31 - 1
|
|
}
|
|
ts.tv_sec = timespec_sec_t(sec)
|
|
ts.tv_nsec = timespec_nsec_t(nsec)
|
|
|
|
if sem_timedwait((*semt)(unsafe.Pointer(_m_.waitsema)), &ts) != 0 {
|
|
err := errno()
|
|
if err == _ETIMEDOUT || err == _EAGAIN || err == _EINTR {
|
|
return -1
|
|
}
|
|
println("sem_timedwait err ", err, " ts.tv_sec ", ts.tv_sec, " ts.tv_nsec ", ts.tv_nsec, " ns ", ns, " id ", _m_.id)
|
|
throw("sem_timedwait")
|
|
}
|
|
return 0
|
|
}
|
|
for {
|
|
r1 := sem_wait((*semt)(unsafe.Pointer(_m_.waitsema)))
|
|
if r1 == 0 {
|
|
break
|
|
}
|
|
if errno() == _EINTR {
|
|
continue
|
|
}
|
|
throw("sem_wait")
|
|
}
|
|
return 0
|
|
}
|
|
|
|
//go:nosplit
|
|
func semawakeup(mp *m) {
|
|
if sem_post((*semt)(unsafe.Pointer(mp.waitsema))) != 0 {
|
|
throw("sem_post")
|
|
}
|
|
}
|
|
|
|
func osinit() {
|
|
ncpu = int32(sysconf(__SC_NPROCESSORS_ONLN))
|
|
physPageSize = uintptr(sysconf(__SC_PAGE_SIZE))
|
|
setupSystemConf()
|
|
}
|
|
|
|
const (
|
|
_CLOCK_REALTIME = 9
|
|
_CLOCK_MONOTONIC = 10
|
|
)
|
|
|
|
const (
|
|
// getsystemcfg constants
|
|
_IMPL_POWER8 = 0x10000
|
|
_IMPL_POWER9 = 0x20000
|
|
)
|
|
|
|
// setupSystemConf retrieves information about the CPU and updates
|
|
// cpu.HWCap variables.
|
|
func setupSystemConf() {
|
|
impl := getsystemcfg(_SC_IMPL)
|
|
if impl&_IMPL_POWER8 != 0 {
|
|
cpu.HWCap2 |= cpu.PPC_FEATURE2_ARCH_2_07
|
|
}
|
|
if impl&_IMPL_POWER9 != 0 {
|
|
cpu.HWCap2 |= cpu.PPC_FEATURE2_ARCH_3_00
|
|
}
|
|
}
|