- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for mp (0.47 sec)
-
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_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) -
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) -
src/image/draw/clip_test.go
for _, c := range clipTests { dst := dst0.SubImage(c.dr).(*image.RGBA) src := src0.SubImage(c.sr).(*image.RGBA) r, sp, mp := c.r, c.sp, c.mp if c.nilMask { clip(dst, &r, src, &sp, nil, nil) } else { clip(dst, &r, src, &sp, mask0.SubImage(c.mr), &mp) } // Check that the actual results equal the expected results. if !c.r0.Eq(r) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 18:07:05 UTC 2023 - 4.4K bytes - Viewed (0) -
src/runtime/coro.go
locked := gp.lockedm != 0 if c.mp != nil || locked { if mp != c.mp || mp.lockedInt != c.lockedInt || mp.lockedExt != c.lockedExt { print("coro: got thread ", unsafe.Pointer(mp), ", want ", unsafe.Pointer(c.mp), "\n") print("coro: got lock internal ", mp.lockedInt, ", want ", c.lockedInt, "\n") print("coro: got lock external ", mp.lockedExt, ", want ", c.lockedExt, "\n")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:18 UTC 2024 - 7.4K bytes - Viewed (0) -
maven-plugin-api/src/test/java/org/apache/maven/plugin/descriptor/PluginDescriptorBuilderTest.java
Parameter mp = md.getParameters().get(0); assertEquals("finalName", mp.getName()); assertEquals("jarName", mp.getAlias()); assertEquals("java.lang.String", mp.getType()); assertEquals("java.lang.String", mp.getImplementation()); assertTrue(mp.isEditable()); assertFalse(mp.isRequired());
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Nov 17 15:51:47 UTC 2023 - 5.4K bytes - Viewed (0) -
test/fixedbugs/issue29329.go
} func (ls LineString) Clone() LineString { ps := MultiPoint(ls) return LineString(ps.Clone()) } type MultiPoint []Point func (mp MultiPoint) Clone() MultiPoint { if mp == nil { return nil } points := make([]Point, len(mp)) copy(points, mp) return MultiPoint(points) } func F1() { cases := []struct { threshold float64 length int }{ {0.1, 1118}, {0.5, 257},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 1.9K bytes - Viewed (0)