Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 765 for allocable (0.23 sec)

  1. pkg/scheduler/framework/plugins/noderesources/most_allocated.go

    func mostResourceScorer(resources []config.ResourceSpec) func(requested, allocable []int64) int64 {
    	return func(requested, allocable []int64) int64 {
    		var nodeScore, weightSum int64
    		for i := range requested {
    			if allocable[i] == 0 {
    				continue
    			}
    			weight := resources[i].Weight
    			resourceScore := mostRequestedScore(requested[i], allocable[i])
    			nodeScore += resourceScore * weight
    			weightSum += weight
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Dec 21 15:23:47 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/noderesources/requested_to_capacity_ratio.go

    		}
    
    		return rawScoringFunction(requested * maxUtilization / capacity)
    	}
    	return func(requested, allocable []int64) int64 {
    		var nodeScore, weightSum int64
    		for i := range requested {
    			if allocable[i] == 0 {
    				continue
    			}
    			weight := resources[i].Weight
    			resourceScore := resourceScoringFunction(requested[i], allocable[i])
    			if resourceScore > 0 {
    				nodeScore += resourceScore * weight
    				weightSum += weight
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Dec 21 15:23:47 UTC 2022
    - 2.6K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/least_allocated.go

    func leastResourceScorer(resources []config.ResourceSpec) func([]int64, []int64) int64 {
    	return func(requested, allocable []int64) int64 {
    		var nodeScore, weightSum int64
    		for i := range requested {
    			if allocable[i] == 0 {
    				continue
    			}
    			weight := resources[i].Weight
    			resourceScore := leastRequestedScore(requested[i], allocable[i])
    			nodeScore += resourceScore * weight
    			weightSum += weight
    		}
    		if weightSum == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Mar 12 01:50:09 UTC 2023
    - 2K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/noderesources/balanced_allocation.go

    			resources:    args.Resources,
    		},
    	}, nil
    }
    
    func balancedResourceScorer(requested, allocable []int64) int64 {
    	var resourceToFractions []float64
    	var totalFraction float64
    	for i := range requested {
    		if allocable[i] == 0 {
    			continue
    		}
    		fraction := float64(requested[i]) / float64(allocable[i])
    		if fraction > 1 {
    			fraction = 1
    		}
    		totalFraction += fraction
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/noderesources/resource_allocation.go

    	case v1.ResourceCPU:
    		return nodeInfo.Allocatable.MilliCPU, (requested.MilliCPU + podRequest)
    	case v1.ResourceMemory:
    		return nodeInfo.Allocatable.Memory, (requested.Memory + podRequest)
    	case v1.ResourceEphemeralStorage:
    		return nodeInfo.Allocatable.EphemeralStorage, (nodeInfo.Requested.EphemeralStorage + podRequest)
    	default:
    		if _, exists := nodeInfo.Allocatable.ScalarResources[resource]; exists {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 20 14:53:43 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  6. src/debug/elf/file.go

    		s.Size = binary.BigEndian.Uint64(b[4:12])
    		zrd = zlib.NewReader
    
    	} else if s.Flags&SHF_ALLOC != 0 {
    		return errorReader{&FormatError{int64(s.Offset),
    			"SHF_COMPRESSED applies only to non-allocable sections", s.compressionType}}
    	}
    
    	switch s.compressionType {
    	case COMPRESS_ZLIB:
    		zrd = zlib.NewReader
    	case COMPRESS_ZSTD:
    		zrd = func(r io.Reader) (io.ReadCloser, error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 23 16:49:58 UTC 2024
    - 43.1K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/devicemanager/manager_test.go

    				t.Fatalf("timeout while waiting for manager update")
    			}
    			capacity, allocatable, _ := m.GetCapacity()
    			resourceCapacity := capacity[v1.ResourceName(testResourceName)]
    			resourceAllocatable := allocatable[v1.ResourceName(testResourceName)]
    			require.Equal(t, resourceCapacity.Value(), resourceAllocatable.Value(), "capacity should equal to allocatable")
    			require.Equal(t, int64(2), resourceAllocatable.Value(), "Devices are not updated.")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/memorymanager/fake_memory_manager.go

    }
    
    func (m *fakeManager) State() state.Reader {
    	return m.state
    }
    
    // GetAllocatableMemory returns the amount of allocatable memory for each NUMA node
    func (m *fakeManager) GetAllocatableMemory() []state.Block {
    	klog.InfoS("Get Allocatable Memory")
    	return []state.Block{}
    }
    
    // GetMemory returns the memory allocated by a container from NUMA nodes
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/memorymanager/memory_manager.go

    	AddContainer(p *v1.Pod, c *v1.Container, containerID string)
    
    	// Allocate is called to pre-allocate memory resources during Pod admission.
    	// This must be called at some point prior to the AddContainer() call for a container, e.g. at pod admission time.
    	Allocate(pod *v1.Pod, container *v1.Container) error
    
    	// RemoveContainer is called after Kubelet decides to kill or delete a
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/memorymanager/memory_manager_test.go

    	testCases := []struct {
    		description                string
    		nodeAllocatableReservation v1.ResourceList
    		machineInfo                *cadvisorapi.MachineInfo
    		systemReservedMemory       []kubeletconfig.MemoryReservation
    		expectedError              string
    	}{
    		{
    			"Node Allocatable not set, reserved not set",
    			v1.ResourceList{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 05 13:01:40 UTC 2023
    - 70.2K bytes
    - Viewed (0)
Back to top