diff options
Diffstat (limited to 'ledger/catchupaccessor.go')
| -rw-r--r-- | ledger/catchupaccessor.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/ledger/catchupaccessor.go b/ledger/catchupaccessor.go index 38b396b19..784a258c7 100644 --- a/ledger/catchupaccessor.go +++ b/ledger/catchupaccessor.go @@ -121,7 +121,7 @@ const ( func MakeCatchpointCatchupAccessor(ledger *Ledger, log logging.Logger) CatchpointCatchupAccessor { rdb := ledger.trackerDB().Rdb wdb := ledger.trackerDB().Wdb - accountsq, err := accountsDbInit(rdb.Handle, wdb.Handle) + accountsq, err := accountsInitDbQueries(rdb.Handle, wdb.Handle) if err != nil { log.Warnf("unable to initialize account db in MakeCatchpointCatchupAccessor : %v", err) return nil @@ -193,7 +193,7 @@ func (c *CatchpointCatchupAccessorImpl) ResetStagingBalances(ctx context.Context return fmt.Errorf("unable to reset catchpoint catchup balances : %v", err) } if !newCatchup { - sq, err := accountsDbInit(tx, tx) + sq, err := accountsInitDbQueries(tx, tx) if err != nil { return fmt.Errorf("unable to initialize accountsDbInit: %v", err) } @@ -271,7 +271,7 @@ func (c *CatchpointCatchupAccessorImpl) processStagingContent(ctx context.Contex start := time.Now() ledgerProcessstagingcontentCount.Inc(nil) err = wdb.Atomic(func(ctx context.Context, tx *sql.Tx) (err error) { - sq, err := accountsDbInit(tx, tx) + sq, err := accountsInitDbQueries(tx, tx) if err != nil { return fmt.Errorf("CatchpointCatchupAccessorImpl::processStagingContent: unable to initialize accountsDbInit: %v", err) } @@ -665,7 +665,7 @@ func (c *CatchpointCatchupAccessorImpl) StoreBalancesRound(ctx context.Context, start := time.Now() ledgerStorebalancesroundCount.Inc(nil) err = wdb.Atomic(func(ctx context.Context, tx *sql.Tx) (err error) { - sq, err := accountsDbInit(tx, tx) + sq, err := accountsInitDbQueries(tx, tx) if err != nil { return fmt.Errorf("CatchpointCatchupAccessorImpl::StoreBalancesRound: unable to initialize accountsDbInit: %v", err) } @@ -769,7 +769,7 @@ func (c *CatchpointCatchupAccessorImpl) finishBalances(ctx context.Context) (err var balancesRound uint64 var totals ledgercore.AccountTotals - sq, err := accountsDbInit(tx, tx) + sq, err := accountsInitDbQueries(tx, tx) if err != nil { return fmt.Errorf("unable to initialize accountsDbInit: %v", err) } |