diff options
author | obscuren <geffobscura@gmail.com> | 2014-12-18 20:22:59 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-12-18 20:22:59 +0800 |
commit | 0dc566124aee24cf3f01b4e586bde7752da89824 (patch) | |
tree | 22bfe271447f8b42598b3066cb92d87df93c7095 /core/transaction_pool.go | |
parent | 721e8ae93f9b8918ff4bc74af86c530bacacea00 (diff) | |
download | go-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.go | 6 |
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 { |