diff options
author | Mike Crute <mike@crute.us> | 2022-11-23 15:38:29 -0800 |
---|---|---|
committer | Mike Crute <mike@crute.us> | 2022-11-23 15:38:29 -0800 |
commit | 21d02e0ee33a30966a8b93e4f6a3e35540548ce6 (patch) | |
tree | 58cc7e51dd8319c47144707c05a3d13333c845c2 | |
parent | a1e017514304206e2fccd72eaa6825f1d7911c79 (diff) | |
download | golib-0.4.2.tar.bz2 golib-0.4.2.tar.xz golib-0.4.2.zip |
service: fix shutdown bugv0.4.2
-rw-r--r-- | service/app_runner.go | 23 |
1 files changed, 11 insertions, 12 deletions
diff --git a/service/app_runner.go b/service/app_runner.go index 9d281cf..3d30571 100644 --- a/service/app_runner.go +++ b/service/app_runner.go | |||
@@ -116,19 +116,18 @@ func (r *AppRunner) RunForever(enableBg bool) { | |||
116 | // go run background if enabled | 116 | // go run background if enabled |
117 | select { | 117 | select { |
118 | case <-r.ctx.Done(): | 118 | case <-r.ctx.Done(): |
119 | r.Logger.Info("Waiting for jobs to terminate") | 119 | goto done |
120 | r.wg.Wait() | ||
121 | |||
122 | r.Logger.Info("Shutdown completed") | ||
123 | return | ||
124 | case <-r.sigs: | 120 | case <-r.sigs: |
125 | r.Logger.Info("Shutting down main app context") | 121 | goto done |
126 | r.ctxCancel() | 122 | } |
127 | 123 | ||
128 | r.Logger.Info("Waiting for jobs to terminate") | 124 | done: |
129 | r.wg.Wait() | 125 | r.Logger.Info("Shutting down main app context") |
126 | r.ctxCancel() | ||
130 | 127 | ||
131 | r.Logger.Info("Shutdown completed") | 128 | r.Logger.Info("Waiting for jobs to terminate") |
132 | return | 129 | r.wg.Wait() |
133 | } | 130 | |
131 | r.Logger.Info("Shutdown completed") | ||
132 | return | ||
134 | } | 133 | } |