- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for enqueue0 (0.17 sec)
-
okhttp/src/test/java/okhttp3/EventListenerTest.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
) { setUp(protocol, mockWebServer) server.enqueue( MockResponse.Builder() .body(Buffer().write(ByteArray(Http2Connection.OKHTTP_CLIENT_WINDOW_SIZE + 1))) .build(), ) server.enqueue( MockResponse(body = "abc"), ) // Enqueue an additional response that show if we burnt a good prior response. server.enqueue( MockResponse(body = "XXX"), )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
"controllerRevision", klog.KObj(history), "labels", history.Labels) } return daemonSets } // addHistory enqueues the DaemonSet that manages a ControllerRevision when the ControllerRevision is created // or when the controller manager is restarted. func (dsc *DaemonSetsController) addHistory(logger klog.Logger, obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
src/cmd/go/internal/modload/buildlist.go
} mu.Unlock() return summary, err }) } var enqueue func(m module.Version, pruning modPruning) enqueue = func(m module.Version, pruning modPruning) { if m.Version == "none" { return } if _, dup := loading.LoadOrStore(dedupKey{m, pruning}, nil); dup { // m has already been enqueued for loading. Since unpruned loading may
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 16:04:44 UTC 2024 - 53.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
2: {false: pZero(), true: pZero()}, } queueNoteFn := func(fn int) func(inQueue bool) { return func(inQueue bool) { atomic.AddInt32(queueNoteCounts[fn][inQueue], 1) } } fatalErrs := []string{} var errsLock sync.Mutex expectQNCount := func(fn int, inQueue bool, expect int32) { if a := atomic.LoadInt32(queueNoteCounts[fn][inQueue]); a != expect { errsLock.Lock() defer errsLock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeState.java
this.dependenciesMayChange = component.getModule().isVirtualPlatform(); } // the enqueue and dequeue methods are used for performance reasons // in order to avoid tracking the set of enqueued nodes boolean enqueue() { if (queued) { return false; } queued = true; return true; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 58.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
// If any of pInfo.PendingPlugins return Queue, // the scheduling queue is supposed to enqueue this Pod to activeQ, skipping backoffQ. // If any of pInfo.unschedulablePlugins return Queue, // the scheduling queue is supposed to enqueue this Pod to activeQ/backoffQ depending on the remaining backoff time of the Pod. // If all QueueingHintFns returns Skip, the scheduling queue enqueues the Pod back to unschedulable Pod pool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
t.Errorf("Expected no error from the controller, but got: %#v", controllerErr) } }) t.Run("priority level concurrency is set to 1, queue length is 1, first request should time out and second (enqueued) request should time out as well", func(t *testing.T) { t.Parallel() type result struct { err error response *http.Response } const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
// Requeue the last update if the last sync returned error. switch { case phaseTransition: p.workQueue.Enqueue(podUID, 0) case syncErr == nil: // No error; requeue at the regular resync interval. p.workQueue.Enqueue(podUID, wait.Jitter(p.resyncInterval, workerResyncIntervalJitterFactor)) case strings.Contains(syncErr.Error(), NetworkNotReadyErrorMsg):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
jm.queue.AddAfter(key, total-passed) logger.V(4).Info("job's ActiveDeadlineSeconds updated, will rsync", "key", key, "interval", total-passed) } } } // deleteJob enqueues the job and all the pods associated with it that still // have a finalizer. func (jm *Controller) deleteJob(logger klog.Logger, obj interface{}) { jm.enqueueSyncJobImmediately(logger, obj) jobObj, ok := obj.(*batch.Job)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)