diff options
author | obscuren <geffobscura@gmail.com> | 2014-09-25 03:13:28 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-09-25 03:13:28 +0800 |
commit | 3aeba50c38e74bc1091895db1cb57e7d93864270 (patch) | |
tree | 67787cd0913b9df7b4378d959611a5cf2ed96754 /peer.go | |
parent | bb4495722f869f456f1f12234bb881ef71a7960f (diff) | |
download | go-tangerine-3aeba50c38e74bc1091895db1cb57e7d93864270.tar.gz go-tangerine-3aeba50c38e74bc1091895db1cb57e7d93864270.tar.zst go-tangerine-3aeba50c38e74bc1091895db1cb57e7d93864270.zip |
merge error
Diffstat (limited to 'peer.go')
-rw-r--r-- | peer.go | 8 |
1 files changed, 3 insertions, 5 deletions
@@ -311,7 +311,7 @@ func (p *Peer) writeMessage(msg *ethwire.Msg) { func (p *Peer) HandleOutbound() { // The ping timer. Makes sure that every 2 minutes a ping is send to the peer pingTimer := time.NewTicker(pingPongTimer) - serviceTimer := time.NewTicker(5 * time.Minute) + serviceTimer := time.NewTicker(5 * time.Second) out: for { @@ -345,10 +345,8 @@ out: // Service timer takes care of peer broadcasting, transaction // posting or block posting case <-serviceTimer.C: - if p.caps&CapPeerDiscTy > 0 { - msg := p.peersMessage() - p.ethereum.BroadcastMsg(msg) - } + + //p.QueueMessage(ethwire.NewMessage(ethwire.MsgGetPeersTy, "")) case <-p.quit: // Break out of the for loop if a quit message is posted |