pull/10958/head
Yanshu Zhao 2021-03-30 16:27:50 +00:00
parent 837ff51c4a
commit 93dad50a94
2 changed files with 6 additions and 3 deletions

View File

@ -36,7 +36,6 @@ var unpauseRequests = make(chan struct{})
var done = make(chan struct{})
var mu sync.Mutex
// TODO: initialize with current state (handle the case that user enables auto-pause after it is already paused)
var runtimePaused bool
var version = "0.0.1"
@ -48,7 +47,7 @@ func main() {
const interval = time.Minute * 1
// Check current state
CheckIfPaused()
alreadyPaused()
// channel for incoming messages
go func() {
@ -126,7 +125,7 @@ func runUnpause() {
out.Step(style.Unpause, "Unpaused {{.count}} containers", out.V{"count": len(uids)})
}
func CheckIfPaused() {
func alreadyPaused() {
mu.Lock()
defer mu.Unlock()
@ -137,5 +136,8 @@ func CheckIfPaused() {
}
runtimePaused, err = cluster.CheckIfPaused(cr, []string{"kube-system"})
if err != nil {
exit.Error(reason.GuestCheckPaused, "Fail check if container paused", err)
}
out.Step(style.Check, "containers paused status: {{.paused}}", out.V{"paused": runtimePaused})
}

View File

@ -263,6 +263,7 @@ var (
GuestStatus = Kind{ID: "GUEST_STATUS", ExitCode: ExGuestError}
GuestStopTimeout = Kind{ID: "GUEST_STOP_TIMEOUT", ExitCode: ExGuestTimeout}
GuestUnpause = Kind{ID: "GUEST_UNPAUSE", ExitCode: ExGuestError}
GuestCheckPaused = Kind{ID: "GUEST_CHECK_PAUSED", ExitCode: ExGuestError}
GuestDrvMismatch = Kind{ID: "GUEST_DRIVER_MISMATCH", ExitCode: ExGuestConflict, Style: style.Conflict}
GuestMissingConntrack = Kind{ID: "GUEST_MISSING_CONNTRACK", ExitCode: ExGuestUnsupported}