- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 672 for fopacity (0.26 sec)
-
pkg/scheduler/framework/plugins/noderesources/least_allocated_test.go
// Node2 Score: (0 + 50) / 2 = 25 name: "requested resources exceed node capacity", requestedPod: st.MakePod().Req(map[v1.ResourceName]string{"cpu": "3000", "memory": "0"}).Obj(), nodes: []*v1.Node{ st.MakeNode().Name("node1").Capacity(map[v1.ResourceName]string{"cpu": "4000", "memory": "10000"}).Obj(), st.MakeNode().Name("node2").Capacity(map[v1.ResourceName]string{"cpu": "4000", "memory": "10000"}).Obj(), },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 18.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
newCache := make([]*watchCacheEvent, capacity) if capacity < w.capacity { // adjust startIndex if cache capacity shrink. w.startIndex = w.endIndex - capacity } for i := w.startIndex; i < w.endIndex; i++ { newCache[i%capacity] = w.cache[i%w.capacity] } w.cache = newCache metrics.RecordsWatchCacheCapacityChange(w.groupResource.String(), w.capacity, capacity) w.capacity = capacity }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
src/runtime/mgclimit_test.go
// CPU resources now. l.ResetCapacity(advance(0), procs-10) if l.Fill() != l.Capacity() { t.Errorf("failed lower fill to new capacity %d, got fill %d", l.Capacity(), l.Fill()) } if !l.Limiting() { t.Errorf("limiter is disabled after resetting capacity lower") } if expect := uint64((CapacityPerProc/2 + 6*time.Millisecond) * procs); l.Overflow() != expect+baseOverflow {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 13 16:02:20 UTC 2022 - 9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/scorer.go
rawScoringFunction := helper.BuildBrokenLinearFunction(scoringFunctionShape) f := func(requested, capacity int64) int64 { if capacity == 0 || requested > capacity { return rawScoringFunction(maxUtilization) } return rawScoringFunction(requested * maxUtilization / capacity) } return func(classResources classResourceMap) int64 { var nodeScore int64
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 13 11:08:45 UTC 2021 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go
// To preserve behavior of tests that assume a given capacity, // resize it to th expected size. wc.capacity = capacity wc.cache = make([]*watchCacheEvent, capacity) wc.lowerBoundCapacity = min(capacity, defaultLowerBoundCapacity) wc.upperBoundCapacity = max(capacity, defaultUpperBoundCapacity) return wc } type immediateTickerFactory struct{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/ctrlz/assets/static/css/all.css
border: 0; position: absolute; top: 3px; right: 1.3em; z-index: 5 } button.copy-hide { transition: opacity .4s ease-in-out; opacity: 0 } button.copy-show { transition: opacity 1.2s ease-in-out; opacity: 1 } p { font-size: 1rem; font-weight: 300; line-height: 1.5; margin: .25em 0 } @media (min-width: 768px) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 17.1K bytes - Viewed (0) -
pkg/volume/util/fs/fs_windows_test.go
t.Fatalf("TestInfo failed: %s", err.Error()) } availablebytes, capacity, usage, inodesTotal, inodesFree, inodeUsage, err = Info(tmpfile1.Name()) validateInfo(t, availablebytes, capacity, usage, inodesTotal, inodeUsage, inodesFree) } func validateInfo(t *testing.T, availablebytes int64, capacity int64, usage int64, inodesTotal int64, inodeUsage int64, inodesFree int64) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux_test.go
}, { name: "capacity property does not have ephemeral-storage", cm: &containerManagerImpl{ cadvisorInterface: mockCadvisor, capacity: v1.ResourceList{}, }, expectedResourceQuantity: resource.NewQuantity(ephemeralStorageFromCadvisor, resource.BinarySI), expectedNoEphemeralStorage: false, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 9.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go
eventsAddedToWatchcache: capacity + bufferSize, intervalStartIndex: 0, }, { name: "watchCache over propagated, eventsAddedToWatchcache > capacity, intervalStartIndex at some offset", eventsAddedToWatchcache: capacity + bufferSize, intervalStartIndex: 5, }, } for _, c := range cases { t.Run(c.name, func(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 11.6K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
} /** * Creates an {@code MonitorBasedArrayBlockingQueue} with the given (fixed) capacity and default * access policy. * * @param capacity the capacity of this queue * @throws IllegalArgumentException if {@code capacity} is less than 1 */ public MonitorBasedArrayBlockingQueue(int capacity) { this(capacity, false); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0)