Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 33 for lockOSThread (0.29 sec)

  1. src/runtime/coro.go

    // pointer errors.
    type coro struct {
    	gp guintptr
    	f  func(*coro)
    
    	// State for validating thread-lock interactions.
    	mp        *m
    	lockedExt uint32 // mp's external LockOSThread counter at coro creation time.
    	lockedInt uint32 // mp's internal lockOSThread counter at coro creation time.
    }
    
    //go:linkname newcoro
    
    // newcoro creates a new coro containing a
    // goroutine blocked waiting to run f
    // and returns that coro.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:09:18 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  2. src/runtime/debugcall.go

    	//
    	// Debuggers rely on us running on the same thread until we get to
    	// dispatch the function they asked as to.
    	//
    	// We're going to transfer this to the new G we just created.
    	lockOSThread()
    
    	// Create a new goroutine to execute the call on. Run this on
    	// the system stack to avoid growing our stack.
    	systemstack(func() {
    		// TODO(mknyszek): It would be nice to wrap these arguments in an allocated
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 05 20:50:21 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/netns_linux.go

    	// leave the thread locked to die without a risk of the current thread
    	// left lingering with incorrect namespace.
    	var innerError error
    	go func() {
    		defer wg.Done()
    		runtime.LockOSThread()
    		innerError = containedCall()
    	}()
    	wg.Wait()
    
    	return innerError
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jan 31 10:05:36 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  4. src/internal/syscall/windows/registry/key.go

    func (k Key) ReadSubKeyNames() ([]string, error) {
    	// RegEnumKeyEx must be called repeatedly and to completion.
    	// During this time, this goroutine cannot migrate away from
    	// its current thread. See #49320.
    	runtime.LockOSThread()
    	defer runtime.UnlockOSThread()
    
    	names := make([]string, 0)
    	// Registry key size limit is 255 bytes and described there:
    	// https://learn.microsoft.com/en-us/windows/win32/sysinfo/registry-element-size-limits
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 12 16:42:41 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  5. 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)
  6. src/runtime/crash_unix_test.go

    		runtime.Close(w)
    	}()
    	runtime.Closeonexec(r)
    	runtime.Closeonexec(w)
    
    	var want, got int64
    	var wg sync.WaitGroup
    	ready := make(chan *runtime.M)
    	wg.Add(1)
    	go func() {
    		runtime.LockOSThread()
    		want, got = runtime.WaitForSigusr1(r, w, func(mp *runtime.M) {
    			ready <- mp
    		})
    		runtime.UnlockOSThread()
    		wg.Done()
    	}()
    	waitingM := <-ready
    	runtime.SendSigusr1(waitingM)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 12 20:11:47 UTC 2023
    - 9.2K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top