- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ReceiveError (0.22 sec)
-
pkg/scheduler/framework/parallelize/error_channel_test.go
"testing" ) func TestErrorChannel(t *testing.T) { errCh := NewErrorChannel() if actualErr := errCh.ReceiveError(); actualErr != nil { t.Errorf("expect nil from err channel, but got %v", actualErr) } err := errors.New("unknown error") errCh.SendError(err) if actualErr := errCh.ReceiveError(); actualErr != err { t.Errorf("expect %v from err channel, but got %v", err, actualErr) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 17:39:23 UTC 2021 - 1.3K bytes - Viewed (0) -
pkg/scheduler/framework/parallelize/error_channel.go
// cancel function. func (e *ErrorChannel) SendErrorWithCancel(err error, cancel context.CancelFunc) { e.SendError(err) cancel() } // ReceiveError receives an error from channel without blocking on the receiver. func (e *ErrorChannel) ReceiveError() error { select { case err := <-e.errCh: return err default: return nil } } // NewErrorChannel returns a new ErrorChannel.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 17:39:23 UTC 2021 - 1.6K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
return } pluginToNodeScores[pl.Name()][index] = framework.NodeScore{ Name: nodeName, Score: s, } } }, metrics.Score) if err := errCh.ReceiveError(); err != nil { return nil, framework.AsStatus(fmt.Errorf("running Score plugins: %w", err)) } } // Run NormalizeScore method for each ScorePlugin in parallel.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
for _, item := range result { if item == nil { continue } diagnosis.NodeToStatusMap[item.node] = item.status diagnosis.AddPluginStatus(item.status) } if err := errCh.ReceiveError(); err != nil { statusCode = framework.Error return feasibleNodes, err } return feasibleNodes, nil } // numFeasibleNodesToFind returns the number of feasible nodes that once found, the scheduler stops
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0)