- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for waitForTurn (0.28 sec)
-
pkg/kubelet/kuberuntime/kuberuntime_termination_order_test.go
var wg sync.WaitGroup wg.Add(1) var sidecarWaitDelay int64 var mainWaitDelay int64 go func() { sidecarWaitDelay = int64(to.waitForTurn("init", 30)) to.containerTerminated("init") wg.Done() }() wg.Add(1) go func() { mainWaitDelay = int64(to.waitForTurn("main", 0)) time.Sleep(1 * time.Second) to.containerTerminated("main") wg.Done() }() wg.Wait() if sidecarWaitDelay != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 00:07:21 UTC 2023 - 6.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_termination_order.go
} previousSidecarName = ic.Name } } return to } // waitForTurn waits until it is time for the container with the specified name to begin terminating, up until // the specified grace period. If gracePeriod = 0, there is no wait. func (o *terminationOrdering) waitForTurn(name string, gracePeriod int64) float64 { // if there is no grace period, we don't wait if gracePeriod <= 0 { return 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 00:07:21 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
// time remaining if ordering != nil && gracePeriod > 0 { // grace period is only in seconds, so the time we've waited gets truncated downward gracePeriod -= int64(ordering.waitForTurn(containerName, gracePeriod)) } // always give containers a minimal shutdown window to avoid unnecessary SIGKILLs if gracePeriod < minimumGracePeriodInSeconds { gracePeriod = minimumGracePeriodInSeconds }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0)