Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 40 for seenNode (0.22 sec)

  1. pkg/scheduler/internal/cache/cache.go

    	} else {
    		cache.removeNodeImageStates(n.info.Node())
    	}
    	cache.moveNodeInfoToHead(logger, node.Name)
    
    	cache.nodeTree.addNode(logger, node)
    	cache.addNodeImageStates(node, n.info)
    	n.info.SetNode(node)
    	return n.info.Snapshot()
    }
    
    func (cache *cacheImpl) UpdateNode(logger klog.Logger, oldNode, newNode *v1.Node) *framework.NodeInfo {
    	cache.mu.Lock()
    	defer cache.mu.Unlock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 09:56:48 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  2. pkg/scheduler/extender.go

    			}
    		}
    	} else if result.Nodes != nil {
    		nodeResult = make([]*framework.NodeInfo, len(result.Nodes.Items))
    		for i := range result.Nodes.Items {
    			nodeResult[i] = framework.NewNodeInfo()
    			nodeResult[i].SetNode(&result.Nodes.Items[i])
    		}
    	}
    
    	return nodeResult, result.FailedNodes, result.FailedAndUnresolvableNodes, nil
    }
    
    // Prioritize based on extender implemented priority functions. Weight*priority is added
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. pkg/scheduler/extender_test.go

    			// nodeInfos instantiations
    			nodeInfoList := make([]*framework.NodeInfo, 0, len(tt.nodeNames))
    			for i, nm := range tt.nodeNames {
    				nodeInfo := framework.NewNodeInfo()
    				node := createNode(nm)
    				nodeInfo.SetNode(node)
    				nodeInfo.AddPod(tt.podsInNodeList[i])
    				nodeInfo.AddPod(tt.podsInNodeList[i+2])
    				nodeInfoList = append(nodeInfoList, nodeInfo)
    			}
    			tt.nodeInfos = tf.NodeInfoLister(nodeInfoList)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/types.go

    			n.PVCRefCounts[key] += 1
    		} else {
    			n.PVCRefCounts[key] -= 1
    			if n.PVCRefCounts[key] <= 0 {
    				delete(n.PVCRefCounts, key)
    			}
    		}
    	}
    }
    
    // SetNode sets the overall node information.
    func (n *NodeInfo) SetNode(node *v1.Node) {
    	n.node = node
    	n.Allocatable = NewResource(node.Status.Allocatable)
    	n.Generation = nextGeneration()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/preemption/preemption_test.go

    		},
    	}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			var nodeInfos []*framework.NodeInfo
    			for _, name := range nodeNames {
    				ni := framework.NewNodeInfo()
    				ni.SetNode(st.MakeNode().Name(name).Obj())
    				nodeInfos = append(nodeInfos, ni)
    			}
    			nodes, _ := nodesWherePreemptionMightHelp(nodeInfos, tt.nodesStatuses)
    			if len(tt.expected) != len(nodes) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go

    		},
    	}
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			nodeInfo := framework.NewNodeInfo()
    			nodeInfo.SetNode(test.node)
    			p, err := New(ctx, nil, nil, feature.Features{})
    			if err != nil {
    				t.Fatalf("creating plugin: %v", err)
    			}
    			gotStatus := p.(framework.FilterPlugin).Filter(ctx, nil, test.pod, nodeInfo)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go

    		addLimitToNode()
    		addDriversCSINode(true)
    	case "csinode-with-no-limit":
    		addDriversCSINode(false)
    	case "no-csi-driver":
    		initCSINode()
    	default:
    		// Do nothing.
    	}
    
    	nodeInfo.SetNode(node)
    	return nodeInfo, csiNode
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 28.6K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/noderesources/fit.go

    func isFit(pod *v1.Pod, node *v1.Node) bool {
    	if node == nil {
    		return false
    	}
    	nodeInfo := framework.NewNodeInfo()
    	nodeInfo.SetNode(node)
    	return len(Fits(pod, nodeInfo)) == 0
    }
    
    // Filter invoked at the filter extension point.
    // Checks if a node has sufficient resources, such as cpu, memory, gpu, opaque int resources etc to run a pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go

    			t.Log("Verify")
    
    			p := pl.(*VolumeBinding)
    			nodeInfos := make([]*framework.NodeInfo, 0)
    			for _, node := range item.nodes {
    				nodeInfo := framework.NewNodeInfo()
    				nodeInfo.SetNode(node)
    				nodeInfos = append(nodeInfos, nodeInfo)
    			}
    			state := framework.NewCycleState()
    
    			t.Logf("Verify: call PreFilter and check status")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 32K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go

    			_, ctx := ktesting.NewTestContext(t)
    			node := v1.Node{ObjectMeta: metav1.ObjectMeta{
    				Name:   test.nodeName,
    				Labels: test.labels,
    			}}
    			nodeInfo := framework.NewNodeInfo()
    			nodeInfo.SetNode(&node)
    
    			p, err := New(ctx, &test.args, nil)
    			if err != nil {
    				t.Fatalf("Creating plugin: %v", err)
    			}
    
    			state := framework.NewCycleState()
    			var gotStatus *framework.Status
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 38.7K bytes
    - Viewed (0)
Back to top