Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 34 of 34 for enqueuePdb (0.13 sec)

  1. src/cmd/go/internal/modload/buildlist.go

    	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
    			// follow cycles in the requirement graph, we need to return early
    			// to avoid making the load queue infinitely long.
    			return
    		}
    
    		loadQueue.Add(func() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 16:04:44 UTC 2024
    - 53.8K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue.go

    func (p *PriorityQueue) Pop(logger klog.Logger) (*framework.QueuedPodInfo, error) {
    	p.lock.Lock()
    	defer p.lock.Unlock()
    	for p.activeQ.Len() == 0 {
    		// When the queue is empty, invocation of Pop() is blocked until new item is enqueued.
    		// When Close() is called, the p.closed is set and the condition is broadcast,
    		// which causes this loop to continue and return from the Pop().
    		if p.closed {
    			logger.V(2).Info("Scheduling queue is closed")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  3. pkg/kubelet/pod_workers_test.go

    		t.Fatalf("unexpected waiting static pods: %s", cmp.Diff(e, a))
    	}
    	// verify all are enqueued
    	if e, a := sets.New[string]("1-normal", "2-static", "4-static", "3-static"), podWorkers.workQueue.(*fakeQueue).Set(); !e.Equal(a) {
    		t.Fatalf("unexpected queued items: %s", cmp.Diff(e, a))
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/CacheTest.kt

        val response = client.newCall(request).execute()
        assertThat(response.body.string()).isEqualTo("B")
      }
    
      @Test
      fun requestOnlyIfCachedWithNoResponseCached() {
        // (no responses enqueued)
        val request =
          Request.Builder()
            .url(server.url("/"))
            .header("Cache-Control", "only-if-cached")
            .build()
        val response = client.newCall(request).execute()
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 108.6K bytes
    - Viewed (0)
Back to top