Mirroristas/kaspad
2
0
Fork 0
mirror of https://github.com/kaspanet/kaspad.git synced 2025-11-28 08:11:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Implement BlockCandidateTransactions

Browse Source
This commit is contained in:
Mike Zak 2021-06-06 12:53:37 +03:00
parent 04c98ac6df
commit 619b7ab8cd
3 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
domain/miningmanager/mempool/mempool.go
View File

@ -34,8 +34,8 @@ func (mp *mempool) RemoveTransaction(transactionID *externalapi.DomainTransactio
panic("mempool.RemoveTransaction not implemented") // TODO (Mike)
}
func (mp *mempool) BlockCandidateTransactions() ([]*externalapi.DomainTransaction, error) {
panic("mempool.BlockCandidateTransactions not implemented") // TODO (Mike)
func (mp *mempool) BlockCandidateTransactions() []*externalapi.DomainTransaction {
return mp.transactionsPool.allReadyTransactions()
}
func (mp *mempool) RevalidateHighPriorityTransactions() (validTransactions []*externalapi.DomainTransaction, err error) {

2
domain/miningmanager/mempool/model.go
View File

@ -5,7 +5,7 @@ import "github.com/kaspanet/kaspad/domain/consensus/model/externalapi"
type idToTransaction map[externalapi.DomainTransactionID]*mempoolTransaction
type mempoolTransaction struct {
transaction externalapi.DomainTransaction
transaction *externalapi.DomainTransaction
parentsInPool idToTransaction
isHighPriority bool
addAtDAAScore uint64

12
domain/miningmanager/mempool/transactions_pool.go
View File

@ -35,3 +35,15 @@ func (tp *transactionsPool) addMempoolTransaction(transaction mempoolTransaction
func (tp *transactionsPool) expireOldTransactions() error {
panic("transactionsPool.expireOldTransactions not implemented") // TODO (Mike)
}
func (tp *transactionsPool) allReadyTransactions() []*externalapi.DomainTransaction {
result := []*externalapi.DomainTransaction{}
for _, mempoolTransaction := range tp.allTransactions {
if len(mempoolTransaction.parentsInPool) == 0 {
result = append(result, mempoolTransaction.transaction)
}
}
return result
}