- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 387 for termination (0.22 sec)
-
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
fn() } func newSignalInterceptingTestStep() *signalInterceptingTestStep { return &signalInterceptingTestStep{ doneCh: make(chan struct{}), } } // This test exercises the graceful termination scenario // described in the following diagram // - every vertical line is an independent timeline // - the leftmost vertical line represents the go routine that // is executing GenericAPIServer.Run method
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
cni/pkg/cmd/root.go
if err = installer.Run(ctx); err != nil { if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) { log.Infof("installer complete: %v", err) // Error was caused by interrupt/termination signal err = nil } else { log.Errorf("installer failed: %v", err) } } if cleanErr := installer.Cleanup(); cleanErr != nil { if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 13K bytes - Viewed (0) -
src/runtime/mprof.go
// snapshot as of the last mark termination without advancing the heap // profile cycle. func mProf_PostSweep() { // Flush cycle C+1 to the active profile so everything as of // the last mark termination becomes visible. *Don't* advance // the cycle, since we're still accumulating allocs in cycle // C+2, which have to become C+1 in the next mark termination // and so on. cycle := mProfCycle.read() + 1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// Unlike the other cases, we actually want to use the "old" event for terminated job pods // - kubernetes will (weirdly) issue a new status to the pod with no IP on termination, meaning // our check of `pod.status` will fail for (some) termination events. // // We will get subsequent events that append a new status with the IP put back, but it's simpler // and safer to just check the old pod status for the IP.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
src/cmd/go/script_test.go
timeout := time.Until(deadline) // If time allows, increase the termination grace period to 5% of the // remaining time. if gp := timeout / 20; gp > gracePeriod { gracePeriod = gp } // When we run commands that execute subprocesses, we want to reserve two // grace periods to clean up. We will send the first termination signal when // the context expires, then wait one grace period for the process to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 18:15:22 UTC 2024 - 12.2K bytes - Viewed (0) -
pkg/kubelet/container/runtime.go
// as termination message output across all containers. Containers will be evenly truncated // until output is below this limit. MaxPodTerminationMessageLogLength = 1024 * 12 // MaxContainerTerminationMessageLength is the upper bound any one container may write to // its termination message path. Contents above this length will be truncated.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K bytes - Viewed (0) -
docs/en/docs/fastapi-cli.md
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Jun 12 23:39:50 UTC 2024 - 6.1K bytes - Viewed (0) -
src/internal/fuzz/worker.go
// // coordinate loops until ctx is canceled or a fatal error is encountered. // If a test process terminates unexpectedly while fuzzing, coordinate will // attempt to restart and continue unless the termination can be attributed // to an interruption (from a timer or the user). // // While looping, coordinate receives inputs from the coordinator, passes // those inputs to the worker process, then passes the results back to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 37.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
kubelet_working_pods{config="orphan",lifecycle="terminating",static=""} 0 kubelet_working_pods{config="orphan",lifecycle="terminating",static="true"} 0 kubelet_working_pods{config="runtime_only",lifecycle="sync",static="unknown"} 0 kubelet_working_pods{config="runtime_only",lifecycle="terminated",static="unknown"} 0 kubelet_working_pods{config="runtime_only",lifecycle="terminating",static="unknown"} 1 `, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
* * <p>Although all tasks are immediately executed in the thread that submitted the task, this * {@code ExecutorService} imposes a small locking overhead on each task submission in order to * implement shutdown and termination behavior. * * <p>Because of the nature of single-thread execution, the methods {@code scheduleAtFixedRate} * and {@code scheduleWithFixedDelay} are not supported by this class and will throw an
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 17:12:37 UTC 2024 - 6.6K bytes - Viewed (0)