//extern SigTabTT runtimeĀ·sigtab[];
-var sigset_all = ^uint32(0)
+type sigset uint32
+
+var sigset_all = ^sigset(0)
func unimplemented(name string) {
println(name, "not implemented")
print("newosproc stk=", stk, " m=", mp, " g=", mp.g0, " id=", mp.id, " ostk=", &mp, "\n")
}
- var oset uint32
+ var oset sigset
sigprocmask(_SIG_SETMASK, &sigset_all, &oset)
errno := bsdthread_create(stk, unsafe.Pointer(mp), funcPC(mstart))
sigprocmask(_SIG_SETMASK, &oset, nil)
}
stk := unsafe.Pointer(uintptr(stack) + stacksize)
- var oset uint32
+ var oset sigset
sigprocmask(_SIG_SETMASK, &sigset_all, &oset)
errno := bsdthread_create(stk, fn, fnarg)
sigprocmask(_SIG_SETMASK, &oset, nil)
//go:nosplit
func msigsave(mp *m) {
- smask := (*uint32)(unsafe.Pointer(&mp.sigmask))
- if unsafe.Sizeof(*smask) > unsafe.Sizeof(mp.sigmask) {
- throw("insufficient storage for signal mask")
- }
- sigprocmask(_SIG_SETMASK, nil, smask)
+ sigprocmask(_SIG_SETMASK, nil, &mp.sigmask)
}
//go:nosplit
func msigrestore(mp *m) {
- smask := (*uint32)(unsafe.Pointer(&mp.sigmask))
- sigprocmask(_SIG_SETMASK, smask, nil)
+ sigprocmask(_SIG_SETMASK, &mp.sigmask, nil)
}
//go:nosplit
signalstack(&_g_.m.gsignal.stack)
// restore signal mask from m.sigmask and unblock essential signals
- nmask := *(*uint32)(unsafe.Pointer(&_g_.m.sigmask))
+ nmask := _g_.m.sigmask
for i := range sigtable {
if sigtable[i].flags&_SigUnblock != 0 {
nmask &^= 1 << (uint32(i) - 1)
}
func updatesigmask(m sigmask) {
- sigprocmask(_SIG_SETMASK, &m[0], nil)
+ s := sigset(m[0])
+ sigprocmask(_SIG_SETMASK, &s, nil)
}
func unblocksig(sig int32) {
- mask := uint32(1) << (uint32(sig) - 1)
+ mask := sigset(1) << (uint32(sig) - 1)
sigprocmask(_SIG_UNBLOCK, &mask, nil)
}
//go:nosplit
func msigsave(mp *m) {
- smask := (*sigset)(unsafe.Pointer(&mp.sigmask))
- if unsafe.Sizeof(*smask) > unsafe.Sizeof(mp.sigmask) {
- throw("insufficient storage for signal mask")
- }
- sigprocmask(_SIG_SETMASK, nil, smask)
+ sigprocmask(_SIG_SETMASK, nil, &mp.sigmask)
}
//go:nosplit
func msigrestore(mp *m) {
- smask := (*sigset)(unsafe.Pointer(&mp.sigmask))
- sigprocmask(_SIG_SETMASK, smask, nil)
+ sigprocmask(_SIG_SETMASK, &mp.sigmask, nil)
}
//go:nosplit
signalstack(&_g_.m.gsignal.stack)
// restore signal mask from m.sigmask and unblock essential signals
- nmask := *(*sigset)(unsafe.Pointer(&_g_.m.sigmask))
+ nmask := _g_.m.sigmask
for i := range sigtable {
if sigtable[i].flags&_SigUnblock != 0 {
nmask.__bits[(i-1)/32] &^= 1 << ((uint32(i) - 1) & 31)
//go:nosplit
func msigsave(mp *m) {
- smask := (*sigset)(unsafe.Pointer(&mp.sigmask))
- if unsafe.Sizeof(*smask) > unsafe.Sizeof(mp.sigmask) {
- throw("insufficient storage for signal mask")
- }
- sigprocmask(_SIG_SETMASK, nil, smask)
+ sigprocmask(_SIG_SETMASK, nil, &mp.sigmask)
}
//go:nosplit
func msigrestore(mp *m) {
- smask := (*sigset)(unsafe.Pointer(&mp.sigmask))
- sigprocmask(_SIG_SETMASK, smask, nil)
+ sigprocmask(_SIG_SETMASK, &mp.sigmask, nil)
}
//go:nosplit
signalstack(&_g_.m.gsignal.stack)
// restore signal mask from m.sigmask and unblock essential signals
- nmask := *(*sigset)(unsafe.Pointer(&_g_.m.sigmask))
+ nmask := _g_.m.sigmask
for i := range sigtable {
if sigtable[i].flags&_SigUnblock != 0 {
nmask.__bits[(i-1)/32] &^= 1 << ((uint32(i) - 1) & 31)
//go:nosplit
func msigsave(mp *m) {
- smask := (*sigset)(unsafe.Pointer(&mp.sigmask))
- if unsafe.Sizeof(*smask) > unsafe.Sizeof(mp.sigmask) {
- throw("insufficient storage for signal mask")
- }
+ smask := &mp.sigmask
rtsigprocmask(_SIG_SETMASK, nil, smask, int32(unsafe.Sizeof(*smask)))
}
//go:nosplit
func msigrestore(mp *m) {
- smask := (*sigset)(unsafe.Pointer(&mp.sigmask))
+ smask := &mp.sigmask
rtsigprocmask(_SIG_SETMASK, smask, nil, int32(unsafe.Sizeof(*smask)))
}
_g_.m.procid = uint64(gettid())
// restore signal mask from m.sigmask and unblock essential signals
- nmask := *(*sigset)(unsafe.Pointer(&_g_.m.sigmask))
+ nmask := _g_.m.sigmask
for i := range sigtable {
if sigtable[i].flags&_SigUnblock != 0 {
sigdelset(&nmask, i)
import "unsafe"
+type sigset struct{}
+
// Called to initialize a new m (including the bootstrap m).
// Called on the parent thread (main thread in case of bootstrap), can allocate memory.
func mpreinit(mp *m) {
//go:nosplit
func msigsave(mp *m) {
- smask := (*sigset)(unsafe.Pointer(&mp.sigmask))
- if unsafe.Sizeof(*smask) > unsafe.Sizeof(mp.sigmask) {
- throw("insufficient storage for signal mask")
- }
- sigprocmask(_SIG_SETMASK, nil, smask)
+ sigprocmask(_SIG_SETMASK, nil, &mp.sigmask)
}
//go:nosplit
func msigrestore(mp *m) {
- smask := (*sigset)(unsafe.Pointer(&mp.sigmask))
- sigprocmask(_SIG_SETMASK, smask, nil)
+ sigprocmask(_SIG_SETMASK, &mp.sigmask, nil)
}
//go:nosplit
signalstack(&_g_.m.gsignal.stack)
// restore signal mask from m.sigmask and unblock essential signals
- nmask := *(*sigset)(unsafe.Pointer(&_g_.m.sigmask))
+ nmask := _g_.m.sigmask
for i := range sigtable {
if sigtable[i].flags&_SigUnblock != 0 {
nmask.__bits[(i-1)/32] &^= 1 << ((uint32(i) - 1) & 31)
_CLOCK_MONOTONIC = 3
)
+type sigset uint32
+
const (
- sigset_none = uint32(0)
- sigset_all = ^uint32(0)
+ sigset_none = sigset(0)
+ sigset_all = ^sigset(0)
)
// From OpenBSD's <sys/sysctl.h>
//go:nosplit
func msigsave(mp *m) {
- smask := (*uint32)(unsafe.Pointer(&mp.sigmask))
- if unsafe.Sizeof(*smask) > unsafe.Sizeof(mp.sigmask) {
- throw("insufficient storage for signal mask")
- }
- *smask = sigprocmask(_SIG_BLOCK, 0)
+ mp.sigmask = sigprocmask(_SIG_BLOCK, 0)
}
//go:nosplit
func msigrestore(mp *m) {
- smask := *(*uint32)(unsafe.Pointer(&mp.sigmask))
- sigprocmask(_SIG_SETMASK, smask)
+ sigprocmask(_SIG_SETMASK, mp.sigmask)
}
//go:nosplit
signalstack(&_g_.m.gsignal.stack)
// restore signal mask from m.sigmask and unblock essential signals
- nmask := *(*uint32)(unsafe.Pointer(&_g_.m.sigmask))
+ nmask := _g_.m.sigmask
for i := range sigtable {
if sigtable[i].flags&_SigUnblock != 0 {
nmask &^= 1 << (uint32(i) - 1)
if restart {
sa.sa_flags |= _SA_RESTART
}
- sa.sa_mask = sigset_all
+ sa.sa_mask = uint32(sigset_all)
if fn == funcPC(sighandler) {
fn = funcPC(sigtramp)
}
}
func updatesigmask(m sigmask) {
- sigprocmask(_SIG_SETMASK, m[0])
+ sigprocmask(_SIG_SETMASK, sigset(m[0]))
}
func unblocksig(sig int32) {
- mask := uint32(1) << (uint32(sig) - 1)
+ mask := sigset(1) << (uint32(sig) - 1)
sigprocmask(_SIG_UNBLOCK, mask)
}
"unsafe"
)
+type sigset struct{}
+
// Called to initialize a new m (including the bootstrap m).
// Called on the parent thread (main thread in case of bootstrap), can allocate memory.
func mpreinit(mp *m) {
_GetQueuedCompletionStatusEx stdFunction
)
+type sigset struct{}
+
// Call a Windows function with stdcall conventions,
// and switch to os stack during the call.
func asmstdcall(fn unsafe.Pointer)
//go:nosplit
func msigsave(mp *m) {
- smask := (*sigset)(unsafe.Pointer(&mp.sigmask))
- if unsafe.Sizeof(*smask) > unsafe.Sizeof(mp.sigmask) {
- throw("insufficient storage for signal mask")
- }
- sigprocmask(_SIG_SETMASK, nil, smask)
+ sigprocmask(_SIG_SETMASK, nil, &mp.sigmask)
}
//go:nosplit
func msigrestore(mp *m) {
- smask := (*sigset)(unsafe.Pointer(&mp.sigmask))
- sigprocmask(_SIG_SETMASK, smask, nil)
+ sigprocmask(_SIG_SETMASK, &mp.sigmask, nil)
}
//go:nosplit
signalstack(&_g_.m.gsignal.stack)
// restore signal mask from m.sigmask and unblock essential signals
- nmask := *(*sigset)(unsafe.Pointer(&_g_.m.sigmask))
+ nmask := _g_.m.sigmask
for i := range sigtable {
if sigtable[i].flags&_SigUnblock != 0 {
nmask.__sigbits[(i-1)/32] &^= 1 << ((uint32(i) - 1) & 31)
func sysctl(mib *uint32, miblen uint32, out *byte, size *uintptr, dst *byte, ndst uintptr) int32
//go:noescape
-func sigprocmask(how uint32, new, old *uint32)
+func sigprocmask(how uint32, new, old *sigset)
//go:noescape
func sigaction(mode uint32, new, old *sigactiont)
func sigaltstack(new, old *stackt)
//go:noescape
-func sigprocmask(mode int32, new uint32) uint32
+func sigprocmask(mode int32, new sigset) sigset
//go:noescape
func sysctl(mib *uint32, miblen uint32, out *byte, size *uintptr, dst *byte, ndst uintptr) int32
// Fields not known to debuggers.
procid uint64 // for debuggers, but offset not hard-coded
gsignal *g // signal-handling g
- sigmask [4]uintptr // storage for saved signal mask
+ sigmask sigset // storage for saved signal mask
tls [6]uintptr // thread-local storage (for x86 extern register)
mstartfn func()
curg *g // current running goroutine