Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 76 for deleteRS (0.14 sec)

  1. pkg/kubelet/cm/devicemanager/manager_test.go

    	as.True(ok)
    	as.Equal(int64(3), resource1Capacity.Value())
    	as.Equal(int64(2), resource1Allocatable.Value())
    	as.Equal(0, len(removedResources))
    
    	// Deletes an unhealthy device should NOT change allocatable but change capacity.
    	devs1 := devs[:len(devs)-1]
    	callback(resourceName1, devs1)
    	capacity, allocatable, removedResources = testManager.GetCapacity()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

          Thread w = thread;
          if (w != null) {
            thread = null;
            LockSupport.unpark(w);
          }
        }
      }
    
      /**
       * Marks the given node as 'deleted' (null waiter) and then scans the list to unlink all deleted
       * nodes. This is an O(n) operation in the common case (and O(n^2) in the worst), but we are saved
       * by two things.
       *
       * <ul>
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
  3. guava/src/com/google/common/util/concurrent/AbstractFuture.java

          Thread w = thread;
          if (w != null) {
            thread = null;
            LockSupport.unpark(w);
          }
        }
      }
    
      /**
       * Marks the given node as 'deleted' (null waiter) and then scans the list to unlink all deleted
       * nodes. This is an O(n) operation in the common case (and O(n^2) in the worst), but we are saved
       * by two things.
       *
       * <ul>
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
  4. src/crypto/tls/handshake_client_test.go

    	}
    
    	// Calling Put with a nil entry deletes the key.
    	cache.Put(keys[0], nil)
    	if _, ok := cache.Get(keys[0]); ok {
    		t.Fatalf("session cache failed to delete key 0")
    	}
    
    	// Delete entry 2. LRU should keep 4 and 5
    	cache.Put(keys[2], nil)
    	if _, ok := cache.Get(keys[2]); ok {
    		t.Fatalf("session cache failed to delete key 4")
    	}
    	for i := 4; i < 6; i++ {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 88.7K bytes
    - Viewed (0)
  5. src/net/http/transport.go

    				break
    			}
    		}
    		if q.len() == 0 {
    			delete(t.connsPerHostWait, key)
    		} else {
    			// q is a value (like a slice), so we have to store
    			// the updated q back into the map.
    			t.connsPerHostWait[key] = q
    		}
    		if done {
    			return
    		}
    	}
    
    	// Otherwise, decrement the recorded count.
    	if n--; n == 0 {
    		delete(t.connsPerHost, key)
    	} else {
    		t.connsPerHost[key] = n
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.31.md

    - Kube-scheduler implements scheduling hints for the CSILimit plugin.
      The scheduling hints allow the scheduler to retry scheduling a Pod that was previously rejected by the CSILimit plugin if a deleted pod has a PVC from the same driver. ([#121508](https://github.com/kubernetes/kubernetes/pull/121508), [@utam0k](https://github.com/utam0k)) [SIG Scheduling and Storage]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 20:34:14 UTC 2024
    - 60.3K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/queue/scheduling_queue.go

    	p.cond.Broadcast()
    	return nil
    }
    
    // Delete deletes the item from either of the two queues. It assumes the pod is
    // only in one queue.
    func (p *PriorityQueue) Delete(pod *v1.Pod) error {
    	p.lock.Lock()
    	defer p.lock.Unlock()
    	p.deleteNominatedPodIfExistsUnlocked(pod)
    	pInfo := newQueuedPodInfoForLookup(pod)
    	if err := p.activeQ.Delete(pInfo); err != 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)
  8. cmd/test-utils_test.go

    }
    
    // return URL for deleting multiple objects from a bucket.
    func getMultiDeleteObjectURL(endPoint, bucketName string) string {
    	queryValue := url.Values{}
    	queryValue.Set("delete", "")
    	return makeTestTargetURL(endPoint, bucketName, "", queryValue)
    }
    
    // return URL for HEAD on the object.
    func getHeadObjectURL(endPoint, bucketName, objectName string) string {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    				test.pod.Status.NominatedNodeName = res.NominatedNodeName
    			}
    
    			// Manually set the deleted Pods' deletionTimestamp to non-nil.
    			for _, pod := range test.pods {
    				if deletedPodNames.Has(pod.Name) {
    					now := metav1.Now()
    					pod.DeletionTimestamp = &now
    					deletedPodNames.Delete(pod.Name)
    				}
    			}
    
    			// Call preempt again and make sure it doesn't preempt any more pods.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  10. testing/architecture-test/src/changes/archunit-store/provider-task-properties.txt

    Method <org.gradle.api.tasks.Delete.getDelete()> does not have raw return type assignable to org.gradle.api.provider.Property in (Delete.java:0)
    Method <org.gradle.api.tasks.Delete.isFollowSymlinks()> does not have raw return type assignable to org.gradle.api.provider.Property in (Delete.java:0)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 13:33:20 UTC 2024
    - 51.8K bytes
    - Viewed (0)
Back to top