Superminaren
/
kvm
mirror of https://github.com/jetkvm/kvm.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Golang standards :)

This commit is contained in:
tutman96 2025-01-05 19:44:34 +00:00
parent 562f6c406c
commit e764000697
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/plugin/process_manager.go
View File

@ -9,8 +9,10 @@ import (
) )
// TODO: this can probably be defaulted to this, but overwritten on a per-plugin basis // TODO: this can probably be defaulted to this, but overwritten on a per-plugin basis
const GRACEFUL_SHUTDOWN_DELAY = 30 * time.Second const (
const MAX_RESTART_BACKOFF = 30 * time.Second gracefulShutdownDelay = 30 * time.Second
maxRestartBackoff = 30 * time.Second
)
type ProcessManager struct { type ProcessManager struct {
cmdGen func() *exec.Cmd cmdGen func() *exec.Cmd
@ -75,8 +77,8 @@ func (pm *ProcessManager) scheduleRestart() {
log.Printf("Restarting process in %v...", pm.backoff) log.Printf("Restarting process in %v...", pm.backoff)
time.Sleep(pm.backoff) time.Sleep(pm.backoff)
pm.backoff *= 2 // Exponential backoff pm.backoff *= 2 // Exponential backoff
if pm.backoff > MAX_RESTART_BACKOFF { if pm.backoff > maxRestartBackoff {
pm.backoff = MAX_RESTART_BACKOFF pm.backoff = maxRestartBackoff
} }
pm.restartCh <- struct{}{} pm.restartCh <- struct{}{}
} }
@ -87,7 +89,7 @@ func (pm *ProcessManager) terminate() {
log.Printf("Sending SIGTERM...") log.Printf("Sending SIGTERM...")
pm.cmd.Process.Signal(syscall.SIGTERM) pm.cmd.Process.Signal(syscall.SIGTERM)
select { select {
case <-time.After(GRACEFUL_SHUTDOWN_DELAY): case <-time.After(gracefulShutdownDelay):
log.Printf("Forcing process termination...") log.Printf("Forcing process termination...")
pm.cmd.Process.Kill() pm.cmd.Process.Kill()
case <-pm.waitForExit(): case <-pm.waitForExit():