Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 31 for removeContainers (0.21 sec)

  1. subprojects/core/src/integTest/groovy/org/gradle/api/FinalizerTaskIntegrationTest.groovy

                    finalizedBy 'dockerStop' // dependsOn removeContainer
                }
    
                task dockerUp(type: BreakingTask) {
                    dependsOn 'createContainer'
                }
    
                task dockerStop(type: BreakingTask) {
                    dependsOn 'removeContainer'
                }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri May 17 13:27:33 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cpumanager/fake_cpu_manager.go

    	klog.InfoS("AddContainer", "pod", klog.KObj(pod), "containerName", container.Name, "containerID", containerID)
    }
    
    func (m *fakeManager) RemoveContainer(containerID string) error {
    	klog.InfoS("RemoveContainer", "containerID", containerID)
    	return nil
    }
    
    func (m *fakeManager) GetTopologyHints(pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cpumanager/policy_none_test.go

    	}
    
    	testPod := makePod("fakePod", "fakeContainer", "1000m", "1000m")
    
    	container := &testPod.Spec.Containers[0]
    	err := policy.RemoveContainer(st, string(testPod.UID), container.Name)
    	if err != nil {
    		t.Errorf("NonePolicy RemoveContainer() error. expected no error but got %v", err)
    	}
    }
    
    func TestNonePolicyGetAllocatableCPUs(t *testing.T) {
    	// any random topology is fine
    
    	var cpuIDs []int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/cpumanager/cpu_manager.go

    	AddContainer(p *v1.Pod, c *v1.Container, containerID string)
    
    	// RemoveContainer is called after Kubelet decides to kill or delete a
    	// container. After this call, the CPU manager stops trying to reconcile
    	// that container and any CPUs dedicated to the container are freed.
    	RemoveContainer(containerID string) error
    
    	// State returns a read-only interface to the internal CPU manager state.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 19.9K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/memorymanager/memory_manager.go

    	Allocate(pod *v1.Pod, container *v1.Container) error
    
    	// RemoveContainer is called after Kubelet decides to kill or delete a
    	// container. After this call, any memory allocated to the container is freed.
    	RemoveContainer(containerID string) error
    
    	// State returns a read-only interface to the internal memory manager state.
    	State() state.Reader
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/topologymanager/fake_topology_manager_test.go

    		},
    		{
    			name:        "Case2",
    			containerID: "Busy_Box",
    			podUID:      "b3ee37fc-39a5-11e9-bcb1-a4bf01040474",
    		},
    	}
    	fm := fakeManager{}
    	for _, tc := range testCases {
    		err := fm.RemoveContainer(tc.containerID)
    		if err != nil {
    			t.Errorf("Expected error to be nil but got: %v", err)
    		}
    
    	}
    
    }
    
    func TestFakeAdmit(t *testing.T) {
    	tcases := []struct {
    		name     string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 10 11:44:15 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/cpumanager/policy_none.go

    	klog.InfoS("None policy: Start")
    	return nil
    }
    
    func (p *nonePolicy) Allocate(s state.State, pod *v1.Pod, container *v1.Container) error {
    	return nil
    }
    
    func (p *nonePolicy) RemoveContainer(s state.State, podUID string, containerName string) error {
    	return nil
    }
    
    func (p *nonePolicy) GetTopologyHints(s state.State, pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint {
    	return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/topologymanager/scope_test.go

    		scope.podTopologyHints[string(tc.podUID)][tc.name] = TopologyHint{}
    		len1 = len(scope.podMap)
    		lenHints1 = len(scope.podTopologyHints)
    		err := scope.RemoveContainer(tc.containerID)
    		len2 = len(scope.podMap)
    		lenHints2 = len(scope.podTopologyHints)
    		if err != nil {
    			t.Errorf("Expected error to be nil but got: %v", err)
    		}
    		if len1-len2 != 1 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 10 11:44:15 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/internal_container_lifecycle.go

    	}
    
    	i.topologyManager.AddContainer(pod, container, containerID)
    
    	return nil
    }
    
    func (i *internalContainerLifecycleImpl) PostStopContainer(containerID string) error {
    	return i.topologyManager.RemoveContainer(containerID)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 10 06:43:12 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/cpumanager/policy_static_test.go

    				testCase.description, testCase.expCSetAfterAlloc, st.defaultCPUSet)
    		}
    
    		// remove
    		policy.RemoveContainer(st, string(pod.UID), testCase.containerName)
    
    		if !reflect.DeepEqual(st.defaultCPUSet, testCase.expCSetAfterRemove) {
    			t.Errorf("StaticPolicy RemoveContainer() error (%v). expected default cpuset %v but got %v",
    				testCase.description, testCase.expCSetAfterRemove, st.defaultCPUSet)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 40.8K bytes
    - Viewed (0)
Back to top