- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 135 for Queuing (0.11 sec)
-
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/DynamicVersionResolver.java
// Queue this up for checking again later // This is done because we're checking what we have locally in cache, and there may be nothing // so we're queuing it back so that the next time we check in remote access. if (request.canMakeFurtherAttempts()) { missing.add(request); } break;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Dec 13 17:41:33 UTC 2023 - 26.8K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/prioritylevelconfiguration_test.go
limited := b.object.Spec.Limited if limited == nil { return b } limited.LimitResponse.Type = flowcontrolv1.LimitResponseTypeQueue limited.LimitResponse.Queuing = &flowcontrolv1.QueuingConfiguration{ Queues: queues, HandSize: handSize, QueueLengthLimit: queueLengthLimit, } return b
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 19.8K bytes - Viewed (0) -
src/time/tick_test.go
// Trybots are slower, so it will fail even more reliably there. // With the fix, the code runs in under a second. done := make(chan bool) AfterFunc(60*Second, func() { close(done) }) // Set up a queuing goroutine to ping pong through the scheduler. inQ := make(chan func()) outQ := make(chan func()) defer close(inQ) wg.Add(1) go func() { defer wg.Done() defer close(outQ)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/gen_test.go
Type: flowcontrol.LimitResponseTypeReject}}}} if rng.Float32() < 0.95 { plc.Spec.Limited.LimitResponse.Type = flowcontrol.LimitResponseTypeQueue hs := rng.Int31n(5) + 1 plc.Spec.Limited.LimitResponse.Queuing = &flowcontrol.QueuingConfiguration{ Queues: hs + rng.Int31n(20), HandSize: hs, QueueLengthLimit: 5} } labelVals := []string{"test"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 24.8K bytes - Viewed (0) -
api/openapi-spec/v3/apis__flowcontrol.apiserver.k8s.io__v1beta3_openapi.json
"properties": { "queuing": { "allOf": [ { "$ref": "#/components/schemas/io.k8s.api.flowcontrol.v1beta3.QueuingConfiguration" } ], "description": "`queuing` holds the configuration parameters for queuing. This field may be non-empty only if `type` is `\"Queue\"`." },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 232.7K bytes - Viewed (0) -
api/openapi-spec/v3/apis__flowcontrol.apiserver.k8s.io__v1_openapi.json
"properties": { "queuing": { "allOf": [ { "$ref": "#/components/schemas/io.k8s.api.flowcontrol.v1.QueuingConfiguration" } ], "description": "`queuing` holds the configuration parameters for queuing. This field may be non-empty only if `type` is `\"Queue\"`." }, "type": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 231.7K bytes - Viewed (0) -
cluster/log-dump/log-dump.sh
# seems to treat them as non-empty with single empty string. if [[ -n "${NON_LOGEXPORTED_NODES:-}" ]]; then for node in "${NON_LOGEXPORTED_NODES[@]:-}"; do echo "Logexporter didn't succeed on node ${node}. Queuing it for logdump through SSH." failed_nodes+=("${node}") done fi # If less than a certain ratio of the nodes got logexported, report an error.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 21:15:57 UTC 2024 - 28.9K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
return nil, err } } if requeueAfter != nil { logger.V(4).Info("Re-queuing cronjob", "cronjob", klog.KObj(cronJob), "requeueAfter", requeueAfter) return requeueAfter, nil } // this marks the key done, currently only happens when the cronjob is suspended or spec has invalid schedule format
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformWithDependenciesIntegrationTest.groovy
// NOTE: filter out the dependency to trigger the problem, so that the main thread, which holds the project lock, does not see and isolate the second transform while // queuing the transforms for execution // The problem can potentially also be triggered by including many direct dependencies so that the queued transforms start to execute before the main thread sees the second transform
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 54.2K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
if err = controllerutil.MarkPodsNotReady(ctx, nc.kubeClient, nc.recorder, pods, node.Name); err != nil { utilruntime.HandleError(fmt.Errorf("unable to mark all pods NotReady on node %v: %v; queuing for retry", node.Name, err)) nc.nodesToRetry.Store(node.Name, struct{}{}) return } } } nc.nodesToRetry.Delete(node.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0)