MCPcopy
hub / github.com/netdata/netdata / shutdown

Method shutdown

src/go/plugin/framework/functions/manager.go:223–229  ·  view source on GitHub ↗
(signalQuit, cancelInflight bool, quitCh chan struct{}, workersWG *sync.WaitGroup)

Source from the content-addressed store, hash-verified

221}
222
223func (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
231func (m *Manager) signalQuitIfRequested(signalQuit bool, quitCh chan struct{}) {
232 if signalQuit && quitCh != nil {

Callers 1

runMethod · 0.95

Calls 5

setStoppingMethod · 0.95
signalQuitIfRequestedMethod · 0.95
waitWorkersMethod · 0.95

Tested by

no test coverage detected