Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for casgstatus (0.16 sec)

  1. src/runtime/proc.go

    // casGToWaiting transitions gp from old to _Gwaiting, and sets the wait reason.
    //
    // Use this over casgstatus when possible to ensure that a waitreason is set.
    func casGToWaiting(gp *g, old uint32, reason waitReason) {
    	// Set the wait reason before calling casgstatus, because casgstatus will use it.
    	gp.waitreason = reason
    	casgstatus(gp, old, _Gwaiting)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/runtime/framework_test.go

    		},
    		{
    			name: "ErrorFilter",
    			plugins: []*TestPlugin{
    				{
    					name: "TestPlugin",
    					inj:  injectedResult{FilterStatus: int(framework.Error)},
    				},
    			},
    			wantStatus: framework.AsStatus(fmt.Errorf(`running "TestPlugin" filter plugin: %w`, errInjectedFilterStatus)).WithPlugin("TestPlugin"),
    		},
    		{
    			name: "UnschedulableFilter",
    			plugins: []*TestPlugin{
    				{
    					name: "TestPlugin",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  3. pkg/scheduler/schedule_one_test.go

    func (pl *falseMapPlugin) Name() string {
    	return "FalseMap"
    }
    
    func (pl *falseMapPlugin) Score(_ context.Context, _ *framework.CycleState, _ *v1.Pod, _ string) (int64, *framework.Status) {
    	return 0, framework.AsStatus(errPrioritize)
    }
    
    func (pl *falseMapPlugin) ScoreExtensions() framework.ScoreExtensions {
    	return nil
    }
    
    type numericMapPlugin struct{}
    
    func newNumericMapPlugin() frameworkruntime.PluginFactory {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go

    	cycleState := framework.NewCycleState()
    	gotStatus := p.(*PodTopologySpread).Filter(context.Background(), cycleState, pod, nodeInfo)
    	wantStatus := framework.AsStatus(fmt.Errorf(`reading "PreFilterPodTopologySpread" from cycleState: %w`, framework.ErrNotFound))
    	if !reflect.DeepEqual(gotStatus, wantStatus) {
    		t.Errorf("status does not match: %v, want: %v", gotStatus, wantStatus)
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 143.1K bytes
    - Viewed (0)
Back to top