aboutsummaryrefslogtreecommitdiff
path: root/service
diff options
context:
space:
mode:
authorMike Crute <mike@crute.us>2022-11-23 15:38:29 -0800
committerMike Crute <mike@crute.us>2022-11-23 15:38:29 -0800
commit21d02e0ee33a30966a8b93e4f6a3e35540548ce6 (patch)
tree58cc7e51dd8319c47144707c05a3d13333c845c2 /service
parenta1e017514304206e2fccd72eaa6825f1d7911c79 (diff)
downloadgolib-21d02e0ee33a30966a8b93e4f6a3e35540548ce6.tar.bz2
golib-21d02e0ee33a30966a8b93e4f6a3e35540548ce6.tar.xz
golib-21d02e0ee33a30966a8b93e4f6a3e35540548ce6.zip
service: fix shutdown bugv0.4.2
Diffstat (limited to 'service')
-rw-r--r--service/app_runner.go23
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") 124done:
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}