(signalQuit, cancelInflight bool, quitCh chan struct{}, workersWG *sync.WaitGroup)
| 221 | } |
| 222 | |
| 223 | func (m *Manager) shutdown(signalQuit, cancelInflight bool, quitCh chan struct{}, workersWG *sync.WaitGroup) { |
| 224 | m.setStopping(true) |
| 225 | m.signalQuitIfRequested(signalQuit, quitCh) |
| 226 | m.stopSchedulerAdmission() |
| 227 | timedOut := m.waitWorkers(workersWG) |
| 228 | m.finalizeUnresolvedOnShutdown(cancelInflight, timedOut) |
| 229 | } |
| 230 | |
| 231 | func (m *Manager) signalQuitIfRequested(signalQuit bool, quitCh chan struct{}) { |
| 232 | if signalQuit && quitCh != nil { |
no test coverage detected