- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 54 for hasError (0.28 sec)
-
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
if !status.IsSuccess() { return status.AsError() } return nil } addPod := func(api *framework.PodInfo) error { nodeInfo.AddPodInfo(api) status := pl.fh.RunPreFilterExtensionAddPod(ctx, state, pod, api, nodeInfo) if !status.IsSuccess() { return status.AsError() } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
preScoreStatus := fwk.RunPreScorePlugins(ctx, state, pod, nodes) if !preScoreStatus.IsSuccess() { return nil, preScoreStatus.AsError() } // Run the Score plugins. nodesScores, scoreStatus := fwk.RunScorePlugins(ctx, state, pod, nodes) if !scoreStatus.IsSuccess() { return nil, scoreStatus.AsError() } // Additional details logged at level 10 if enabled. loggerVTen := logger.V(10) if loggerVTen.Enabled() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/support/KotlinCompiler.kt
private val pathTranslation: (String) -> String, ) : MessageCollector { val errors = arrayListOf<ScriptCompilationError>() override fun hasErrors() = errors.isNotEmpty() override fun clear() = errors.clear() override fun report(severity: CompilerMessageSeverity, message: String, location: CompilerMessageSourceLocation?) { fun msg() =
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 31 08:46:17 UTC 2023 - 20.1K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
code := s.Code() return code == Unschedulable || code == UnschedulableAndUnresolvable || code == Pending } // AsError returns nil if the status is a success, a wait or a skip; otherwise returns an "error" object // with a concatenated message on reasons of the Status. func (s *Status) AsError() error { if s.IsSuccess() || s.IsWait() || s.IsSkip() { return nil } if s.err != nil { return s.err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
defer m.podStatusesLock.RUnlock() // Clean up orphaned versions. if all { for uid := range m.apiStatusVersions { _, hasPod := m.podStatuses[types.UID(uid)] _, hasMirror := mirrorToPod[uid] if !hasPod && !hasMirror { delete(m.apiStatusVersions, uid) } } } // Decide which pods need status updates. for uid, status := range m.podStatuses {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/catalog/parser/TomlCatalogFileParser.java
return definingCategory .severity(ERROR); } private void assertNoParseErrors(TomlParseResult result) { if (result.hasErrors()) { List<TomlParseError> errors = result.errors(); reportErrors(errors); TreeFormatter formatter = new TreeFormatter(); formatter.node(INVALID_TOML_CATALOG_DEFINITION);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 06 13:35:05 UTC 2024 - 29.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go
if _, s := p.PreFilter(ctx, cs, tt.preemptor); !s.IsSuccess() { t.Fatal(s.AsError()) } nodeInfo, err := snapshot.Get(tt.nodes[tt.nodeIdx].Name) if err != nil { t.Fatal(err) } if s := p.AddPod(ctx, cs, tt.preemptor, mustNewPodInfo(t, tt.addedPod), nodeInfo); !s.IsSuccess() { t.Fatal(s.AsError()) } state, err := getPreFilterState(cs) if err != nil { t.Fatal(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 143.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/scoring_test.go
p := pl.(*PodTopologySpread) cs := framework.NewCycleState() if s := p.PreScore(ctx, cs, tt.pod, tf.BuildNodeInfos(tt.nodes)); !s.IsSkip() { t.Fatalf("Expected skip but got %v", s.AsError()) } }) } } func TestPreScoreStateEmptyNodes(t *testing.T) { tests := []struct { name string pod *v1.Pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 60K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
status = framework.AsStatus(fmt.Errorf("expected at least one victim pod on node %q", nodeInfoCopy.Node().Name)) } statusesLock.Lock() if status.Code() == framework.Error { errs = append(errs, status.AsError()) } nodeStatuses[nodeInfoCopy.Node().Name] = status statusesLock.Unlock() } fh.Parallelizer().Until(ctx, len(potentialNodes), checkNode, ev.PluginName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultModelBuilder.java
&& (version == null || message.contains(version)); } protected boolean hasModelErrors(ModelProblemCollector problems) { return problems.hasErrors(); } protected boolean hasFatalErrors(ModelProblemCollector problems) { return problems.hasFatalErrors(); } ModelProcessor getModelProcessor() {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Jun 07 07:31:02 UTC 2024 - 61.9K bytes - Viewed (0)