aboutsummaryrefslogtreecommitdiffstats
path: root/core/transaction_pool.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-12-18 20:22:59 +0800
committerobscuren <geffobscura@gmail.com>2014-12-18 20:22:59 +0800
commit0dc566124aee24cf3f01b4e586bde7752da89824 (patch)
tree22bfe271447f8b42598b3066cb92d87df93c7095 /core/transaction_pool.go
parent721e8ae93f9b8918ff4bc74af86c530bacacea00 (diff)
downloadgo-tangerine-0dc566124aee24cf3f01b4e586bde7752da89824.tar.gz
go-tangerine-0dc566124aee24cf3f01b4e586bde7752da89824.tar.zst
go-tangerine-0dc566124aee24cf3f01b4e586bde7752da89824.zip
Merge fixes
Diffstat (limited to 'core/transaction_pool.go')
-rw-r--r--core/transaction_pool.go6
1 files changed, 2 insertions, 4 deletions
diff --git a/core/transaction_pool.go b/core/transaction_pool.go
index 86286f23d..2bbda7d90 100644
--- a/core/transaction_pool.go
+++ b/core/transaction_pool.go
@@ -72,19 +72,17 @@ type TxPool struct {
subscribers []chan TxMsg
- broadcaster types.Broadcaster
chainManager *ChainManager
eventMux *event.TypeMux
}
-func NewTxPool(chainManager *ChainManager, broadcaster types.Broadcaster, eventMux *event.TypeMux) *TxPool {
+func NewTxPool(chainManager *ChainManager, eventMux *event.TypeMux) *TxPool {
return &TxPool{
pool: list.New(),
queueChan: make(chan *types.Transaction, txPoolQueueSize),
quit: make(chan bool),
chainManager: chainManager,
eventMux: eventMux,
- broadcaster: broadcaster,
}
}
@@ -96,7 +94,7 @@ func (pool *TxPool) addTransaction(tx *types.Transaction) {
pool.pool.PushBack(tx)
// Broadcast the transaction to the rest of the peers
- pool.Ethereum.EventMux().Post(TxPreEvent{tx})
+ pool.eventMux.Post(TxPreEvent{tx})
}
func (pool *TxPool) ValidateTransaction(tx *types.Transaction) error {