Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for Dequeue (0.18 sec)

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

    		queue.flushBackoffQCompleted(logger)
    	}
    	moveClockForward = func(t *testing.T, logger klog.Logger, queue *PriorityQueue, _ *framework.QueuedPodInfo) {
    		queue.clock.(*testingclock.FakeClock).Step(2 * time.Second)
    	}
    	flushUnschedulerQ = func(t *testing.T, logger klog.Logger, queue *PriorityQueue, _ *framework.QueuedPodInfo) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_test.go

    	pods[2].Status.StartTime = &startTime
    	pods[2].Spec.ActiveDeadlineSeconds = &exceededActiveDeadlineSeconds
    
    	kubelet.podManager.SetPods(pods)
    	kubelet.workQueue.Enqueue(pods[2].UID, 0)
    	kubelet.workQueue.Enqueue(pods[3].UID, 30*time.Second)
    	kubelet.workQueue.Enqueue(pods[4].UID, 2*time.Minute)
    
    	clock.Step(1 * time.Minute)
    
    	expected := []*v1.Pod{pods[2], pods[3], pods[0]}
    	podsToSync := kubelet.getPodsToSync()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  3. tensorflow/compiler/mlir/tensorflow/transforms/tf_passes.td

    }
    
    def TPUUpdateEmbeddingEnqueueOpInputsPass : Pass<"tf-tpu-update-embedding-enqueue-op-inputs", "mlir::func::FuncOp"> {
      let summary = "Updates inputs to TPU embedding enqueue ops depending on whether graph is in training mode or in evaluation mode.";
    
      let description = [{
        Updates inputs to TPU embedding enqueue ops depending on whether graph
        is in training mode or in evaluation mode.
      }];
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Jun 12 21:18:05 UTC 2024
    - 99.6K bytes
    - Viewed (0)
  4. okhttp-android/src/main/baseline-prof.txt

    HSPLandroidx/lifecycle/DispatchQueue;-><init>()V
    HSPLandroidx/lifecycle/DispatchQueue;->canRun()Z
    HSPLandroidx/lifecycle/DispatchQueue;->drainQueue()V
    HSPLandroidx/lifecycle/DispatchQueue;->enqueue(Ljava/lang/Runnable;)V
    HSPLandroidx/lifecycle/Lifecycle$1;-><clinit>()V
    HSPLandroidx/lifecycle/Lifecycle$Event;-><clinit>()V
    HSPLandroidx/lifecycle/Lifecycle$Event;-><init>(Ljava/lang/String;I)V
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Mar 21 11:22:00 UTC 2022
    - 127.9K bytes
    - Viewed (0)
  5. src/database/sql/sql_test.go

    	<-drv.waitingCh
    	// Now close the busy connections. This provides a connection for
    	// the blocked goroutine and then fills up the idle queue.
    	for _, v := range rows {
    		v.Close()
    	}
    	// At this point we give the new connection to DB. This connection is
    	// now useless, since the idle queue is full and there are no pending
    	// requests. DB should deal with this situation without leaking the
    	// connection.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  6. src/internal/trace/traceviewer/static/webcomponents.min.js

    t){var n=w.get(t);n&&n.forEach(function(t){t.observer===e&&t.removeTransientObservers()})})}function i(e,t){for(var n=e;n;n=n.parentNode){var r=w.get(n);if(r)for(var o=0;o<r.length;o++){var i=r[o],a=i.options;if(n===e||a.subtree){var s=t(a);s&&i.enqueue(s)}}}}function a(e){this.callback_=e,this.nodes_=[],this.records_=[],this.uid_=++E}function s(e,t){this.type=e,this.target=t,this.addedNodes=[],this.removedNodes=[],this.previousSibling=null,this.nextSibling=null,this.attributeName=null,this.attr...
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 20:45:06 UTC 2023
    - 115.6K bytes
    - Viewed (0)
Back to top