core: added accessor for queued transactions

1 files changed, 12 insertions, 0 deletions

diff --git a/core/transaction_pool.go b/core/transaction_pool.go
index 9c175e568..7098dba23 100644
--- a/core/transaction_pool.go
+++ b/core/transaction_pool.go
@@ -201,6 +201,18 @@ func (self *TxPool) GetTransactions() (txs types.Transactions) {
 	return
 }
 
+func (self *TxPool) GetQueuedTransactions() types.Transactions {
+	self.mu.RLock()
+	defer self.mu.RUnlock()
+
+	var txs types.Transactions
+	for _, ts := range self.queue {
+		txs = append(txs, ts...)
+	}
+
+	return txs
+}
+
 func (self *TxPool) RemoveTransactions(txs types.Transactions) {
 	self.mu.Lock()
 	defer self.mu.Unlock()