Package nxt.blockchain

Class TransactionProcessorImpl

java.lang.Object

nxt.blockchain.TransactionProcessorImpl

All Implemented Interfaces:

TransactionProcessor, Observable<List<? extends Transaction>,TransactionProcessor.Event>

public final class TransactionProcessorImpl
extends Object
implements TransactionProcessor

Nested Class Summary

Nested classes/interfaces inherited from interface nxt.blockchain.TransactionProcessor

TransactionProcessor.Event

Field Summary

Fields

Modifier and Type	Field	Description
static final int	maxUnconfirmedTransactions

Method Summary

Modifier and Type	Method	Description
boolean	addListener(Listener<List<? extends Transaction>> listener, TransactionProcessor.Event eventType)
void	broadcast(Transaction transaction)
void	broadcastLater(Transaction transaction)
void	clearUnconfirmedTransactions()
List<ChainTransactionId>	filterPeerRequestIds(Stream<ChainTransactionId> requestIdsStream, int maxSize)	Filter out any of the IDs that are known to be already available in the pool or forged.
List<Transaction>	filterPeerTransactions(List<Transaction> transactions)
TransactionImpl[]	getAllBroadcastedTransactions()
List<Long>	getAllUnconfirmedTransactionIds()
DbIterator<UnconfirmedTransaction>	getAllUnconfirmedTransactions()
DbIterator<UnconfirmedTransaction>	getAllUnconfirmedTransactions(int from, int to)
DbIterator<UnconfirmedTransaction>	getAllUnconfirmedTransactions(int from, int to, String sort)
DbIterator<UnconfirmedTransaction>	getAllUnconfirmedTransactions(String sort)
UnconfirmedTransaction[]	getAllWaitingTransactions()
List<? extends Transaction>	getCachedUnconfirmedTransactions(List<Long> exclude, int maxCount)	Get the cached unconfirmed transactions
static TransactionProcessorImpl	getInstance()
DbIterator<UnconfirmedTransaction>	getUnconfirmedChildTransactions(ChildChain childChain)
DbIterator<UnconfirmedTransaction>	getUnconfirmedFxtTransactions()
Map<String,Object>	getUnconfirmedPoolInfo()
int	getUnconfirmedPoolSize()
UnconfirmedTransaction	getUnconfirmedTransaction(long transactionId)
Collection<UnconfirmedTransaction>	getWaitingTransactions()
static void	init()
void	notifyListeners(List<? extends Transaction> transactions, TransactionProcessor.Event eventType)
void	processLater(Collection<? extends FxtTransaction> transactions)
List<TransactionImpl>	processPeerTransactions(List<Transaction> transactions)
void	rebroadcastAllUnconfirmedTransactions()
boolean	removeListener(Listener<List<? extends Transaction>> listener, TransactionProcessor.Event eventType)
void	requeueAllUnconfirmedTransactions()
List<Transaction>	restorePrunableData(List<Transaction> transactions)	Restore expired prunable data

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

maxUnconfirmedTransactions

public static final int maxUnconfirmedTransactions

Method Details

getInstance

public static TransactionProcessorImpl getInstance()

init

public static void init()

addListener

public boolean addListener(Listener<List<? extends Transaction>> listener,
 TransactionProcessor.Event eventType)

Specified by:

addListener in interface Observable<List<? extends Transaction>,TransactionProcessor.Event>

removeListener

public boolean removeListener(Listener<List<? extends Transaction>> listener,
 TransactionProcessor.Event eventType)

Specified by:

removeListener in interface Observable<List<? extends Transaction>,TransactionProcessor.Event>

notifyListeners

public void notifyListeners(List<? extends Transaction> transactions,
 TransactionProcessor.Event eventType)

getAllUnconfirmedTransactions

public DbIterator<UnconfirmedTransaction> getAllUnconfirmedTransactions()

Specified by:

getAllUnconfirmedTransactions in interface TransactionProcessor

getAllUnconfirmedTransactions

public DbIterator<UnconfirmedTransaction> getAllUnconfirmedTransactions(int from,
 int to)

Specified by:

getAllUnconfirmedTransactions in interface TransactionProcessor

getAllUnconfirmedTransactions

public DbIterator<UnconfirmedTransaction> getAllUnconfirmedTransactions(String sort)

Specified by:

