diff options
author | John Lee <64482439+algojohnlee@users.noreply.github.com> | 2022-07-09 21:21:04 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-07-09 21:21:04 -0400 |
commit | fca9e64fbb8b38bc3b5c41f2a042b68652a80ebc (patch) | |
tree | 6c9858d56c71664fa4461761968eebe335c0af56 | |
parent | 641a1f1316904f78895fb9080532f04fdb0bd5fd (diff) | |
parent | 73615e0b7e3409b2d8f5158d77d812fa322483fd (diff) |
Merge pull request #4252 from onetechnical/relbeta3.8.1v3.8.1-beta
-rw-r--r-- | buildnumber.dat | 2 | ||||
-rw-r--r-- | ledger/internal/prefetcher/prefetcher.go | 44 |
2 files changed, 1 insertions, 45 deletions
diff --git a/buildnumber.dat b/buildnumber.dat index 573541ac9..d00491fd7 100644 --- a/buildnumber.dat +++ b/buildnumber.dat @@ -1 +1 @@ -0 +1 diff --git a/ledger/internal/prefetcher/prefetcher.go b/ledger/internal/prefetcher/prefetcher.go index aa08d850e..e011ad23e 100644 --- a/ledger/internal/prefetcher/prefetcher.go +++ b/ledger/internal/prefetcher/prefetcher.go @@ -250,7 +250,6 @@ func loadAccountsAddResourceTask(addr *basics.Address, cidx basics.CreatableInde func (p *accountPrefetcher) prefetch(ctx context.Context) { defer close(p.outChan) accountTasks := make(map[basics.Address]*preloaderTask) - resourceTasks := make(map[accountCreatableKey]*preloaderTask) var maxTxnGroupEntries int if p.consensusParams.Application { @@ -293,52 +292,9 @@ func (p *accountPrefetcher) prefetch(ctx context.Context) { loadAccountsAddAccountTask(&stxn.Txn.Receiver, task, accountTasks, queue) loadAccountsAddAccountTask(&stxn.Txn.CloseRemainderTo, task, accountTasks, queue) case protocol.AssetConfigTx: - loadAccountsAddResourceTask(nil, basics.CreatableIndex(stxn.Txn.ConfigAsset), basics.AssetCreatable, task, resourceTasks, queue) case protocol.AssetTransferTx: - if !stxn.Txn.AssetSender.IsZero() { - loadAccountsAddResourceTask(nil, basics.CreatableIndex(stxn.Txn.XferAsset), basics.AssetCreatable, task, resourceTasks, queue) - loadAccountsAddResourceTask(&stxn.Txn.AssetSender, basics.CreatableIndex(stxn.Txn.XferAsset), basics.AssetCreatable, task, resourceTasks, queue) - } else { - loadAccountsAddResourceTask(&stxn.Txn.Sender, basics.CreatableIndex(stxn.Txn.XferAsset), basics.AssetCreatable, task, resourceTasks, queue) - if stxn.Txn.AssetAmount == 0 && (stxn.Txn.AssetReceiver == stxn.Txn.Sender) { - // opt in - loadAccountsAddResourceTask(nil, basics.CreatableIndex(stxn.Txn.XferAsset), basics.AssetCreatable, task, resourceTasks, queue) - } - } - if !stxn.Txn.AssetReceiver.IsZero() { - loadAccountsAddResourceTask(&stxn.Txn.AssetReceiver, basics.CreatableIndex(stxn.Txn.XferAsset), basics.AssetCreatable, task, resourceTasks, queue) - } - if !stxn.Txn.AssetCloseTo.IsZero() { - loadAccountsAddResourceTask(&stxn.Txn.AssetCloseTo, basics.CreatableIndex(stxn.Txn.XferAsset), basics.AssetCreatable, task, resourceTasks, queue) - } case protocol.AssetFreezeTx: - if !stxn.Txn.FreezeAccount.IsZero() { - loadAccountsAddResourceTask(nil, basics.CreatableIndex(stxn.Txn.FreezeAsset), basics.AssetCreatable, task, resourceTasks, queue) - loadAccountsAddResourceTask(&stxn.Txn.FreezeAccount, basics.CreatableIndex(stxn.Txn.FreezeAsset), basics.AssetCreatable, task, resourceTasks, queue) - loadAccountsAddAccountTask(&stxn.Txn.FreezeAccount, task, accountTasks, queue) - } case protocol.ApplicationCallTx: - if stxn.Txn.ApplicationID != 0 { - // load the global - so that we'll have the program - loadAccountsAddResourceTask(nil, basics.CreatableIndex(stxn.Txn.ApplicationID), basics.AppCreatable, task, resourceTasks, queue) - // load the local - so that we'll have the local state - // TODO: this is something we need to decide if we want to enable, since not - // every application call would use local storage. - if (stxn.Txn.ApplicationCallTxnFields.OnCompletion == transactions.OptInOC) || - (stxn.Txn.ApplicationCallTxnFields.OnCompletion == transactions.CloseOutOC) || - (stxn.Txn.ApplicationCallTxnFields.OnCompletion == transactions.ClearStateOC) { - loadAccountsAddResourceTask(&stxn.Txn.Sender, basics.CreatableIndex(stxn.Txn.ApplicationID), basics.AppCreatable, task, resourceTasks, queue) - } - } - for _, fa := range stxn.Txn.ForeignApps { - loadAccountsAddResourceTask(nil, basics.CreatableIndex(fa), basics.AppCreatable, task, resourceTasks, queue) - } - for _, fa := range stxn.Txn.ForeignAssets { - loadAccountsAddResourceTask(nil, basics.CreatableIndex(fa), basics.AssetCreatable, task, resourceTasks, queue) - } - for ixa := range stxn.Txn.Accounts { - loadAccountsAddAccountTask(&stxn.Txn.Accounts[ixa], task, accountTasks, queue) - } case protocol.CompactCertTx: case protocol.KeyRegistrationTx: } |