- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for lockOSThread (0.42 sec)
-
src/runtime/proc_test.go
go func() { if locked { runtime.LockOSThread() } for { select { case <-c: cack <- true return default: runtime.Gosched() } } }() time.Sleep(10 * time.Millisecond) c <- true <-cack } func TestYieldLocked(t *testing.T) { const N = 10 c := make(chan bool) go func() { runtime.LockOSThread() for i := 0; i < N; i++ { runtime.Gosched()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 25.8K bytes - Viewed (0) -
src/syscall/syscall_linux_test.go
if e != 0 { return e } return nil }, }, } waiter := func(q <-chan uintptr, r chan<- uintptr, once bool) { for x := range q { runtime.LockOSThread() v, _, e := syscall.Syscall(syscall.SYS_PRCTL, PR_GET_KEEPCAPS, 0, 0) if e != 0 { t.Errorf("tid=%d prctl(PR_GET_KEEPCAPS) failed: %v", syscall.Gettid(), e) } else if x != v {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23K bytes - Viewed (0) -
src/cmd/cgo/internal/test/testx.go
if runtime.GOOS == "android" { return } // Used to panic because of the UnlockOSThread below. C.lockOSThreadC() } //export lockOSThreadCallback func lockOSThreadCallback() { runtime.LockOSThread() runtime.UnlockOSThread() go C.usleep(10000) runtime.Gosched() } // issue 4054 part 2 - part 1 in test.go var issue4054b = []int{C.A, C.B, C.C, C.D, C.E, C.F, C.G, C.H, C.II, C.J}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 17 21:53:11 UTC 2023 - 10.6K bytes - Viewed (0) -
src/runtime/debug/garbage.go
// of goroutines. A Go program creates a new thread only when a goroutine // is ready to run but all the existing threads are blocked in system calls, cgo calls, // or are locked to other goroutines due to use of runtime.LockOSThread. // // SetMaxThreads is useful mainly for limiting the damage done by // programs that create an unbounded number of threads. The idea is // to take down the program before it takes down the operating system.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9.9K bytes - Viewed (0) -
src/runtime/cgocall.go
// exitsyscall, since it would otherwise be free to move us to // a different M. The call to unlockOSThread is in this function // after cgocallbackg1, or in the case of panicking, in unwindm. lockOSThread() checkm := gp.m // Save current syscall parameters, so m.winsyscall can be // used again if callback decide to make syscall. winsyscall := gp.m.winsyscall
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:47 UTC 2024 - 24.2K bytes - Viewed (0) -
tools/istio-iptables/pkg/dependencies/implementation_linux.go
// Warning: Do not call UnlockOSThread! Notably, netns.Do does call this. runtime.LockOSThread() if err := setupSandbox(); err != nil { return err } // Mark we have actually run the command. This lets us distinguish from a failure in setupSandbox() vs f() executed = true return f()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 20:49:10 UTC 2024 - 12K bytes - Viewed (0) -
src/os/exec.go
// new process, so it normally starts with the program name. // // If the calling goroutine has locked the operating system thread // with [runtime.LockOSThread] and modified any inheritable OS-level // thread state (for example, Linux or Plan 9 name spaces), the new // process will inherit the caller's thread state. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 12.8K bytes - Viewed (0) -
src/net/lookup_windows.go
err error } ch := make(chan result) // unbuffered go func() { if err := acquireThread(ctx); err != nil { ch <- result{err: mapErr(err)} return } defer releaseThread() runtime.LockOSThread() defer runtime.UnlockOSThread() proto, err := getprotobyname(name) select { case ch <- result{proto: proto, err: err}: case <-ctx.Done(): } }() select { case r := <-ch:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 14.2K bytes - Viewed (0) -
src/runtime/syscall_windows_test.go
} } func TestCallbackGC(t *testing.T) { nestedCall(t, runtime.GC) } func TestCallbackPanicLocked(t *testing.T) { runtime.LockOSThread() defer runtime.UnlockOSThread() if !runtime.LockedOSThread() { t.Fatal("runtime.LockOSThread didn't") } defer func() { s := recover() if s == nil { t.Fatal("did not panic") } if s.(string) != "callback panic" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 31 16:31:35 UTC 2023 - 32.5K bytes - Viewed (0) -
src/syscall/exec_plan9.go
func startProcess(argv0 string, argv []string, attr *ProcAttr) (pid int, err error) { type forkRet struct { pid int err error } forkc := make(chan forkRet, 1) go func() { runtime.LockOSThread() var ret forkRet ret.pid, ret.err = forkExec(argv0, argv, attr) // If fork fails there is nothing to wait for. if ret.err != nil || ret.pid == 0 { forkc <- ret return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 13.3K bytes - Viewed (0)