upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-06-03 14:00:11 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

history.Sync: Don't operate on closed channel

Browse source
This commit is contained in:
Yonas Habteab 2024-03-28 14:52:27 +01:00
parent 51e5434374
commit ce56dffa8f
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
pkg/icingadb/history/sync.go
View file

@ -144,7 +144,11 @@ func (s Sync) deleteFromRedis(ctx context.Context, key string, input <-chan redi
stream := "icinga:history:stream:" + key
for {
select {
case bulk := <-bulks:
case bulk, ok := <-bulks:
if !ok {
return nil
}
ids := make([]string, len(bulk))
for i := range bulk {
ids[i] = bulk[i].ID