- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for numPods (0.17 sec)
-
pkg/kubelet/pod_workers_test.go
podWorkers, _, processed := createPodWorkers() numPods := 20 for i := 0; i < numPods; i++ { for j := i; j < numPods; j++ { podWorkers.UpdatePod(UpdatePodOptions{ Pod: newNamedPod(strconv.Itoa(j), "ns", strconv.Itoa(i), false), UpdateType: kubetypes.SyncPodCreate, }) } } drainWorkers(podWorkers, numPods) if len(processed) != numPods { t.Fatalf("Not all pods processed: %v", len(processed))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
} } p.moveRequestCycle = p.schedulingCycle if p.isSchedulingQueueHintEnabled && len(p.inFlightPods) != 0 { logger.V(5).Info("Event received while pods are in flight", "event", event.Label, "numPods", len(p.inFlightPods)) // AddUnschedulableIfNotPresent might get called for in-flight Pods later, and in // AddUnschedulableIfNotPresent we need to know whether events were // observed while scheduling them.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache_test.go
if len(snapshot.nodeInfoList) != cache.nodeTree.numNodes { return fmt.Errorf("unexpected number of nodes in NodeInfoList. Expected: %v, got: %v", cache.nodeTree.numNodes, len(snapshot.nodeInfoList)) } expectedNodeInfoList := make([]*framework.NodeInfo, 0, cache.nodeTree.numNodes) expectedHavePodsWithAffinityNodeInfoList := make([]*framework.NodeInfo, 0, cache.nodeTree.numNodes) expectedUsedPVCSet := sets.New[string]()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 63.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
logger.V(5).Info("remembering potential nodes", "pod", klog.KObj(pod), "potentialnodes", klog.KObjSlice(nodes)) numNodes := len(nodes) if numNodes > resourcev1alpha2.PodSchedulingNodeListMaxSize { numNodes = resourcev1alpha2.PodSchedulingNodeListMaxSize } potentialNodes := make([]string, 0, numNodes) if numNodes == len(nodes) { // Copy all node names. for _, node := range nodes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/sparsecore/embedding_pipelining.cc
template <typename Vector> void Append(Vector& a, const Vector& b) { a.insert(a.end(), b.begin(), b.end()); } int64_t GetNumOps(func::FuncOp func) { int64_t num_ops = 0; for (auto it = func.begin(); it != func.end(); ++it) ++num_ops; return num_ops; } std::vector<Value> ResultsAsVector(Operation* op) { std::vector<Value> vec; vec.reserve(op->getNumResults());
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 92.9K bytes - Viewed (0)