Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for SetMachineState (0.22 sec)

  1. pkg/kubelet/cm/memorymanager/state/state_checkpoint.go

    	sc.RLock()
    	defer sc.RUnlock()
    
    	return sc.cache.GetMemoryAssignments()
    }
    
    // SetMachineState stores NUMANodeMap in State
    func (sc *stateCheckpoint) SetMachineState(memoryMap NUMANodeMap) {
    	sc.Lock()
    	defer sc.Unlock()
    
    	sc.cache.SetMachineState(memoryMap)
    	err := sc.storeState()
    	if err != nil {
    		klog.InfoS("Store state to checkpoint error", "err", err)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 08 16:05:48 UTC 2022
    - 5.3K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/memorymanager/state/state_mem.go

    func (s *stateMemory) GetMemoryAssignments() ContainerMemoryAssignments {
    	s.RLock()
    	defer s.RUnlock()
    
    	return s.assignments.Clone()
    }
    
    // SetMachineState stores NUMANodeMap in State
    func (s *stateMemory) SetMachineState(nodeMap NUMANodeMap) {
    	s.Lock()
    	defer s.Unlock()
    
    	s.machineState = nodeMap.Clone()
    	klog.InfoS("Updated machine memory state")
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 15 19:51:19 UTC 2021
    - 3.2K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/memorymanager/state/state.go

    	// GetMemoryAssignments returns ContainerMemoryAssignments
    	GetMemoryAssignments() ContainerMemoryAssignments
    }
    
    type writer interface {
    	// SetMachineState stores NUMANodeMap in State
    	SetMachineState(memoryMap NUMANodeMap)
    	// SetMemoryBlocks stores memory assignments of a container
    	SetMemoryBlocks(podUID string, containerName string, blocks []Block)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 08 23:10:00 UTC 2021
    - 4.4K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/memorymanager/state/state_checkpoint_test.go

    	assert.NoError(t, err, "could not create testing checkpointState instance")
    
    	// set values of cs1 instance so they are stored in checkpoint and can be read by cs2
    	cs1.SetMachineState(expectedState.machineState)
    	cs1.SetMemoryAssignments(expectedState.assignments)
    
    	// restore checkpoint with previously stored values
    	cs2, err := NewCheckpointState(testingDir, testingCheckpoint, "static")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 30 03:35:26 UTC 2022
    - 10.6K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/memorymanager/memory_manager_test.go

    				podStatusProvider: mockPodStatusProvider{},
    			}
    			mgr.sourcesReady = &sourcesReadyStub{}
    			mgr.state.SetMemoryAssignments(testCase.assignments)
    			mgr.state.SetMachineState(testCase.machineState)
    
    			mgr.removeStaleState()
    
    			if !areContainerMemoryAssignmentsEqual(t, mgr.state.GetMemoryAssignments(), testCase.expectedAssignments) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 05 13:01:40 UTC 2023
    - 70.2K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/memorymanager/policy_static.go

    		}
    
    		// Update nodes memory state
    		p.updateMachineState(machineState, maskBits, resourceName, requestedSize)
    	}
    
    	p.updatePodReusableMemory(pod, container, containerBlocks)
    
    	s.SetMachineState(machineState)
    	s.SetMemoryBlocks(podUID, container.Name, containerBlocks)
    
    	// update init containers memory blocks to reflect the fact that we re-used init containers memory
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Nov 12 07:34:55 UTC 2023
    - 34K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/memorymanager/policy_static_test.go

    	if err != nil {
    		return nil, nil, err
    	}
    	if initContainersReusableMemory != nil {
    		p.(*staticPolicy).initContainersReusableMemory = initContainersReusableMemory
    	}
    	s := state.NewMemoryState()
    	s.SetMachineState(testCase.machineState)
    	s.SetMemoryAssignments(testCase.assignments)
    	return p, s, nil
    }
    
    func newNUMAAffinity(bits ...int) bitmask.BitMask {
    	affinity, err := bitmask.NewBitMask(bits...)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 05:49:15 UTC 2023
    - 100.4K bytes
    - Viewed (0)
Back to top