- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 351 for allocable (0.35 sec)
-
pkg/kubelet/cm/container_manager_linux.go
} klog.InfoS("Container manager verified user specified cgroup-root exists", "cgroupRoot", cgroupRoot) // Include the top level cgroup for enforcing node allocatable into cgroup-root. // This way, all sub modules can avoid having to understand the concept of node allocatable. cgroupRoot = NewCgroupName(cgroupRoot, defaultNodeAllocatableCgroupName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters.go
if old, ok := node.Status.Allocatable[k]; !ok || old.Value() != v.Value() { klog.V(2).InfoS("Updated allocatable", "device", k, "allocatable", v.Value()) } node.Status.Allocatable[k] = v } // for every huge page reservation, we need to remove it from allocatable memory for k, v := range node.Status.Capacity { if v1helper.IsHugePageResourceName(k) { allocatableMemory := node.Status.Allocatable[v1.ResourceMemory]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 12:12:04 UTC 2024 - 30.5K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static_test.go
defaultCPUSet: testCase.stDefaultCPUSet, } pod := testCase.pod // allocate for _, container := range append(pod.Spec.InitContainers, pod.Spec.Containers...) { policy.Allocate(st, pod, &container) } if !reflect.DeepEqual(st.defaultCPUSet, testCase.expCSetAfterAlloc) { t.Errorf("StaticPolicy Allocate() error (%v). expected default cpuset %v but got %v",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 40.8K bytes - Viewed (0) -
pkg/registry/core/service/storage/alloc.go
err = svcAllocator.AllocateService(service, parsedIP) } else { err = allocator.Allocate(parsedIP) } } else { err = allocator.Allocate(parsedIP) } if err != nil { el := field.ErrorList{field.Invalid(field.NewPath("spec", "clusterIPs"), service.Spec.ClusterIPs, fmt.Sprintf("failed to allocate IP %v: %v", ip, err))} return allocated, errors.NewInvalid(api.Kind("Service"), service.Name, el) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:05 UTC 2023 - 37.3K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
if maxAttachLimit == 0 { return driverInfoSpec.Allocatable == nil || driverInfoSpec.Allocatable.Count == nil } return driverInfoSpec.Allocatable != nil && driverInfoSpec.Allocatable.Count != nil && int64(*driverInfoSpec.Allocatable.Count) == maxAttachLimit } func (nim *nodeInfoManager) installDriverToCSINode( nodeInfo *storagev1.CSINode,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static.go
} func (p *staticPolicy) Allocate(s state.State, pod *v1.Pod, container *v1.Container) (rerr error) { numCPUs := p.guaranteedCPUs(pod, container) if numCPUs == 0 { // container belongs in the shared pool (nothing to do; use default cpuset) return nil } klog.InfoS("Static policy: Allocate", "pod", klog.KObj(pod), "containerName", container.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 28.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit.go
insufficientResources = append(insufficientResources, InsufficientResource{ ResourceName: v1.ResourceMemory, Reason: "Insufficient memory", Requested: podRequest.Memory, Used: nodeInfo.Requested.Memory, Capacity: nodeInfo.Allocatable.Memory, }) } if podRequest.EphemeralStorage > 0 &&
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 20.2K bytes - Viewed (0) -
pkg/kubelet/cm/node_container_manager_linux_test.go
capacity: tc.capacity, } err := cm.validateNodeAllocatable() if err == nil && tc.invalidConfiguration { t.Fatalf("Expected invalid node allocatable configuration") } else if err != nil && !tc.invalidConfiguration { t.Fatalf("Expected valid node allocatable configuration: %v", err) } } ephemeralStorageEvictionThreshold := resource.MustParse("100Mi") ephemeralStorageTestCases := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 12.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
existingNode.Status.Capacity = make(map[v1.ResourceName]resource.Quantity) } } if existingNode.Status.Allocatable == nil { if initialNode.Status.Allocatable != nil { existingNode.Status.Allocatable = initialNode.Status.Allocatable.DeepCopy() requiresUpdate = true } else { existingNode.Status.Allocatable = make(map[v1.ResourceName]resource.Quantity) } } return requiresUpdate }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
.put(Buffer.class, ByteBuffer.allocate(0)) .put(CharBuffer.class, CharBuffer.allocate(0)) .put(ByteBuffer.class, ByteBuffer.allocate(0)) .put(ShortBuffer.class, ShortBuffer.allocate(0)) .put(IntBuffer.class, IntBuffer.allocate(0)) .put(LongBuffer.class, LongBuffer.allocate(0)) .put(FloatBuffer.class, FloatBuffer.allocate(0))
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 17 16:33:44 UTC 2024 - 21K bytes - Viewed (0)