- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 3,012 for deleteSV (0.17 sec)
-
pkg/kubelet/cm/memorymanager/state/state_mem.go
s.assignments = assignments.Clone() } // Delete deletes corresponding Blocks from ContainerMemoryAssignments func (s *stateMemory) Delete(podUID string, containerName string) { s.Lock() defer s.Unlock() if _, ok := s.assignments[podUID]; !ok { return } delete(s.assignments[podUID], containerName) if len(s.assignments[podUID]) == 0 { delete(s.assignments, podUID) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 15 19:51:19 UTC 2021 - 3.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
} } } return pmap } // deleteIP returns true if the pod and ip are really deleted. func (pc *PodCache) deleteIP(ip string, podKey types.NamespacedName) bool { pc.Lock() defer pc.Unlock() if pc.podsByIP[ip].Contains(podKey) { sets.DeleteCleanupLast(pc.podsByIP, ip, podKey) delete(pc.IPByPods, podKey) return true } return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
hack/testdata/CRD/foo-deleted-subfield.yaml
Nikhita Raghunath <******@****.***> 1506872372 +0530
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Oct 01 15:43:24 UTC 2017 - 176 bytes - Viewed (0) -
pkg/controller/namespace/deletion/namespaced_resources_deleter.go
discoverResourcesFn func() ([]*metav1.APIResourceList, error) // The finalizer token that should be removed from the namespace // when all resources in that namespace have been deleted. finalizerToken v1.FinalizerName } // Delete deletes all resources in the given namespace. // Before deleting resources: // - It ensures that deletion timestamp is set on the // namespace (does nothing if deletion timestamp is missing).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 07:34:23 UTC 2023 - 25.2K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
deleter, err := plugin.NewDeleter(logger, spec) if err != nil { // Cannot create deleter return pluginName, false, fmt.Errorf("failed to create deleter for volume %q: %w", volume.Name, err) } opComplete := util.OperationCompleteHook(pluginName, "volume_delete") err = deleter.Delete() opComplete(volumetypes.CompleteFuncParam{Err: &err}) if err != nil { // Deleter failed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
cmd/metacache-manager.go
m.buckets[bucket] = b return b } // deleteBucketCache will delete the bucket cache if it exists. func (m *metacacheManager) deleteBucketCache(bucket string) { m.init.Do(m.initManager) m.mu.Lock() b, ok := m.buckets[bucket] if !ok { m.mu.Unlock() return } delete(m.buckets, bucket) m.mu.Unlock() // Since deletes may take some time we try to do it without // holding lock to m all the time.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 5.2K bytes - Viewed (0) -
platforms/jvm/language-java/src/main/java/org/gradle/api/internal/tasks/compile/incremental/transaction/CompileTransaction.java
Set<File> ensureEmptyDirectories = new HashSet<>(); deleter.ensureEmptyDirectory(stashDirectory); ensureEmptyDirectories.add(stashDirectory); deleter.ensureEmptyDirectory(backupDirectory); ensureEmptyDirectories.add(backupDirectory); // Delete any other file or directory try (Stream<Path> dirStream = Files.list(tempDir.toPath())) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 13.3K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client.go
// In all cases delete the recycler pod and log its result. klog.V(2).Infof("deleting recycler pod %s/%s", pod.Namespace, pod.Name) deleteErr := recyclerClient.DeletePod(pod.Name, pod.Namespace) if deleteErr != nil { klog.Errorf("failed to delete recycler pod %s/%s: %v", pod.Namespace, pod.Name, err) } // Returning recycler error is preferred, the pod will be deleted again on // the next retry. if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.5K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/sync/sync.go
return nil } // deleteOp handles deletion of a node. type deleteOp struct { node *v1.Node } func (op *deleteOp) String() string { if op.node == nil { return fmt.Sprintf("deleteOp(nil)") } return fmt.Sprintf("deleteOp(%q,%v)", op.node.Name, op.node.Spec.PodCIDR) } func (op *deleteOp) run(logger klog.Logger, sync *NodeSync) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 07:50:01 UTC 2023 - 12.6K bytes - Viewed (0) -
pkg/kubelet/pod/mirror_client.go
return nil } } return err } // DeleteMirrorPod deletes a mirror pod. // It takes the full name of the pod and optionally a UID. If the UID // is non-nil, the pod is deleted only if its UID matches the supplied UID. // It returns whether the pod was actually deleted, and any error returned // while parsing the name of the pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 21 11:38:40 UTC 2021 - 5.5K bytes - Viewed (0)