Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for NewFit (0.23 sec)

  1. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    				test.args.ScoringStrategy = defaultScoringStrategy
    			}
    
    			_, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    			p, err := NewFit(ctx, &test.args, nil, plfeature.Features{})
    			if err != nil {
    				t.Fatal(err)
    			}
    			cycleState := framework.NewCycleState()
    			_, preFilterStatus := p.(framework.PreFilterPlugin).PreFilter(ctx, cycleState, test.pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/registry.go

    		podtopologyspread.Name:               runtime.FactoryAdapter(fts, podtopologyspread.New),
    		nodeunschedulable.Name:               nodeunschedulable.New,
    		noderesources.Name:                   runtime.FactoryAdapter(fts, noderesources.NewFit),
    		noderesources.BalancedAllocationName: runtime.FactoryAdapter(fts, noderesources.NewBalancedAllocation),
    		volumebinding.Name:                   runtime.FactoryAdapter(fts, volumebinding.New),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/fit.go

    	}
    	return s, nil
    }
    
    // Name returns name of the plugin. It is used in logs, etc.
    func (f *Fit) Name() string {
    	return Name
    }
    
    // NewFit initializes a new plugin and returns it.
    func NewFit(_ context.Context, plArgs runtime.Object, h framework.Handle, fts feature.Features) (framework.Plugin, error) {
    	args, ok := plArgs.(*config.NodeResourcesFitArgs)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  4. pkg/scheduler/schedule_one_test.go

    		tf.RegisterBindPlugin(defaultbinder.Name, defaultbinder.New),
    		tf.RegisterPluginAsExtensions(noderesources.Name, frameworkruntime.FactoryAdapter(feature.Features{}, noderesources.NewFit), "Filter", "PreFilter"),
    	}
    
    	informerFactory := informers.NewSharedInformerFactory(clientsetfake.NewSimpleClientset(objects...), 0)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    	configv1.Convert_v1_DefaultPreemptionArgs_To_config_DefaultPreemptionArgs(v1dpa, dpa, nil)
    	return dpa
    }
    
    var nodeResourcesFitFunc = frameworkruntime.FactoryAdapter(feature.Features{}, noderesources.NewFit)
    var podTopologySpreadFunc = frameworkruntime.FactoryAdapter(feature.Features{}, podtopologyspread.New)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  6. src/runtime/map_fast64.go

    	if h.growing() {
    		evacuate_fast64(t, h, h.nevacuate)
    	}
    }
    
    func evacuate_fast64(t *maptype, h *hmap, oldbucket uintptr) {
    	b := (*bmap)(add(h.oldbuckets, oldbucket*uintptr(t.BucketSize)))
    	newbit := h.noldbuckets()
    	if !evacuated(b) {
    		// TODO: reuse overflow buckets instead of using new ones, if there
    		// is no iterator using the old buckets.  (If !oldIterator.)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  7. src/runtime/map_fast32.go

    	if h.growing() {
    		evacuate_fast32(t, h, h.nevacuate)
    	}
    }
    
    func evacuate_fast32(t *maptype, h *hmap, oldbucket uintptr) {
    	b := (*bmap)(add(h.oldbuckets, oldbucket*uintptr(t.BucketSize)))
    	newbit := h.noldbuckets()
    	if !evacuated(b) {
    		// TODO: reuse overflow buckets instead of using new ones, if there
    		// is no iterator using the old buckets.  (If !oldIterator.)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  8. src/runtime/map_faststr.go

    	if h.growing() {
    		evacuate_faststr(t, h, h.nevacuate)
    	}
    }
    
    func evacuate_faststr(t *maptype, h *hmap, oldbucket uintptr) {
    	b := (*bmap)(add(h.oldbuckets, oldbucket*uintptr(t.BucketSize)))
    	newbit := h.noldbuckets()
    	if !evacuated(b) {
    		// TODO: reuse overflow buckets instead of using new ones, if there
    		// is no iterator using the old buckets.  (If !oldIterator.)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:17:26 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  9. src/runtime/map.go

    		advanceEvacuationMark(h, t, newbit)
    	}
    }
    
    func advanceEvacuationMark(h *hmap, t *maptype, newbit uintptr) {
    	h.nevacuate++
    	// Experiments suggest that 1024 is overkill by at least an order of magnitude.
    	// Put it in there as a safeguard anyway, to ensure O(1) behavior.
    	stop := h.nevacuate + 1024
    	if stop > newbit {
    		stop = newbit
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 57.6K bytes
    - Viewed (0)
Back to top