Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 27 for removeContainers (0.24 sec)

  1. 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)
  2. 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)
  3. 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 (1)
  4. 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)
  5. 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)
  6. 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)
  7. pkg/kubelet/kuberuntime/instrumented_services.go

    	recordError(operation, err)
    	return err
    }
    
    func (in instrumentedRuntimeService) RemoveContainer(ctx context.Context, containerID string) error {
    	const operation = "remove_container"
    	defer recordOperation(operation, time.Now())
    
    	err := in.service.RemoveContainer(ctx, containerID)
    	recordError(operation, err)
    	return err
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 10:46:06 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/cpumanager/cpu_manager_test.go

    		activePods:        func() []*v1.Pod { return nil },
    		podStatusProvider: mockPodStatusProvider{},
    	}
    
    	containerMap.Add("", "", containerID)
    	err := mgr.RemoveContainer(containerID)
    	if err != nil {
    		t.Errorf("CPU Manager RemoveContainer() error. expected error to be nil but got: %v", err)
    	}
    
    	mgr = &manager{
    		policy: &mockPolicy{
    			err: fmt.Errorf("fake error"),
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 42.9K bytes
    - Viewed (0)
  9. pkg/kubelet/kuberuntime/kuberuntime_container.go

    			}
    			// prune all other init containers that match this container name
    			klog.V(4).InfoS("Removing init container", "containerName", status.Name, "containerID", status.ID.ID, "count", count)
    			if err := m.removeContainer(ctx, status.ID.ID); err != nil {
    				utilruntime.HandleError(fmt.Errorf("failed to remove pod init container %q: %v; Skipping pod %q", status.Name, err, format.Pod(pod)))
    				continue
    			}
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  10. platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_7.adoc

            finalizedBy("dockerStop") // dependsOn removeContainer
        }
    
        register("dockerUp") {
            dependsOn("createContainer")
        }
    
        register("dockerStop") {
            dependsOn("removeContainer")
        }
    
        register("createContainer") {
            mustRunAfter("removeContainer")
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 01 15:00:23 UTC 2024
    - 87.7K bytes
    - Viewed (0)
Back to top