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

Merge pull request #35 from lippserd/bugfix/deleted0

Browse source 
Sync#Sync(): don't run no-ops
This commit is contained in:
Eric Lippmann 2021-04-19 22:46:39 +02:00 committed by GitHub
commit fd5589cb02
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
pkg/icingadb/sync.go
View file

@ -74,7 +74,7 @@ func (s Sync) Sync(ctx context.Context, factoryFunc contracts.EntityFactoryFunc)
}
// Create
{
if len(delta.Create) > 0 {
var entities <-chan contracts.Entity
if delta.WithChecksum {
pairs, errs := s.redis.HMYield(
@ -102,7 +102,7 @@ func (s Sync) Sync(ctx context.Context, factoryFunc contracts.EntityFactoryFunc)
}
// Update
{
if len(delta.Update) > 0 {
s.logger.Infof("Updating %d rows of type %s", len(delta.Update), utils.Key(utils.Name(v), ' '))
pairs, errs := s.redis.HMYield(
ctx,
@ -129,7 +129,7 @@ func (s Sync) Sync(ctx context.Context, factoryFunc contracts.EntityFactoryFunc)
}
// Delete
{
if len(delta.Delete) > 0 {
s.logger.Infof("Deleting %d rows of type %s", len(delta.Delete), utils.Key(utils.Name(v), ' '))
g.Go(func() error {
return s.db.BulkExec(ctx, s.db.BuildDeleteStmt(v), 1<<15, 1<<3, delta.Delete.IDs())