- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 106 for mp (0.02 sec)
-
src/runtime/os3_solaris.go
mp.ts.tv_sec = ns / 1000000000 mp.ts.tv_nsec = ns % 1000000000 mp.libcall.fn = uintptr(unsafe.Pointer(&libc_sem_reltimedwait_np)) mp.libcall.n = 2 mp.scratch = mscratch{} mp.scratch.v[0] = mp.waitsema mp.scratch.v[1] = uintptr(unsafe.Pointer(&mp.ts)) mp.libcall.args = uintptr(unsafe.Pointer(&mp.scratch)) asmcgocall(unsafe.Pointer(&asmsysvicall6x), unsafe.Pointer(&mp.libcall)) if *mp.perrno != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 17.6K bytes - Viewed (0) -
src/runtime/os_darwin.go
pthread_mutex_unlock(&mp.mutex) return -1 } var t timespec t.setNsec(ns - spent) err := pthread_cond_timedwait_relative_np(&mp.cond, &mp.mutex, &t) if err == _ETIMEDOUT { pthread_mutex_unlock(&mp.mutex) return -1 } } else { pthread_cond_wait(&mp.cond, &mp.mutex) } } } //go:nosplit func semawakeup(mp *m) { if g := getg(); g == g.m.gsignal {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 11.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/examples/stateful/stateful.go
mp.mu.Lock() defer mp.mu.Unlock() mp.executionPoints = nil } // PreBind is the function invoked by the framework at "prebind" extension // point. func (mp *MultipointExample) PreBind(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status { // PreBind could be called concurrently for different pods. mp.mu.Lock() defer mp.mu.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 03:43:17 UTC 2023 - 3.3K bytes - Viewed (0) -
src/runtime/os_aix.go
initsig(true) } // Ms related functions func mpreinit(mp *m) { mp.gsignal = malg(32 * 1024) // AIX wants >= 8K mp.gsignal.m = mp } // errno address must be retrieved by calling _Errno libc function. // This will return a pointer to errno. func miniterrno() { mp := getg().m r, _ := syscall0(&libc__Errno) mp.perrno = r } func minit() { miniterrno() minitSignals()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.9K bytes - Viewed (0) -
src/runtime/debug.go
var n = int64(atomic.Load64(&ncgocall)) for mp := (*m)(atomic.Loadp(unsafe.Pointer(&allm))); mp != nil; mp = mp.alllink { n += int64(mp.ncgocall) } return n } func totalMutexWaitTimeNanos() int64 { total := sched.totalMutexWaitTime.Load() total += sched.totalRuntimeLockWaitTime.Load() for mp := (*m)(atomic.Loadp(unsafe.Pointer(&allm))); mp != nil; mp = mp.alllink { total += mp.mLockProfile.waitTime.Load() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 20:38:24 UTC 2024 - 4.2K bytes - Viewed (0) -
src/runtime/os_windows.go
// //go:nosplit func mdestroy(mp *m) { if mp.highResTimer != 0 { stdcall1(_CloseHandle, mp.highResTimer) mp.highResTimer = 0 } if mp.waitIocpTimer != 0 { stdcall1(_CloseHandle, mp.waitIocpTimer) mp.waitIocpTimer = 0 } if mp.waitIocpHandle != 0 { stdcall1(_CloseHandle, mp.waitIocpHandle) mp.waitIocpHandle = 0 } if mp.waitsema != 0 { stdcall1(_CloseHandle, mp.waitsema)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 41.5K bytes - Viewed (0) -
src/runtime/os_dragonfly.go
func lwp_start(uintptr) // May run with m.p==nil, so write barriers are not allowed. // //go:nowritebarrier func newosproc(mp *m) { stk := unsafe.Pointer(mp.g0.stack.hi) if false { print("newosproc stk=", stk, " m=", mp, " g=", mp.g0, " lwp_start=", abi.FuncPCABI0(lwp_start), " id=", mp.id, " ostk=", &mp, "\n") } var oset sigset sigprocmask(_SIG_SETMASK, &sigset_all, &oset) params := lwpparams{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 7.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/suppliers/DynamicRevisionRemoteResolveWithMetadataSupplierIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 01 11:46:17 UTC 2024 - 49K bytes - Viewed (0) -
src/runtime/os_wasm.go
} 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) { mp.gsignal = malg(32 * 1024) mp.gsignal.m = mp } //go:nosplit func usleep_no_g(usec uint32) { usleep(usec) } //go:nosplit func sigsave(p *sigset) { } //go:nosplit func msigrestore(sigmask sigset) { }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 3.2K bytes - Viewed (0) -
src/runtime/debugcall.go
// Save lock state to restore later. mp := gp.m if mp != gp.lockedm.ptr() { throw("inconsistent lockedm") } // Save the external lock count and clear it so // that it can't be unlocked from the debug call. // Note: we already locked internally to the thread, // so if we were locked before we're still locked now. lockedExt = mp.lockedExt mp.lockedExt = 0 mp.lockedg.set(newg) newg.lockedm.set(mp)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 05 20:50:21 UTC 2024 - 7.1K bytes - Viewed (0)