- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 122 for podAdd (0.11 sec)
-
pkg/kubelet/cm/memorymanager/memory_manager.go
for podUID := range assignments { for containerName := range assignments[podUID] { if _, ok := activeContainers[podUID][containerName]; !ok { klog.InfoS("RemoveStaleState removing state", "podUID", podUID, "containerName", containerName) m.policyRemoveContainerByRef(podUID, containerName) } } } m.containerMap.Visit(func(podUID, containerName, containerID string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (1) -
pkg/kubelet/cm/devicemanager/manager.go
defer m.mutex.Unlock() m.pendingAdmissionPod = pod } func (m *ManagerImpl) isContainerAlreadyRunning(podUID, cntName string) bool { cntID, err := m.containerMap.GetContainerID(podUID, cntName) if err != nil { klog.V(4).InfoS("container not found in the initial map, assumed NOT running", "podUID", podUID, "containerName", cntName, "err", err) return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
pkg/volume/util/fsquota/quota_linux.go
delete(podQuotaMap, poduid) delete(podUidMap, poduid) } else { err = removeProjectID(path, projid) podDirCountMap[poduid]-- klog.V(4).Infof("Not clearing quota for pod %s; still %v dirs outstanding", poduid, podDirCountMap[poduid]) } delete(dirPodMap, path) delete(dirQuotaMap, path) delete(supportsQuotasMap, path) clearApplier(path) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 07 08:07:51 UTC 2023 - 14.1K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
} if csiMounter.volumeID == "" { t.Error("mounter volume id not set") } if csiMounter.pod == nil { t.Error("mounter pod not set") } if string(csiMounter.podUID) != string(test.podUID) { t.Error("mounter podUID not set") } csiClient, err := csiMounter.csiClientGetter.Get() if csiClient == nil { t.Errorf("mounter csiClient is nil: %v", err) } if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static.go
} // RemoveContainer call is idempotent func (p *staticPolicy) RemoveContainer(s state.State, podUID string, containerName string) { blocks := s.GetMemoryBlocks(podUID, containerName) if blocks == nil { return } klog.InfoS("RemoveContainer", "podUID", podUID, "containerName", containerName) s.Delete(podUID, containerName) // Mutate machine memory state to update free and reserved memory
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Nov 12 07:34:55 UTC 2023 - 34K bytes - Viewed (0) -
pkg/volume/portworx/portworx.go
mounter mount.Interface) (volume.Unmounter, error) { return &portworxVolumeUnmounter{ &portworxVolume{ podUID: podUID, volName: volName, manager: manager, mounter: mounter, plugin: plugin, MetricsProvider: volume.NewMetricsStatFS(getPath(podUID, volName, plugin.host)), }}, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
} } func (m *manager) getWorker(podUID types.UID, containerName string, probeType probeType) (*worker, bool) { m.workerLock.RLock() defer m.workerLock.RUnlock() worker, ok := m.workers[probeKey{podUID, containerName, probeType}] return worker, ok } // Called by the worker after exiting. func (m *manager) removeWorker(podUID types.UID, containerName string, probeType probeType) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
security/pkg/server/ca/node_auth_test.go
PodName: "ztunnel-a", PodNamespace: "istio-system", PodUID: "12345", PodServiceAccount: "ztunnel", } ztunnelPod := pod{ name: ztunnelCaller.PodName, namespace: ztunnelCaller.PodNamespace, account: ztunnelCaller.PodServiceAccount, uid: ztunnelCaller.PodUID, node: "zt-node", } podSameNode := pod{ name: "pod-a", namespace: "ns-a",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
} func (m *manager) SetContainerReadiness(podUID types.UID, containerID kubecontainer.ContainerID, ready bool) { m.podStatusesLock.Lock() defer m.podStatusesLock.Unlock() pod, ok := m.podManager.GetPodByUID(podUID) if !ok { klog.V(4).InfoS("Pod has been deleted, no need to update readiness", "podUID", string(podUID)) return } oldStatus, found := m.podStatuses[pod.UID]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
pkg/volume/downwardapi/downwardapi.go
}, nil } func (plugin *downwardAPIPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return &downwardAPIVolumeUnmounter{ &downwardAPIVolume{ volName: volName, podUID: podUID, plugin: plugin, MetricsProvider: volume.NewCachedMetrics(volume.NewMetricsDu(getPath(podUID, volName, plugin.host))), }, }, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10.4K bytes - Viewed (0)