Stop shuts down Module
()
| 142 | |
| 143 | // Stop shuts down Module |
| 144 | func (this *Module) run() { |
| 145 | for { |
| 146 | select { |
| 147 | case _ = <-this.ctx.Done(): |
| 148 | err := this.child.Stop() |
| 149 | if err != nil { |
| 150 | this.logger.Fatalf("%s\t stop Module error:%v.", this.child.Name(), err) |
| 151 | } |
| 152 | return |
| 153 | } |
| 154 | } |
| 155 | } |
| 156 | |
| 157 | func (this *Module) readEvents() error { |
| 158 | var errChan = make(chan error, 8) |