summaryrefslogtreecommitdiff
path: root/node/netprio.go
diff options
context:
space:
mode:
Diffstat (limited to 'node/netprio.go')
-rw-r--r--node/netprio.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/node/netprio.go b/node/netprio.go
index c65db60d4..d3a4e99b6 100644
--- a/node/netprio.go
+++ b/node/netprio.go
@@ -80,12 +80,12 @@ func (node *AlgorandFullNode) MakePrioResponse(challenge string) []byte {
voteRound := latest + 2
for _, part := range node.accountManager.Keys(voteRound) {
parent := part.Address()
- data, err := node.ledger.Lookup(latest, parent)
+ data, err := node.ledger.LookupAgreement(latest, parent)
if err != nil {
continue
}
- weight := data.MicroAlgos.ToUint64()
+ weight := data.MicroAlgosWithRewards.ToUint64()
if weight > maxWeight {
maxPart = part
maxWeight = weight
@@ -125,7 +125,7 @@ func (node *AlgorandFullNode) VerifyPrioResponse(challenge string, response []by
return
}
- data, err := node.ledger.Lookup(balanceRound, rs.Sender)
+ data, err := node.ledger.LookupAgreement(balanceRound, rs.Sender)
if err != nil {
return
}
@@ -143,10 +143,10 @@ func (node *AlgorandFullNode) VerifyPrioResponse(challenge string, response []by
// GetPrioWeight implements the network.NetPrioScheme interface
func (node *AlgorandFullNode) GetPrioWeight(addr basics.Address) uint64 {
latest := node.ledger.LastRound()
- data, err := node.ledger.Lookup(latest, addr)
+ data, err := node.ledger.LookupAgreement(latest, addr)
if err != nil {
return 0
}
- return data.MicroAlgos.ToUint64()
+ return data.MicroAlgosWithRewards.ToUint64()
}