getAllUnconfirmedTransactions in interface TransactionProcessor

getAllUnconfirmedTransactions

public DbIterator<UnconfirmedTransaction> getAllUnconfirmedTransactions(int from,
 int to,
 String sort)

Specified by:

getAllUnconfirmedTransactions in interface TransactionProcessor

getUnconfirmedFxtTransactions

public DbIterator<UnconfirmedTransaction> getUnconfirmedFxtTransactions()

Specified by:

getUnconfirmedFxtTransactions in interface TransactionProcessor

getUnconfirmedChildTransactions

public DbIterator<UnconfirmedTransaction> getUnconfirmedChildTransactions(ChildChain childChain)

Specified by:

getUnconfirmedChildTransactions in interface TransactionProcessor

getUnconfirmedTransaction

public UnconfirmedTransaction getUnconfirmedTransaction(long transactionId)

Specified by:

getUnconfirmedTransaction in interface TransactionProcessor

getAllUnconfirmedTransactionIds

public List<Long> getAllUnconfirmedTransactionIds()

Specified by:

getAllUnconfirmedTransactionIds in interface TransactionProcessor

getUnconfirmedPoolSize

public int getUnconfirmedPoolSize()

getAllWaitingTransactions

public UnconfirmedTransaction[] getAllWaitingTransactions()

Specified by:

getAllWaitingTransactions in interface TransactionProcessor

getWaitingTransactions

public Collection<UnconfirmedTransaction> getWaitingTransactions()

getAllBroadcastedTransactions

public TransactionImpl[] getAllBroadcastedTransactions()

Specified by:

getAllBroadcastedTransactions in interface TransactionProcessor

broadcast

public void broadcast(Transaction transaction)
               throws NxtException.ValidationException

Specified by:

broadcast in interface TransactionProcessor

Throws:

NxtException.ValidationException

broadcastLater

public void broadcastLater(Transaction transaction)

Specified by:

broadcastLater in interface TransactionProcessor

clearUnconfirmedTransactions

public void clearUnconfirmedTransactions()

Specified by:

clearUnconfirmedTransactions in interface TransactionProcessor

requeueAllUnconfirmedTransactions

public void requeueAllUnconfirmedTransactions()

Specified by:

requeueAllUnconfirmedTransactions in interface TransactionProcessor

rebroadcastAllUnconfirmedTransactions

public void rebroadcastAllUnconfirmedTransactions()

Specified by:

rebroadcastAllUnconfirmedTransactions in interface TransactionProcessor

processLater

public void processLater(Collection<? extends FxtTransaction> transactions)

Specified by:

processLater in interface TransactionProcessor

filterPeerRequestIds

public List<ChainTransactionId> filterPeerRequestIds(Stream<ChainTransactionId> requestIdsStream,
 int maxSize)

Filter out any of the IDs that are known to be already available in the pool or forged. And filter out any ids that are known to be dropped unless they are with better priority than some of the transactions in the pool or the pool is not full

Specified by:

filterPeerRequestIds in interface TransactionProcessor

Parameters:

requestIdsStream - stream of ids

maxSize - maxSize

Returns:

A list of filtered

filterPeerTransactions

public List<Transaction> filterPeerTransactions(List<Transaction> transactions)

Specified by:

filterPeerTransactions in interface TransactionProcessor

processPeerTransactions

public List<TransactionImpl> processPeerTransactions(List<Transaction> transactions)
                                              throws NxtException.NotValidException

Specified by:

processPeerTransactions in interface TransactionProcessor

Throws:

NxtException.NotValidException

getCachedUnconfirmedTransactions

public List<? extends Transaction> getCachedUnconfirmedTransactions(List<Long> exclude,
 int maxCount)

Get the cached unconfirmed transactions

Specified by:

getCachedUnconfirmedTransactions in interface TransactionProcessor

Parameters:

exclude - List of transaction identifiers to exclude

restorePrunableData

public List<Transaction> restorePrunableData(List<Transaction> transactions)

Restore expired prunable data

Specified by:

restorePrunableData in interface TransactionProcessor

Parameters:

transactions - Transactions containing prunable data

Returns:

Processed transactions

getUnconfirmedPoolInfo

public Map<String,Object> getUnconfirmedPoolInfo()

Specified by:

getUnconfirmedPoolInfo in interface TransactionProcessor