Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 66 for QUEUE (0.05 sec)

  1. pkg/scheduler/internal/queue/scheduling_queue.go

    			queue := p.requeuePodViaQueueingHint(logger, pInfo, hint, UnscheduledPodUpdate.Label)
    			if queue != unschedulablePods {
    				logger.V(5).Info("Pod moved to an internal scheduling queue because the Pod is updated", "pod", klog.KObj(newPod), "event", PodUpdate, "queue", queue)
    				p.unschedulablePods.delete(usPodInfo.Pod, gated)
    			}
    			if queue == activeQ {
    				p.cond.Broadcast()
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (3)
  2. src/internal/trace/order.go

    	name string
    
    	// parentID is the parent ID of the active task.
    	parentID TaskID
    }
    
    // queue implements a growable ring buffer with a queue API.
    type queue[T any] struct {
    	start, end int
    	buf        []T
    }
    
    // push adds a new event to the back of the queue.
    func (q *queue[T]) push(value T) {
    	if q.end-q.start == len(q.buf) {
    		q.grow()
    	}
    	q.buf[q.end%len(q.buf)] = value
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:25 UTC 2024
    - 52.4K bytes
    - Viewed (0)
  3. src/index/suffixarray/sais2.go

    		}
    
    		// Negative j is a work queue entry; rewrite to positive j for final suffix array.
    		j = -j
    		sa[i] = int64(j)
    
    		// Index j was on work queue (encoded as -j but now decoded),
    		// meaning k := j-1 is L-type,
    		// so we can now place k correctly into sa.
    		// If k-1 is S-type, queue -k for processing later in this loop.
    		// If k-1 is L-type (text[k-1] > text[k]), queue k to save for the caller.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 18 23:57:18 UTC 2024
    - 52.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go

    			}
    			queue := &queue{
    				requestsWaiting:   newRequestFIFO(),
    				requestsExecuting: sets.New[*request](),
    			}
    			r := &request{
    				qs:           qs,
    				queue:        queue,
    				workEstimate: qs.completeWorkEstimate(&test.workEstimate),
    			}
    			rOther := &request{qs: qs, queue: queue}
    
    			qs.totRequestsExecuting = 111
    			qs.totSeatsInUse = 222
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 26 12:55:23 UTC 2023
    - 58.4K bytes
    - Viewed (0)
  5. pkg/controller/replicaset/replica_set_test.go

    		logger.V(8).Info("Waiting for queue to have 1 item", "length", manager.queue.Len())
    		return manager.queue.Len() == 1, nil
    	})
    	if err != nil {
    		t.Fatalf("initial RS didn't result in new item in the queue: %v", err)
    	}
    
    	ok := manager.processNextWorkItem(tCtx)
    	if !ok {
    		t.Fatal("queue is shutting down")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    			expectedHint:                    framework.Queue,
    			expectedErr:                     true,
    		},
    		"backoff-wrong-new-object": {
    			pod:                             &v1.Pod{},
    			newObj:                          "not-a-pod",
    			enableInPlacePodVerticalScaling: true,
    			expectedHint:                    framework.Queue,
    			expectedErr:                     true,
    		},
    		"queue-on-other-pod-deleted": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/MapMakerInternalMap.java

        WeakValueReferenceImpl(ReferenceQueue<V> queue, V referent, E entry) {
          super(referent, queue);
          this.entry = entry;
        }
    
        @Override
        public E getEntry() {
          return entry;
        }
    
        @Override
        public WeakValueReference<K, V, E> copyFor(ReferenceQueue<V> queue, E entry) {
          return new WeakValueReferenceImpl<>(queue, get(), entry);
        }
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  8. pkg/controller/podautoscaler/horizontal.go

    		return
    	}
    
    	// Requests are always added to queue with resyncPeriod delay.  If there's already
    	// request for the HPA in the queue then a new request is always dropped. Requests spend resync
    	// interval in queue so HPAs are processed every resync interval.
    	a.queue.AddRateLimited(key)
    
    	// Register HPA in the hpaSelectors map if it's not present yet. Attaching the Nothing selector
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        WeakValueReferenceImpl(ReferenceQueue<V> queue, V referent, E entry) {
          super(referent, queue);
          this.entry = entry;
        }
    
        @Override
        public E getEntry() {
          return entry;
        }
    
        @Override
        public WeakValueReference<K, V, E> copyFor(ReferenceQueue<V> queue, E entry) {
          return new WeakValueReferenceImpl<>(queue, get(), entry);
        }
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/Synchronized.java

      }
    
      static <E extends @Nullable Object> Queue<E> queue(Queue<E> queue, @CheckForNull Object mutex) {
        return (queue instanceof SynchronizedQueue) ? queue : new SynchronizedQueue<E>(queue, mutex);
      }
    
      static class SynchronizedQueue<E extends @Nullable Object> extends SynchronizedCollection<E>
          implements Queue<E> {
    
        SynchronizedQueue(Queue<E> delegate, @CheckForNull Object mutex) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 53.4K bytes
    - Viewed (0)
Back to top