mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-05 06:46:48 +00:00
Code Activity

Activating timed exit

Browse source
This commit is contained in:
postmannen 2021-08-03 12:30:18 +02:00
parent 410f3ff717
commit 7002ca4364
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
server.go
View file

@ -288,8 +288,8 @@ func (s *server) Start() {
// Adding a safety function here so we can make sure that all processes // Adding a safety function here so we can make sure that all processes
// are stopped after a given time if the context cancelation below hangs. // are stopped after a given time if the context cancelation below hangs.
func() { go func() {
time.Sleep(time.Second * 0) time.Sleep(time.Second * 5)
log.Printf("error: doing a non graceful shutdown of all processes..\n") log.Printf("error: doing a non graceful shutdown of all processes..\n")
os.Exit(1) os.Exit(1)
}() }()
@ -302,7 +302,7 @@ func (s *server) Start() {
// the state if the messages received have been processed or not, so it is not // the state if the messages received have been processed or not, so it is not
// deeply needed to implement this. // deeply needed to implement this.
// But still.. Need to look into this. // But still.. Need to look into this.
time.Sleep(time.Second * 10) //time.Sleep(time.Second * 10)
s.ctxCancelFunc() s.ctxCancelFunc()
fmt.Printf(" *** Done: ctxCancelFunc()\n") fmt.Printf(" *** Done: ctxCancelFunc()\n")