From 483b20d50b83b68d65e06ebe7a676b880191c5fe Mon Sep 17 00:00:00 2001 From: Dmitrii Neeman Date: Mon, 23 Sep 2024 11:17:39 +0300 Subject: [PATCH] FMWK-405-node-list - comment update --- handler_backup_records.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/handler_backup_records.go b/handler_backup_records.go index 46a3aa39..a6c7d73f 100644 --- a/handler_backup_records.go +++ b/handler_backup_records.go @@ -178,7 +178,8 @@ func (bh *backupRecordsHandler) makeAerospikeReadWorkersForNodes( nodes := bh.aerospikeClient.GetNodes() // If bh.config.NodeList is not empty we filter nodes. nodes = filterNodes(bh.config.NodeList, nodes) - // As we can have nodes < workers, we must spread nodes only to workers. + // As we can have nodes < workers, we can't distribute a small number of nodes to a large number of workers. + // So we set workers = nodes. if len(nodes) < n { n = len(nodes) } @@ -189,7 +190,7 @@ func (bh *backupRecordsHandler) makeAerospikeReadWorkersForNodes( } readWorkers := make([]pipeline.Worker[*models.Token], n) - // As nodesGroups can be < then workers number; we iterate over groups. + for i := 0; i < n; i++ { // Skip empty groups. if len(nodesGroups[i]) == 0 {