Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 137 for Setg (0.12 sec)

  1. src/runtime/export_debuglog_test.go

    func (l *dlogger) P(x any) *dlogger      { return l.p(x) }
    func (l *dlogger) S(x string) *dlogger   { return l.s(x) }
    func (l *dlogger) PC(x uintptr) *dlogger { return l.pc(x) }
    
    func DumpDebugLog() string {
    	gp := getg()
    	gp.writebuf = make([]byte, 0, 1<<20)
    	printDebugLog()
    	buf := gp.writebuf
    	gp.writebuf = nil
    
    	return string(buf)
    }
    
    func ResetDebugLog() {
    	stw := stopTheWorld(stwForTestResetDebugLog)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 15 16:49:45 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  2. src/runtime/rwmutex.go

    			lock(&rw.rLock)
    			if rw.readerPass > 0 {
    				// Writer finished.
    				rw.readerPass -= 1
    				unlock(&rw.rLock)
    			} else {
    				// Queue this reader to be woken by
    				// the writer.
    				m := getg().m
    				m.schedlink = rw.readers
    				rw.readers.set(m)
    				unlock(&rw.rLock)
    				notesleep(&m.park)
    				noteclear(&m.park)
    			}
    		})
    	}
    }
    
    // runlock undoes a single rlock call on rw.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 14:29:04 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. src/runtime/mgcmark.go

    // This must be called with preemption enabled.
    func gcAssistAlloc(gp *g) {
    	// Don't assist in non-preemptible contexts. These are
    	// generally fragile and won't allow the assist to block.
    	if getg() == gp.m.g0 {
    		return
    	}
    	if mp := getg().m; mp.locks > 0 || mp.preemptoff != "" {
    		return
    	}
    
    	// This extremely verbose boolean indicates whether we've
    	// entered mark assist from the perspective of the tracer.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  4. src/runtime/stack.go

    	}
    	if s := readgstatus(gp); s&_Gscan == 0 {
    		// We don't own the stack via _Gscan. We could still
    		// own it if this is our own user G and we're on the
    		// system stack.
    		if !(gp == getg().m.curg && getg() != getg().m.curg && s == _Grunning) {
    			// We don't own the stack.
    			throw("bad status in shrinkstack")
    		}
    	}
    	if !isShrinkStackSafe(gp) {
    		throw("shrinkstack at bad time")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 41.1K bytes
    - Viewed (0)
  5. src/runtime/sys_libc.go

    // Preserves the calling point as the location where a profiler traceback will begin.
    //
    //go:nosplit
    func libcCall(fn, arg unsafe.Pointer) int32 {
    	// Leave caller's PC/SP/G around for traceback.
    	gp := getg()
    	var mp *m
    	if gp != nil {
    		mp = gp.m
    	}
    	if mp != nil && mp.libcallsp == 0 {
    		mp.libcallg.set(gp)
    		mp.libcallpc = getcallerpc()
    		// sp must be the last, because once async cpu profiler finds
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 05 17:54:15 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  6. src/runtime/export_unix_test.go

    func WaitForSigusr1(r, w int32, ready func(mp *M)) (int64, int64) {
    	lockOSThread()
    	// Make sure we can receive SIGUSR1.
    	unblocksig(_SIGUSR1)
    
    	waitForSigusr1.rdpipe = r
    	waitForSigusr1.wrpipe = w
    
    	mp := getg().m
    	testSigusr1 = waitForSigusr1Callback
    	ready(mp)
    
    	// Wait for the signal. We use a pipe rather than a note
    	// because write is always async-signal-safe.
    	entersyscallblock()
    	var b byte
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 20 21:27:51 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  7. src/runtime/os_linux.go

    	// procid. We need this for asynchronous preemption and it's
    	// useful in debuggers.
    	getg().m.procid = uint64(gettid())
    }
    
    // Called from dropm to undo the effect of an minit.
    //
    //go:nosplit
    func unminit() {
    	unminitSignals()
    	getg().m.procid = 0
    }
    
    // Called from exitm, but not from drop, to undo the effect of thread-owned
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  8. src/runtime/os_dragonfly.go

    // Called to initialize a new m (including the bootstrap m).
    // Called on the new thread, cannot allocate memory.
    func minit() {
    	getg().m.procid = uint64(lwp_gettid())
    	minitSignals()
    }
    
    // Called from dropm to undo the effect of an minit.
    //
    //go:nosplit
    func unminit() {
    	unminitSignals()
    	getg().m.procid = 0
    }
    
    // Called from exitm, but not from drop, to undo the effect of thread-owned
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Dec 05 20:34:30 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  9. src/runtime/os_freebsd.go

    	// FreeBSD users are running a patched kernel. See issue #15658.
    	if gp := getg(); !isarchive && !islibrary && gp.m == &m0 && gp == gp.m.g0 {
    		st := stackt{ss_flags: _SS_DISABLE}
    		sigaltstack(&st, nil)
    	}
    
    	minitSignals()
    }
    
    // Called from dropm to undo the effect of an minit.
    //
    //go:nosplit
    func unminit() {
    	unminitSignals()
    	getg().m.procid = 0
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Dec 05 20:34:30 UTC 2023
    - 11.6K bytes
    - Viewed (0)
  10. src/runtime/cgo.go

    // so it emits the test and keeps the call, giving the desired
    // escape analysis result. The test is cheaper than the call.
    var cgoAlwaysFalse bool
    
    var cgo_yield = &_cgo_yield
    
    func cgoNoCallback(v bool) {
    	g := getg()
    	if g.nocgocallback && v {
    		panic("runtime: unexpected setting cgoNoCallback")
    	}
    	g.nocgocallback = v
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:47 UTC 2024
    - 3.1K bytes
    - Viewed (0)
Back to top