diff --git a/domain/consensus/consensus.go b/domain/consensus/consensus.go index f4e77bf90..d45addf63 100644 --- a/domain/consensus/consensus.go +++ b/domain/consensus/consensus.go @@ -2,6 +2,7 @@ package consensus import ( "github.com/kaspanet/kaspad/infrastructure/db/database" + "github.com/kaspanet/kaspad/infrastructure/logger" "sync" "github.com/kaspanet/kaspad/domain/consensus/model" @@ -374,6 +375,9 @@ func (s *consensus) GetHeadersSelectedTip() (*externalapi.DomainHash, error) { } func (s *consensus) GetVirtualUTXOSet() ([]*externalapi.OutpointUTXOPair, error) { + onEnd := logger.LogAndMeasureExecutionTime(log, "consensus.GetVirtualUTXOSet") + defer onEnd() + s.lock.Lock() defer s.lock.Unlock() diff --git a/domain/utxoindex/store.go b/domain/utxoindex/store.go index b049c8a6f..e2e8e4b9f 100644 --- a/domain/utxoindex/store.go +++ b/domain/utxoindex/store.go @@ -309,11 +309,15 @@ func (uis *utxoIndexStore) replaceUTXOSet(utxoSet []*externalapi.OutpointUTXOPai } uis.virtualSelectedParent = virtualSelectedParent - for _, pair := range utxoSet { + for i, pair := range utxoSet { err := uis.add(pair.Entry.ScriptPublicKey(), pair.Outpoint, pair.Entry) if err != nil { return err } + const logInterval = 10_000 + if i%logInterval == 0 { + log.Debugf("Recovered %d UTXO entries out of %d", i+1, len(utxoSet)) + } } return uis.commit()