Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 60 for mp (0.02 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. test/typeparam/pairimp.dir/main.go

    		panic(fmt.Sprintf("unexpected f2 size == %d, want %d", got, want))
    	}
    
    	type mypair struct {
    		Field1 int32
    		Field2 int64
    	}
    	mp := mypair(p)
    	if mp.Field1 != 1 || mp.Field2 != 2 {
    		panic(fmt.Sprintf("mp == %#v, want %#v", mp, mypair{1, 2}))
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 24 02:14:15 UTC 2022
    - 716 bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/kubelet/cm/memorymanager/state/checkpoint.go

    	}
    }
    
    // MarshalCheckpoint returns marshalled checkpoint
    func (mp *MemoryManagerCheckpoint) MarshalCheckpoint() ([]byte, error) {
    	// make sure checksum wasn't set before so it doesn't affect output checksum
    	mp.Checksum = 0
    	mp.Checksum = checksum.New(mp)
    	return json.Marshal(*mp)
    }
    
    // UnmarshalCheckpoint tries to unmarshal passed bytes to checkpoint
    func (mp *MemoryManagerCheckpoint) UnmarshalCheckpoint(blob []byte) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 17 12:58:53 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  10. src/runtime/debuglog_on.go

    // returns false if this fails.
    func putCachedDlogger(l *dlogger) bool {
    	mp := acquirem()
    	if getg() != mp.gsignal && mp.dlogCache == nil {
    		mp.dlogCache = l
    		releasem(mp)
    		return true
    	}
    	releasem(mp)
    	return false
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 28 18:17:57 UTC 2021
    - 1.1K bytes
    - Viewed (0)
Back to top