Commit 84f161ba authored by Stefan Dähling's avatar Stefan Dähling
Browse files

fix

parent 99b7407f
Pipeline #273603 passed with stages
in 1 minute and 7 seconds
...@@ -151,9 +151,9 @@ func (agency *Agency) init() (err error) { ...@@ -151,9 +151,9 @@ func (agency *Agency) init() (err error) {
// terminate takes care of terminating all parts of the MAP before exiting. It is to be called as a // terminate takes care of terminating all parts of the MAP before exiting. It is to be called as a
// goroutine and waits until an OS signal is inserted into the channel gracefulStop // goroutine and waits until an OS signal is inserted into the channel gracefulStop
func (agency *Agency) terminate(gracefulStop chan os.Signal) { func (agency *Agency) terminate(gracefulStop chan os.Signal) {
agency.logInfo.Println("Terminating agency")
// var err error // var err error
_ = <-gracefulStop _ = <-gracefulStop
agency.logInfo.Println("Terminating agency")
agency.mutex.Lock() agency.mutex.Lock()
for i := range agency.localAgents { for i := range agency.localAgents {
agency.localAgents[i].Terminate() agency.localAgents[i].Terminate()
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment