summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJohn Lee <64482439+algojohnlee@users.noreply.github.com>2022-07-09 21:21:04 -0400
committerGitHub <noreply@github.com>2022-07-09 21:21:04 -0400
commitfca9e64fbb8b38bc3b5c41f2a042b68652a80ebc (patch)
tree6c9858d56c71664fa4461761968eebe335c0af56
parent641a1f1316904f78895fb9080532f04fdb0bd5fd (diff)
parent73615e0b7e3409b2d8f5158d77d812fa322483fd (diff)
Merge pull request #4252 from onetechnical/relbeta3.8.1v3.8.1-beta
-rw-r--r--buildnumber.dat2
-rw-r--r--ledger/internal/prefetcher/prefetcher.go44
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:
}