fix(go.d): avoid blocking all jobs when stopping a slow job (#21448)

fix(go.d): avoid blocking all jobs when stopping a slow job (#21448) · netdata/netdata@510f134

File tree

lines changed

lines changed

Original file line number	Diff line number	Diff line change
`@@ -259,24 +259,25 @@ func (m *Manager) runNotifyRunningJobs() {`
`259`	`259`	`}`
`260`	`260`
`261`	`261`	`func (m Manager) startRunningJob(job module.Job) {`
	`262`	`+m.stopRunningJob(job.FullName())`
	`263`	`+`
`262`	`264`	`m.runningJobs.lock()`
`263`	`265`	`defer m.runningJobs.unlock()`
`264`	`266`
`265`		`-if job, ok := m.runningJobs.lookup(job.FullName()); ok {`
`266`		`-job.Stop()`
`267`		`- }`
`268`		`-`
`269`	`267`	`go job.Start()`
`270`	`268`	`m.runningJobs.add(job.FullName(), job)`
`271`	`269`	`}`
`272`	`270`
`273`	`271`	`func (m *Manager) stopRunningJob(name string) {`
`274`	`272`	`m.runningJobs.lock()`
`275`		`-defer m.runningJobs.unlock()`
	`273`	`+job, ok := m.runningJobs.lookup(name)`
	`274`	`+if ok {`
	`275`	`+m.runningJobs.remove(name)`
	`276`	`+ }`
	`277`	`+m.runningJobs.unlock()`
`276`	`278`
`277`		`-if job, ok := m.runningJobs.lookup(name); ok {`
	`279`	`+if ok {`
`278`	`280`	`job.Stop()`
`279`		`-m.runningJobs.remove(name)`
`280`	`281`	`}`
`281`	`282`	`}`
`282`	`283`