- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 218 for accounting (0.35 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go
// goroutines (proportional to the number of watchers) that are all // resumed at once, as a starting point we assume that each such goroutine // is taking 1/Nth of a seat for M milliseconds. // We allow the accounting of that work in P&F to be reshaped into another // rectangle of equal area for practical reasons. var finalSeats uint64 var additionalLatency time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 6K bytes - Viewed (0) -
src/net/dnsconfig_unix_test.go
if shortestSuffix == 0 || len(suffix) < shortestSuffix { shortestSuffix = len(suffix) } } // Test a name that will be maximally long when prefixing the shortest // suffix (accounting for the intervening dot). longName := longDomain[len(longDomain)-254+1+shortestSuffix:] if longName[0] == '.' || longName[1] == '.' { longName = "aa." + longName[3:] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 03 17:41:32 UTC 2022 - 7.1K bytes - Viewed (0) -
src/vendor/golang.org/x/text/unicode/norm/composition.go
func (rb *reorderBuffer) insertDecomposed(dcomp []byte) insertErr { rb.tmpBytes.setBytes(dcomp) // As the streamSafe accounting already handles the counting for modifiers, // we don't have to call next. However, we do need to keep the accounting // intact when flushing the buffer. for i := 0; i < len(dcomp); { info := rb.f.info(rb.tmpBytes, i)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 19:27:51 UTC 2019 - 14.1K bytes - Viewed (0) -
src/runtime/cgocall.go
// foreign code. // // The call to asmcgocall is guaranteed not to // grow the stack and does not allocate memory, // so it is safe to call while "in a system call", outside // the $GOMAXPROCS accounting. // // fn may call back into Go code, in which case we'll exit the // "system call", run the Go code (which may grow the stack), // and then re-enter the "system call" reusing the PC and SP
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:47 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_assignment.go
// went wrong in our accounting and we should error out. if acc.numCPUsNeeded > 0 { return cpuset.New(), fmt.Errorf("accounting error, not enough CPUs allocated, remaining: %v", acc.numCPUsNeeded) } // Likewise, if we have allocated too many CPUs at this point, then something // went wrong in our accounting and we should error out. if acc.numCPUsNeeded < 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 25 23:56:21 UTC 2024 - 36.3K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
ssc.addPod(logger, obj) }, // lookup current and old statefulset if labels changed UpdateFunc: func(oldObj, newObj interface{}) { ssc.updatePod(logger, oldObj, newObj) }, // lookup statefulset accounting for deletion tombstones DeleteFunc: func(obj interface{}) { ssc.deletePod(logger, obj) }, }) ssc.podLister = podInformer.Lister() ssc.podListerSynced = podInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
src/runtime/debuglog.go
} } } // If that failed, allocate a new logger. if l == nil { // Use sysAllocOS instead of sysAlloc because we want to interfere // with the runtime as little as possible, and sysAlloc updates accounting. l = (*dlogger)(sysAllocOS(unsafe.Sizeof(dlogger{}))) if l == nil { throw("failed to allocate debug log") } l.w.r.data = &l.w.data l.owned.Store(1) // Prepend to allDloggers list.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 15:10:48 UTC 2024 - 18.3K bytes - Viewed (0) -
pkg/volume/util/fsquota/common/quota_common_linux_impl.go
if err != nil { return false, err } if qType == FSQuotaEnforcing { return strings.Contains(data, "Enforcement: ON"), nil } return strings.Contains(data, "Accounting: ON"), nil } func isFilesystemOfType(mountpoint string, backingDev string, typeMagic int64) bool { var buf syscall.Statfs_t err := syscall.Statfs(mountpoint, &buf) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 9.1K bytes - Viewed (0) -
pkg/volume/configmap/configmap.go
return volume.Spec{ // This should be on a tmpfs instead of the local disk; the problem is // charging the memory for the tmpfs to the right cgroup. We should make // this a tmpfs when we can do the accounting correctly. Volume: &v1.Volume{VolumeSource: v1.VolumeSource{EmptyDir: &v1.EmptyDirVolumeSource{}}}, } } func (b *configMapVolumeMounter) SetUp(mounterArgs volume.MounterArgs) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight_test.go
defer server.Close() ctx, cancel := context.WithCancel(context.Background()) defer cancel() StartMaxInFlightWatermarkMaintenance(ctx.Done()) // These should hang, but not affect accounting. use a query param match for i := 0; i < AllowedNonMutatingInflightRequestsNo; i++ { // These should hang waiting on block... go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 10.2K bytes - Viewed (0)