Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for orphaned (0.14 sec)

  1. pkg/kubelet/kubelet_volumes.go

    			}
    		}
    
    		// Rmdir the pod dir, which should be empty if everything above was successful
    		klog.V(3).InfoS("Orphaned pod found, removing", "podUID", uid)
    		if err := syscall.Rmdir(podDir); err != nil {
    			cleanupFailed = true
    			klog.ErrorS(err, "Failed to remove orphaned pod dir", "podUID", uid)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  2. subprojects/core/src/main/java/org/gradle/api/internal/initialization/loadercache/DefaultClassLoaderCache.java

                Map<ClassLoaderId, CachedClassLoader> orphaned = new HashMap<>();
                for (Map.Entry<ClassLoaderId, CachedClassLoader> entry : byId.entrySet()) {
                    if (!bySpec.containsKey(entry.getValue().spec)) {
                        orphaned.put(entry.getKey(), entry.getValue());
                    }
                }
    
                if (!orphaned.isEmpty()) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Dec 11 13:37:56 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  3. pkg/controller/podgc/gc_controller.go

    		}(terminatedPods[i])
    	}
    	wait.Wait()
    }
    
    // gcOrphaned deletes pods that are bound to nodes that don't exist.
    func (gcc *PodGCController) gcOrphaned(ctx context.Context, pods []*v1.Pod, nodes []*v1.Node) {
    	logger := klog.FromContext(ctx)
    	logger.V(4).Info("GC'ing orphaned")
    	existingNodeNames := sets.NewString()
    	for _, node := range nodes {
    		existingNodeNames.Insert(node.Name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. src/os/signal/signal_cgo_test.go

    	//
    	// These steps are complicated by the rules around foreground process
    	// groups. A process group cannot be foreground if it is "orphaned",
    	// unless it masks SIGTTOU.  i.e., to be foreground the process group
    	// must have a parent process group in the same session or mask SIGTTOU
    	// (which we do). An orphaned process group cannot receive
    	// terminal-generated SIGTSTP at all.
    	//
    	// Achieving this requires three processes total:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 20 10:09:15 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. pkg/kubelet/metrics/metrics.go

    	WorkingPodCount = metrics.NewGaugeVec(
    		&metrics.GaugeOpts{
    			Subsystem:      KubeletSubsystem,
    			Name:           WorkingPodCountKey,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 15:13:25 UTC 2024
    - 45.6K bytes
    - Viewed (0)
  6. pkg/kubelet/userns/userns_manager.go

    			continue
    		}
    
    		klog.V(5).InfoS("Clean up orphaned pod user namespace possible allocation", "podUID", podUID)
    		m.releaseWithLock(podUID)
    	}
    
    	// Lets remove any existing allocation for a pod that is not "found".
    	for podUID := range m.usedBy {
    		if allFound.Has(string(podUID)) {
    			continue
    		}
    
    		klog.V(5).InfoS("Clean up orphaned pod user namespace possible allocation", "podUID", podUID)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  7. pkg/kubelet/pod/pod_manager.go

    // fact that the kubelet reports the pod status using the pod full name, the
    // status of the mirror pod always reflects the actual status of the static
    // pod. When a static pod gets deleted, the associated orphaned mirror pod
    // will also be removed.
    type Manager interface {
    	// GetPodByFullName returns the (non-mirror) pod that matches full name, as well as
    	// whether the pod was found.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:00 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go

    		}
    	}
    
    	// Clean up orphaned policies by replacing the old cache of compiled policies
    	// (the map of used policies is updated by `compilePolicy`)
    	for policyKey := range s.compiledPolicies {
    		if _, wasSeen := policiesToBindings[policyKey]; !wasSeen {
    			delete(s.compiledPolicies, policyKey)
    		}
    	}
    
    	// Clean up orphaned param informers
    	for paramKind, info := range s.paramsCRDControllers {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 21 23:07:34 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  9. plugin/pkg/auth/authorizer/node/graph.go

    		g.removeEdgeFromDestinationIndex_locked(edge)
    	}
    }
    
    // must be called under write lock
    // deletes edges from a given vertex type to a specific vertex
    // will delete each orphaned "from" vertex, but will never delete the "to" vertex
    func (g *Graph) deleteEdges_locked(fromType, toType vertexType, toNamespace, toName string) {
    	// get the "to" side
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  10. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java

            if (!allLockedByCurrentThread(locks)) {
                throw new IllegalStateException("Not all of the locks specified are currently held by the current thread.  This could lead to orphaned locks.");
            }
        }
    
        @Override
        public <T> T withReplacedLocks(Collection<? extends ResourceLock> currentLocks, ResourceLock newLock, Factory<T> factory) {
            if (currentLocks.contains(newLock)) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 09 04:43:28 UTC 2024
    - 20.9K bytes
    - Viewed (0)
Back to top