- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for newNode (0.51 sec)
-
guava/src/com/google/common/util/concurrent/AbstractFuture.java
if (!isDone()) { Listener oldHead = listeners; if (oldHead != Listener.TOMBSTONE) { Listener newNode = new Listener(listener, executor); do { newNode.next = oldHead; if (ATOMIC_HELPER.casListeners(this, oldHead, newNode)) { return; } oldHead = listeners; // re-read } while (oldHead != Listener.TOMBSTONE); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
if (!isDone()) { Listener oldHead = listeners; if (oldHead != Listener.TOMBSTONE) { Listener newNode = new Listener(listener, executor); do { newNode.next = oldHead; if (ATOMIC_HELPER.casListeners(this, oldHead, newNode)) { return; } oldHead = listeners; // re-read } while (oldHead != Listener.TOMBSTONE); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
nc.zoneStates[k] = newState } } } func (nc *Controller) podUpdated(oldPod, newPod *v1.Pod) { if newPod == nil { return } if len(newPod.Spec.NodeName) != 0 && (oldPod == nil || newPod.Spec.NodeName != oldPod.Spec.NodeName) { podItem := podUpdateItem{newPod.Namespace, newPod.Name} nc.podUpdateQueue.Add(podItem) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
plugin/pkg/admission/resourcequota/admission_test.go
// create a pod that has an active deadline newPod := validPod("allowed-pod", 1, getResourceRequirements(getResourceList("100m", "2Gi"), getResourceList("", ""))) activeDeadlineSeconds := int64(30) newPod.Spec.ActiveDeadlineSeconds = &activeDeadlineSeconds
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 84.1K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
"notthere": {Time: currentTime}, // Should be removed, pod deleted. } add(t, dc.pdbStore, pdb) pod1, _ := newPod(t, "p1") pod1.DeletionTimestamp = &metav1.Time{Time: dc.clock.Now()} pod2, _ := newPod(t, "p2") pod3, _ := newPod(t, "p3") add(t, dc.podStore, pod1) add(t, dc.podStore, pod2) add(t, dc.podStore, pod3) dc.sync(ctx, pdbName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
pkg/registry/core/pod/strategy_test.go
newPod := tc.newPod Strategy.PrepareForCreate(genericapirequest.NewContext(), newPod) if errs := Strategy.Validate(genericapirequest.NewContext(), newPod); len(errs) != 0 { t.Errorf("Unexpected error: %v", errs.ToAggregate()) } if diff := cmp.Diff(getLifecycle(newPod), getLifecycle(tc.wantPod)); diff != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
generatedVolumeName, podAddErr := dsw.AddPod(types.UniquePodName(podName1), controllervolumetesting.NewPod(podName1, podName1), volumeSpec, nodeName1) if podAddErr != nil { t.Fatalf("AddPod failed. Expected: <no error> Actual: <%v>", podAddErr) } _, podAddErr = dsw.AddPod(types.UniquePodName(podName2), controllervolumetesting.NewPod(podName2, podName2), volumeSpec, nodeName2) if podAddErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
func (p *PriorityQueue) AssignedPodUpdated(logger klog.Logger, oldPod, newPod *v1.Pod) { p.lock.Lock() if isPodResourcesResizedDown(newPod) { p.moveAllToActiveOrBackoffQueue(logger, AssignedPodUpdate, oldPod, newPod, nil) } else { p.movePodsToActiveOrBackoffQueue(logger, p.getUnschedulablePodsWithMatchingAffinityTerm(logger, newPod), AssignedPodUpdate, oldPod, newPod) } p.lock.Unlock() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
expectFn func(t *testing.T, status v1.PodStatus) }{ {pod: newPod(0, 1, func(pod *v1.Pod) { pod.Status.Phase = v1.PodFailed })}, { pod: newPod(0, 1, func(pod *v1.Pod) { pod.Status.Phase = v1.PodRunning }), expectFn: func(t *testing.T, status v1.PodStatus) { status.Phase = v1.PodFailed }, }, { pod: newPod(0, 1, func(pod *v1.Pod) { pod.Status.Phase = v1.PodRunning
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
pendingDeletionRS.ObjectMeta.OwnerReferences[0].UID = "789" now := metav1.Now() pendingDeletionRS.DeletionTimestamp = &now pod1 := newPod("pod1", someRS, v1.PodRunning, nil, true) pod2 := newPod("pod2", someRS, v1.PodRunning, nil, true) pod3 := newPod("pod3", relatedRS, v1.PodRunning, nil, true) pod4 := newPod("pod4", unrelatedRS, v1.PodRunning, nil, true) logger, _ := ktesting.NewTestContext(t) stopCh := make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0)