Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for popHead (0.11 sec)

  1. src/sync/pool.go

    	New func() any
    }
    
    // Local per-P Pool appendix.
    type poolLocalInternal struct {
    	private any       // Can be used only by the respective P.
    	shared  poolChain // Local P can pushHead/popHead; any P can popTail.
    }
    
    type poolLocal struct {
    	poolLocalInternal
    
    	// Prevents false sharing on widespread platforms with
    	// 128 mod (cache line size) = 0 .
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue_test.go

    	// Simulate a pod being popped by the scheduler,
    	// At this time, unschedulable pod should be popped.
    	p1, err := q.Pop(logger)
    	if err != nil {
    		t.Errorf("Error while popping the head of the queue: %v", err)
    	}
    	if p1.Pod != unschedulablePod {
    		t.Errorf("Expected that test-pod-unscheduled was popped, got %v", p1.Pod.Name)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue.go

    	// are popped from this heap before the scheduler looks at activeQ
    	podBackoffQ *heap.Heap
    	// unschedulablePods holds pods that have been tried and determined unschedulable.
    	unschedulablePods *UnschedulablePods
    	// schedulingCycle represents sequence number of scheduling cycle and is incremented
    	// when a pod is popped.
    	schedulingCycle int64
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    		}
    	}
    
    	// Ensure there is enough budget for slow processing since
    	// the entire watch cache is going to be served through the
    	// interval and events won't be popped from the cacheWatcher's
    	// input channel until much later.
    	cacher.dispatchTimeoutBudget.returnUnused(100 * time.Millisecond)
    
    	// We define a custom index validator such that the interval is
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/ssagen/ssa.go

    	deferBitsAddr *ssa.Value
    	deferBitsTemp *ir.Name
    
    	// line number stack. The current line number is top of stack
    	line []src.XPos
    	// the last line number processed; it may have been popped
    	lastPos src.XPos
    
    	// list of panic calls by function name and line number.
    	// Used to deduplicate panic calls.
    	panics map[funcLine]*ssa.Block
    
    	cgoUnsafeArgs       bool
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 19:44:43 UTC 2024
    - 284.9K bytes
    - Viewed (0)
  6. tensorflow/compiler/mlir/tensorflow/ir/tf_generated_ops.td

      let arguments = (ins
        Arg<TF_ResourceTensor, [{The handle to a stack.}], [TF_StackRead, TF_StackWrite]>:$handle
      );
    
      let results = (outs
        Res<TF_Tensor, [{The tensor that is popped from the top of the stack.}]>:$elem
      );
    
      TF_DerivedResultTypeAttr elem_type = TF_DerivedResultTypeAttr<0>;
    }
    
    def TF_StackPushV2Op : TF_Op<"StackPushV2", []> {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Jun 11 23:24:08 UTC 2024
    - 793K bytes
    - Viewed (0)
Back to top