From 70dc9702bd651e970fc7d6bc4a8df21d214c8207 Mon Sep 17 00:00:00 2001 From: Sasha Koshka Date: Wed, 17 Sep 2025 14:54:12 -0400 Subject: [PATCH] Add a --fast-timing option to make things happen sooner The smaller time scale is better for debugging --- environment.go | 8 ++++++++ phases.go | 10 +++++++--- 2 files changed, 15 insertions(+), 3 deletions(-) diff --git a/environment.go b/environment.go index ec57b9b..50cca69 100644 --- a/environment.go +++ b/environment.go @@ -43,6 +43,7 @@ type environment struct { verbose bool crash bool crashOnError bool + fastTiming bool } // running stores whether the environment is currently running. @@ -418,6 +419,7 @@ func (this *environment) applyConfig() error { } return nil } + // TODO: trim interval err := parseDuration("init-timeout", &this.timing.initTimeout) if err != nil { return err } err = parseDuration("restart-threshold", &this.timing.restartThreshold) @@ -434,6 +436,12 @@ func (this *environment) applyConfig() error { if err != nil { return err } err = parseDuration("shutdown-timeout", &this.timing.shutdownTimeout) if err != nil { return err } + + if this.flags.fastTiming { + this.timing.shutdownTimeout.Store(this.timing.shutdownTimeout.Load() / 60) + // TODO: quicken trim interval + } + return nil } diff --git a/phases.go b/phases.go index 1f9ddd3..0fd87c3 100644 --- a/phases.go +++ b/phases.go @@ -24,9 +24,10 @@ func (this *environment) phase10FlagParsing() bool { flagUser := set.Flag('u', "user", "The user:group to run as", cli.ValString) flagLogDirectory := set.Flag('l', "log-directory", "Write logs to the specified directory", cli.ValString) flagConfigFile := set.Flag('c', "config-file", "Use this configuration file", cli.ValString) - flagVerbose := set.Flag('v', "verbose", "Enable verbose output/logging", nil) - flagCrash := set.Flag(0, "crash", "Crash when an actor panics", nil) - flagCrashOnError := set.Flag(0, "crash-on-error", "Crash when an actor experiences any error", nil) + flagVerbose := set.Flag('v', "verbose", "(debug) Enable verbose output/logging", nil) + flagCrash := set.Flag(0, "crash", "(debug) Crash when an actor panics", nil) + flagCrashOnError := set.Flag(0, "crash-on-error", "(debug) Crash when an actor experiences any error", nil) + flagFastTiming := set.Flag(0, "fast-timing", "(debug) Make timed things happen faster/more often", nil) // ask actors to add flags actors, done := this.actors.RBorrow() @@ -70,6 +71,9 @@ func (this *environment) phase10FlagParsing() bool { this.flags.crash = true this.flags.crashOnError = true } + if _, ok := flagFastTiming.First(); ok { + this.flags.fastTiming = true + } return true }