From b8d2372899b840cb82989c4a5f8170fe995a8b86 Mon Sep 17 00:00:00 2001 From: "Alexander A. Klimov" Date: Mon, 19 Apr 2021 18:22:48 +0200 Subject: [PATCH] Sync#Sync(): don't run no-ops --- pkg/icingadb/sync.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/pkg/icingadb/sync.go b/pkg/icingadb/sync.go index 5c03986f..0dd1e733 100644 --- a/pkg/icingadb/sync.go +++ b/pkg/icingadb/sync.go @@ -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())