- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 76 for deleteRS (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)