Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for mp (0.47 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top