Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 106 for mp (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  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/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)
  6. 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)
  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. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/suppliers/DynamicRevisionRemoteResolveWithMetadataSupplierIntegrationTest.groovy

              if (project.gradle.startParameter.offline) {
                 MP.filename = 'status-offline.txt'
              }
              class MP implements ComponentMetadataSupplier {
                final RepositoryResourceAccessor repositoryResourceAccessor
    
                @Inject
                MP(RepositoryResourceAccessor accessor) { repositoryResourceAccessor = accessor }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 01 11:46:17 UTC 2024
    - 49K 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/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)
Back to top