- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for processPod (0.2 sec)
-
.teamcity/test-buckets.json
"launcher", "time", "logging-api", "kotlin-dsl-plugins", "serialization", "toolchains-jvm-shared", "docs-asciidoctor-extensions-base", "internal-instrumentation-processor", "security", "input-tracking", "base-ide-plugins" ] }, { "parallelizationMethod":{ "name":"TestDistribution" }, "subprojects":[ "testing-jvm",
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 15:56:44 UTC 2024 - 54.2K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
// in "rval". f must be fully processed, so that each Value is where it // will be when machine code is emitted. func BuildFuncDebug(ctxt *obj.Link, f *Func, loggingLevel int, stackOffset func(LocalSlot) int32, rval *FuncDebug) { if f.RegAlloc == nil { f.Fatalf("BuildFuncDebug on func %v that has not been fully processed", f) } state := &f.Cache.debugState
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
Pop(logger klog.Logger) (*framework.QueuedPodInfo, error) // Done must be called for pod returned by Pop. This allows the queue to // keep track of which pods are currently being processed. Done(types.UID) Update(logger klog.Logger, oldPod, newPod *v1.Pod) error Delete(pod *v1.Pod) error // TODO(sanposhiho): move all PreEnqueueCkeck to Requeue and delete it from this parameter eventually.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
t.Fatalf("Couldn't create cacher: %v", err) } defer cacher.Stop() concurrency := 1000 wg := sync.WaitGroup{} wg.Add(concurrency) // Ensure that test doesn't deadlock if cacher already processed everything // and get back into Pending state before some watches get called. ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second) defer cancel() errCh := make(chan error, concurrency)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeState.java
// then reset the state of the node that owns those dependencies. // This way, all edges of the node will be re-processed. pendingDepsVisitor.complete(); if (shouldComputeOwnStrictVersions) { storeOwnStrictVersions(strictVersionsSet); } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 58.9K bytes - Viewed (0) -
cluster/gce/windows/k8s-node-setup.psm1
} if ((Get-service $service).Status -ne 'Stopped') { # Force kill the processes. Stop-Process -Force -PassThru -Id (Get-WmiObject win32_process | Where CommandLine -Like $cmdline).ProcessId # Wait until process has stopped. $waited = 0 $log_period = 10 $timeout = 60 while ((Get-service $service).Status -ne 'Stopped' -and $waited -lt $timeout) { Start-Sleep 1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KaFirResolver.kt
is FirAnonymousFunctionExpression -> realPsi?.parent as? KtLabeledExpression ?: realPsi as? KtExpression is FirWhenSubjectExpression -> // The subject variable is not processed here as we don't have KtExpression to represent it. // K1 creates a fake expression in this case. whenRef.value.subject?.findSourceKtExpressionForCallArgument()
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Tue Jun 11 15:45:42 UTC 2024 - 73K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
if err != nil { return newErrWatcher(err), nil } // We explicitly use thread unsafe version and do locking ourself to ensure that // no new events will be processed in the meantime. The watchCache will be unlocked // on return from this function. // Note that we cannot do it under Cacher lock, to avoid a deadlock, since the // underlying watchCache is calling processEvent under its lock.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
cmd/kubelet/app/server.go
}) return cmd } // mergeKubeletConfigurations merges the provided drop-in configurations with the base kubelet configuration. // The drop-in configurations are processed in lexical order based on the file names. This means that the // configurations in files with lower numeric prefixes are applied first, followed by higher numeric prefixes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
tests/integration/ambient/baseline_test.go
from.CallOrFail(t, echo.CallOptions{ Address: "111.111.222.222", Port: to.PortForName("http"), // If request is sent before service is processed it will hit 10s timeout, so fail faster Timeout: time.Millisecond * 500, }) }) }) } } }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0)