Skip to content

Commit

Permalink
Fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
samsondav committed Nov 18, 2024
1 parent 89e51d7 commit cf277b8
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion core/services/llo/mercurytransmitter/transmitter.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ import (
"errors"
"fmt"
"io"
"strconv"
"sync"

"github.com/prometheus/client_golang/prometheus"
Expand Down Expand Up @@ -177,9 +178,10 @@ func (mt *transmitter) Start(ctx context.Context) (err error) {
// see: https://smartcontract-it.atlassian.net/browse/MERC-6635
nThreads := int(mt.cfg.TransmitConcurrency())
mt.wg.Add(2 * nThreads)
donIDStr := strconv.FormatUint(uint64(mt.donID), 10)
for i := 0; i < nThreads; i++ {
go s.runDeleteQueueLoop(mt.stopCh, mt.wg)
go s.runQueueLoop(mt.stopCh, mt.wg, fmt.Sprintf("%d", mt.donID))
go s.runQueueLoop(mt.stopCh, mt.wg, donIDStr)
}
}
if err := (&services.MultiStart{}).Start(ctx, startClosers...); err != nil {
Expand Down

0 comments on commit cf277b8

Please sign in to comment.