Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 119 for Setg (0.17 sec)

  1. src/runtime/race.go

    //go:nosplit
    func racerelease(addr unsafe.Pointer) {
    	racereleaseg(getg(), addr)
    }
    
    //go:nosplit
    func racereleaseg(gp *g, addr unsafe.Pointer) {
    	if getg().raceignore != 0 || !isvalidaddr(addr) {
    		return
    	}
    	racecall(&__tsan_release, gp.racectx, uintptr(addr), 0, 0)
    }
    
    //go:nosplit
    func racereleaseacquire(addr unsafe.Pointer) {
    	racereleaseacquireg(getg(), addr)
    }
    
    //go:nosplit
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:37:29 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  2. src/runtime/lock_wasip1.go

    		// observe this.
    		throw("self deadlock")
    	}
    	gp := getg()
    	if gp.m.locks < 0 {
    		throw("lock count")
    	}
    	gp.m.locks++
    	l.key = mutex_locked
    }
    
    func unlock(l *mutex) {
    	unlockWithRank(l)
    }
    
    func unlock2(l *mutex) {
    	if l.key == mutex_unlocked {
    		throw("unlock of unlocked lock")
    	}
    	gp := getg()
    	gp.m.locks--
    	if gp.m.locks < 0 {
    		throw("lock count")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 21:02:20 UTC 2023
    - 2K bytes
    - Viewed (0)
  3. src/runtime/lock_js.go

    		// observe this.
    		throw("self deadlock")
    	}
    	gp := getg()
    	if gp.m.locks < 0 {
    		throw("lock count")
    	}
    	gp.m.locks++
    	l.key = mutex_locked
    }
    
    func unlock(l *mutex) {
    	unlockWithRank(l)
    }
    
    func unlock2(l *mutex) {
    	if l.key == mutex_unlocked {
    		throw("unlock of unlocked lock")
    	}
    	gp := getg()
    	gp.m.locks--
    	if gp.m.locks < 0 {
    		throw("lock count")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 21:02:20 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  4. src/runtime/os2_aix.go

    //go:nosplit
    func exit(code int32) {
    	gp := getg()
    
    	// Check the validity of g because without a g during
    	// newosproc0.
    	if gp != nil {
    		syscall1(&libc_exit, uintptr(code))
    		return
    	}
    	exit1(code)
    }
    
    func write2(fd, p uintptr, n int32) int32
    
    //go:nosplit
    func write1(fd uintptr, p unsafe.Pointer, n int32) int32 {
    	gp := getg()
    
    	// Check the validity of g because without a g during
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Dec 14 17:22:18 UTC 2023
    - 20.9K bytes
    - Viewed (0)
  5. src/runtime/lockrank_on.go

    			throw("lockRank release without matching lockRank acquire")
    		}
    	})
    
    	releasem(getg().m)
    }
    
    // nosplit because it may be called from nosplit contexts.
    //
    //go:nosplit
    func lockWithRankMayAcquire(l *mutex, rank lockRank) {
    	gp := getg()
    	if gp.m.locksHeldLen == 0 {
    		// No possibility of lock ordering problem if no other locks held
    		return
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 14:29:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. src/runtime/os_windows.go

    	if ns < 0 {
    		result = stdcall2(_WaitForSingleObject, getg().m.waitsema, uintptr(_INFINITE))
    	} else {
    		start := nanotime()
    		elapsed := int64(0)
    		for {
    			ms := int64(timediv(ns-elapsed, 1000000, nil))
    			if ms == 0 {
    				ms = 1
    			}
    			result = stdcall4(_WaitForMultipleObjects, 2,
    				uintptr(unsafe.Pointer(&[2]uintptr{getg().m.waitsema, getg().m.resumesema})),
    				0, uintptr(ms))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 22:55:25 UTC 2024
    - 41.5K bytes
    - Viewed (0)
  7. src/runtime/export_debug_test.go

    	// a signal handler. Add the go:nowritebarrierrec annotation and restructure
    	// this to avoid write barriers.
    
    	switch h.gp.atomicstatus.Load() {
    	case _Grunning:
    		if getg().m != h.mp {
    			println("trap on wrong M", getg().m, h.mp)
    			return false
    		}
    		// Save the signal context
    		h.saveSigContext(ctxt)
    		// Set PC to debugCallV2.
    		ctxt.setsigpc(uint64(abi.FuncPCABIInternal(debugCallV2)))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  8. src/runtime/os_aix.go

    // This will return a pointer to errno.
    func miniterrno() {
    	mp := getg().m
    	r, _ := syscall0(&libc__Errno)
    	mp.perrno = r
    
    }
    
    func minit() {
    	miniterrno()
    	minitSignals()
    	getg().m.procid = uint64(pthread_self())
    }
    
    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
    - 8.9K bytes
    - Viewed (0)
  9. src/runtime/mwbbuf.go

    	if getg().m.dying > 0 {
    		// We're going down. Not much point in write barriers
    		// and this way we can allow write barriers in the
    		// panic path.
    		getg().m.p.ptr().wbBuf.discard()
    		return
    	}
    
    	// Switch to the system stack so we don't have to worry about
    	// safe points.
    	systemstack(func() {
    		wbBufFlush1(getg().m.p.ptr())
    	})
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. src/runtime/signal_windows.go

    	callbackLastVCH
    )
    
    // sigFetchGSafe is like getg() but without panicking
    // when TLS is not set.
    // Only implemented on windows/386, which is the only
    // arch that loads TLS when calling getg(). Others
    // use a dedicated register.
    func sigFetchGSafe() *g
    
    func sigFetchG() *g {
    	if GOARCH == "386" {
    		return sigFetchGSafe()
    	}
    	return getg()
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 17 20:32:29 UTC 2023
    - 14.5K bytes
    - Viewed (0)
Back to top