Commit 0e9c8568 authored by obscuren's avatar obscuren

Re broadcast transactions

parent 2667cb3a
...@@ -381,6 +381,7 @@ func (p *Peer) HandleInbound() { ...@@ -381,6 +381,7 @@ func (p *Peer) HandleInbound() {
} }
case ethwire.MsgTxTy: case ethwire.MsgTxTy:
fmt.Println("received tx")
// If the message was a transaction queue the transaction // If the message was a transaction queue the transaction
// in the TxPool where it will undergo validation and // in the TxPool where it will undergo validation and
// processing when a new block is found // processing when a new block is found
...@@ -658,10 +659,8 @@ func (p *Peer) CatchupWithPeer(blockHash []byte) { ...@@ -658,10 +659,8 @@ func (p *Peer) CatchupWithPeer(blockHash []byte) {
ethutil.Config.Log.Debugf("Requesting blockchain %x... from peer %s\n", p.ethereum.BlockChain().CurrentBlock.Hash()[:4], p.conn.RemoteAddr()) ethutil.Config.Log.Debugf("Requesting blockchain %x... from peer %s\n", p.ethereum.BlockChain().CurrentBlock.Hash()[:4], p.conn.RemoteAddr())
/* msg = ethwire.NewMessage(ethwire.MsgGetTxsTy, []interface{}{})
msg = ethwire.NewMessage(ethwire.MsgGetTxsTy, []interface{}{}) p.QueueMessage(msg)
p.QueueMessage(msg)
*/
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment