Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for asError (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. internal/event/target/elasticsearch.go

    	}
    	xhttp.DrainBody(resp.Body)
    	return !resp.IsError(), nil
    }
    
    func (c *esClientV7) entryExists(ctx context.Context, index string, key string) (bool, error) {
    	res, err := c.Exists(
    		index,
    		key,
    		c.Exists.WithContext(ctx),
    	)
    	if err != nil {
    		return false, err
    	}
    	xhttp.DrainBody(res.Body)
    	return !res.IsError(), nil
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15K bytes
    - Viewed (0)
  5. subprojects/core/src/integTest/groovy/org/gradle/api/tasks/TaskParametersIntegrationTest.groovy

    task someTask(type: SomeTask) {
        v = $initialValue
        d = file("build/out")
    }
    """
            def isError = expectedValidationProblem != null
    
            when:
            if (isError) {
                fails 'someTask'
            } else {
                succeeds "someTask"
            }
    
            then:
            if (isError) {
                failure.error.contains(expectedValidationProblem)
            }
    
            when:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 09:03:53 UTC 2024
    - 36.3K bytes
    - Viewed (0)
  6. pkg/kubelet/lifecycle/handlers_test.go

    			container.Lifecycle.PostStart.HTTPGet.Port = tt.Port
    			pod.Spec.Containers = []v1.Container{container}
    			_, err := handlerRunner.Run(ctx, containerID, &pod, &container, container.Lifecycle.PostStart)
    
    			if hasError := (err != nil); hasError != tt.ExpectError {
    				t.Errorf("unexpected error: %v", err)
    			}
    
    			if fakeHTTPDoer.url != tt.Expected {
    				t.Errorf("unexpected url: %s", fakeHTTPDoer.url)
    			}
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  7. src/go/build/deps_test.go

    	< internal/msan
    	< internal/asan
    	< internal/weak
    	< sync
    	< internal/bisect
    	< internal/godebug
    	< internal/reflectlite
    	< errors
    	< internal/oserror;
    
    	cmp, internal/race, math/bits
    	< iter
    	< maps, slices;
    
    	internal/oserror, maps, slices
    	< RUNTIME;
    
    	RUNTIME
    	< sort
    	< container/heap;
    
    	RUNTIME
    	< io;
    
    	RUNTIME
    	< arena;
    
    	syscall !< io;
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 16:41:13 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  8. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirPsiTypeProvider.kt

            preserveAnnotations: Boolean,
        ): PsiType? {
            val coneType = type.coneType
    
            with(rootModuleSession.typeContext) {
                if (!allowErrorTypes && coneType.contains { it.isError() }) {
                    return null
                }
            }
    
            if (!rootModuleSession.moduleData.platform.has<JvmPlatform>()) return null
    
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Wed May 29 20:26:34 UTC 2024
    - 18.4K bytes
    - Viewed (0)
Back to top