Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 212 for xremove (0.22 sec)

  1. pkg/scheduler/internal/queue/scheduling_queue.go

    		return
    	}
    	delete(p.inFlightPods, pod)
    
    	// Remove the pod from the list.
    	p.inFlightEvents.Remove(inFlightPod)
    
    	// Remove events which are only referred to by this Pod
    	// so that the inFlightEvents list doesn't grow infinitely.
    	// If the pod was at the head of the list, then all
    	// events between it and the next pod are no longer needed
    	// and can be removed.
    	for {
    		e := p.inFlightEvents.Front()
    		if e == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  2. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    		}
    	case v1.ConditionTrue:
    		removed, err := nc.markNodeAsReachable(ctx, node)
    		if err != nil {
    			logger.Error(nil, "Failed to remove taints from node. Will retry in next iteration", "node", klog.KObj(node))
    		}
    		if removed {
    			logger.V(2).Info("Node is healthy again, removing all taints", "node", klog.KObj(node))
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  3. cmd/iam-store.go

    	if err == errNoSuchGroup {
    		// group does not exist - so remove from memory.
    		cache.removeGroupFromMembershipsMap(group)
    		delete(cache.iamGroupsMap, group)
    		cache.iamGroupPolicyMap.Delete(group)
    
    		cache.updatedAt = time.Now()
    		return nil
    	}
    
    	gi := cache.iamGroupsMap[group]
    
    	// Updating the group memberships cache happens in two steps:
    	//
    	// 1. Remove the group from each user's list of memberships.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/route/route_test.go

    								Remove: []string{"x-route-req-remove"},
    							},
    							Response: &networking.Headers_HeaderOperations{
    								Set:    map[string]string{"x-route-resp-set": "v1"},
    								Add:    map[string]string{"x-route-resp-add": "v2"},
    								Remove: []string{"x-route-resp-remove"},
    							},
    						},
    						Weight: 100,
    					},
    				},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 88.1K bytes
    - Viewed (0)
  5. cluster/gce/windows/k8s-node-setup.psm1

        # removed when the HNS network is created:
        # https://github.com/Microsoft/hcsshim/issues/299#issuecomment-425491610.
        # The behavior here is very unpredictable: the route may only be removed
        # after some delay, or it may appear to be removed then you'll add it back
        # but then it will be removed once again. So, we first wait a long
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 21:13:22 UTC 2024
    - 88.3K bytes
    - Viewed (0)
  6. cmd/erasure-healing_test.go

    		t.Fatal(err)
    	}
    
    	// Remove the object - to simulate the case where the disk was down when the object
    	// was created.
    	err = removeAll(pathJoin(disk.String(), bucket, object))
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Checking abandoned parts should do nothing
    	err = er.checkAbandonedParts(ctx, bucket, object, madmin.HealOpts{ScanMode: madmin.HealNormalScan, Remove: true})
    	if err != nil {
    		t.Fatal(err)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    	}
    
    	// ENOSPC is a valid error from rename(); remove instead of rename in that case
    	if errors.Is(err, errDiskFull) || isSysErrNoSpace(err) {
    		if recursive {
    			err = removeAll(filePath)
    		} else {
    			err = Remove(filePath)
    		}
    		return err // Avoid the immediate purge since not needed
    	}
    
    	if err != nil {
    		return err
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (2)
  8. src/crypto/tls/common.go

    // Put adds the provided (sessionKey, cs) pair to the cache. If cs is nil, the entry
    // corresponding to sessionKey is removed from the cache instead.
    func (c *lruSessionCache) Put(sessionKey string, cs *ClientSessionState) {
    	c.Lock()
    	defer c.Unlock()
    
    	if elem, ok := c.m[sessionKey]; ok {
    		if cs == nil {
    			c.q.Remove(elem)
    			delete(c.m, sessionKey)
    		} else {
    			entry := elem.Value.(*lruSessionCacheEntry)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 59.1K bytes
    - Viewed (0)
  9. platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/configurations/DefaultConfigurationSpec.groovy

            when:
            masterParent2Parent2.artifacts.remove masterParent2Parent2.artifacts.toList().first()
    
            then:
            allArtifacts.size() == 5
            removed == ["p2p2-1"]
    
            when:
            removed.clear()
            masterParent1.extendsFrom = []
    
            then:
            allArtifacts.size() == 3
            removed == ["p1p1-1", "p1p2-1"]
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 23 17:30:13 UTC 2024
    - 64.8K bytes
    - Viewed (0)
  10. cmd/iam.go

    			}
    
    			// Policies mapped to the DN's are the same, so we remove the extra
    			// ones from the map.
    			for i := 1; i < len(origKeys); i++ {
    				delete(policyMap, origKeys[i])
    
    				// Remove the mapping from storage by setting the policy to "".
    				if entityKeysInStorage.Contains(origKeys[i]) {
    					// Ignore any deletion error.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 71.9K bytes
    - Viewed (0)
Back to top