Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 3,012 for deleteSV (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top