Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for mp (0.23 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. staging/src/k8s.io/apiserver/pkg/cel/types_test.go

    	}
    }
    
    func TestTypes_MapType(t *testing.T) {
    	mp := NewMapType(StringType, IntType, -1)
    	if !mp.IsMap() {
    		t.Error("map type not identifiable as map")
    	}
    	if mp.TypeName() != "map" {
    		t.Errorf("got %s, wanted map", mp.TypeName())
    	}
    	if mp.DefaultValue() == nil {
    		t.Error("got nil zero value for map type")
    	}
    	if mp.KeyType.TypeName() != "string" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 10 22:05:55 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  3. src/runtime/os_openbsd_libc.go

    func mstart_stub()
    
    // May run with m.p==nil, so write barriers are not allowed.
    //
    //go:nowritebarrierrec
    func newosproc(mp *m) {
    	if false {
    		print("newosproc m=", mp, " g=", mp.g0, " id=", mp.id, " ostk=", &mp, "\n")
    	}
    
    	// Initialize an attribute object.
    	var attr pthreadattr
    	if err := pthread_attr_init(&attr); err != 0 {
    		writeErrStr(failthreadcreate)
    		exit(1)
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Nov 10 20:44:45 UTC 2022
    - 1.5K bytes
    - Viewed (0)
  4. 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)
  5. src/runtime/os_solaris.go

    	// Leave caller's PC/SP 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
    		// all three values to be non-zero, it will use them
    		mp.libcallsp = getcallersp()
    	} else {
    		mp = nil // See comment in sys_darwin.go:libcCall
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 06 18:49:01 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. src/runtime/os_openbsd_syscall.go

    //
    //go:nowritebarrier
    func newosproc(mp *m) {
    	stk := unsafe.Pointer(mp.g0.stack.hi)
    	if false {
    		print("newosproc stk=", stk, " m=", mp, " g=", mp.g0, " id=", mp.id, " ostk=", &mp, "\n")
    	}
    
    	// Stack pointer must point inside stack area (as marked with MAP_STACK),
    	// rather than at the top of it.
    	param := tforkt{
    		tf_tcb:   unsafe.Pointer(&mp.tls[0]),
    		tf_tid:   nil, // minit will record tid
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Nov 10 20:44:45 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  9. 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)
  10. src/runtime/print.go

    func printlock() {
    	mp := getg().m
    	mp.locks++ // do not reschedule between printlock++ and lock(&debuglock).
    	mp.printlock++
    	if mp.printlock == 1 {
    		lock(&debuglock)
    	}
    	mp.locks-- // now we know debuglock is held and holding up mp.locks for us.
    }
    
    func printunlock() {
    	mp := getg().m
    	mp.printlock--
    	if mp.printlock == 0 {
    		unlock(&debuglock)
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jan 20 03:27:26 UTC 2023
    - 5.9K bytes
    - Viewed (0)
Back to top