- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 121 for dequeue1 (0.14 sec)
-
android/guava/src/com/google/common/collect/Iterables.java
* Queue#isEmpty} and {@link Queue#remove()}, since {@link Queue}'s iteration order is undefined. * Calling {@link Iterator#hasNext()} on a generated iterator from the returned iterable may cause * an item to be immediately dequeued for return on a subsequent call to {@link Iterator#next()}. * * <p>Whether the input {@code iterable} is a {@link Queue} or not, the returned {@code Iterable} * is not thread-safe. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 24 19:38:27 UTC 2024 - 42.8K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
return nil } if err != nil { return err } err = dc.trySync(ctx, pdb) // If the reason for failure was a conflict, then allow this PDB update to be // requeued without triggering the failSafe logic. if errors.IsConflict(err) { return err } if err != nil { logger.Error(err, "Failed to sync PDB", "podDisruptionBudget", klog.KRef(namespace, name))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
ec.queue.AddRateLimited(key) return true } // syncHandler is invoked for each work item which might need to be processed. // If an error is returned from this function, the item will be requeued. func (ec *Controller) syncHandler(ctx context.Context, key string) error { sep := strings.Index(key, ":") if sep < 0 { return fmt.Errorf("unexpected key: %s", key) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
// When Extenders reject some Nodes and the pod ends up being unschedulable, // we put framework.ExtenderName to pInfo.UnschedulablePlugins. // This Pod will be requeued from unschedulable pod pool to activeQ/backoffQ // by any kind of cluster events. // https://github.com/kubernetes/kubernetes/issues/122019 if diagnosis.UnschedulablePlugins == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
tensorflow/compiler/jit/deadness_analysis.cc
if (IsMerge(node)) { for (const Edge* e : node->in_edges()) { if (IsNextIteration(e->src())) { ++num_ready_inputs[node->id()]; } } } } // dequeue is used to ensure that the nodes are first-in-first-out. This // order guarantees that the exits in the ready queue are visited before // nodes that will become ready in the future. std::deque<Node*> ready;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 12 06:33:33 UTC 2024 - 60.4K bytes - Viewed (0) -
src/runtime/time.go
func blockTimerChan(c *hchan) { t := c.timer t.lock() t.trace("blockTimerChan") if !t.isChan { badTimer() } t.blocked++ // If this is the first enqueue after a recent dequeue, // the timer may still be in the heap but marked as a zombie. // Unmark it in this case, if the timer is still pending. if t.state&timerHeaped != 0 && t.state&timerZombie != 0 && t.when > 0 { t.state &^= timerZombie
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 14:36:24 UTC 2024 - 37.5K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
if _, updateErr = dsClient.UpdateStatus(ctx, toUpdate, metav1.UpdateOptions{}); updateErr == nil { return nil } // Stop retrying if we exceed statusUpdateRetries - the DaemonSet will be requeued with a rate limit. if i >= StatusUpdateRetries { break } // Update the set with the latest resource version for the next poll
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
@Synchronized override fun dispatch(request: RecordedRequest): MockResponse { // This guarantees a deterministic sequence when handling the canceled request: // 1. Server reads request and dequeues first response // 2. Client cancels request // 3. Server tries to send response on the canceled stream // Otherwise, there is no guarantee for the sequence. For example, the server may use the
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
watcher.stopLocked() } c.watchersToStop = c.watchersToStop[:0] for _, watcher := range c.expiredBookmarkWatchers { if watcher.stopped { continue } // requeue the watcher for the next bookmark if needed. c.bookmarkWatchers.addWatcherThreadUnsafe(watcher) } c.expiredBookmarkWatchers = c.expiredBookmarkWatchers[:0] } func (c *Cacher) terminateAllWatchers() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
if err != nil { utilruntime.HandleError(fmt.Errorf("couldn't get key for object %+v: %v", obj, err)) return } jm.orphanQueue.Add(key) } // worker runs a worker thread that just dequeues items, processes them, and marks them done. // It enforces that the syncHandler is never invoked concurrently with the same key. func (jm *Controller) worker(ctx context.Context) { for jm.processNextWorkItem(ctx) { }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (1)