upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-05-28 04:35:54 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Finish work before killing workers

Browse source
This commit is contained in:
Noah Hilverling 2019-03-20 15:15:30 +01:00
parent 05272534d4
commit 5aa6720dff
1 changed files with 0 additions and 40 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
configobject/sync/sync.go
View file

@ -174,14 +174,6 @@ func InsertPrepWorker(super *supervisor.Supervisor, ctx *Context, done chan stru
ChBack: chInsertBack,
}
for i, key := range chunk.Keys {
select {
case _, ok := <-done:
if !ok {
return
}
default:
}
if chunk.Configs[i] == nil || chunk.Checksums[i] == nil {
continue
}
@ -254,14 +246,6 @@ func UpdateCompWorker(super *supervisor.Supervisor, ctx *Context, done chan stru
prep := func(chunk *icingadb_connection.ChecksumChunk, mysqlChecksums map[string]map[string]string) {
changed := make([]string, 0)
for i, key := range chunk.Keys {
select {
case _, ok := <-done:
if !ok {
return
}
default:
}
if chunk.Checksums[i] == nil {
continue
}
@ -299,14 +283,6 @@ func UpdateCompWorker(super *supervisor.Supervisor, ctx *Context, done chan stru
go func() {
for chunk := range ch {
select {
case _, ok := <-done:
if !ok {
return
}
default:
}
go prep(chunk, checksums)
}
}()
@ -319,14 +295,6 @@ func UpdatePrepWorker(super *supervisor.Supervisor, ctx *Context, done chan stru
ChBack: chUpdateBack,
}
for i, key := range chunk.Keys {
select {
case _, ok := <-done:
if !ok {
return
}
default:
}
if chunk.Configs[i] == nil || chunk.Checksums[i] == nil {
continue
}
@ -355,14 +323,6 @@ func UpdatePrepWorker(super *supervisor.Supervisor, ctx *Context, done chan stru
ch := super.Rdbw.PipeConfigChunks(done, keys, ctx.ObjectType)
go func() {
for chunk := range ch {
select {
case _, ok := <-done:
if !ok {
return
}
default:
}
go prep(chunk)
}
}()