good morning!!!!

Skip to content
Snippets Groups Projects
Commit 3aeba50c authored by Jeffrey Wilcke's avatar Jeffrey Wilcke
Browse files

merge error

parent bb449572
No related branches found
No related tags found
No related merge requests found
......@@ -386,6 +386,7 @@ func (s *Ethereum) ReapDeadPeerHandler() {
// Start the ethereum
func (s *Ethereum) Start(seed bool) {
s.reactor.Start()
s.blockPool.Start()
// Bind to addr and port
ln, err := net.Listen("tcp", ":"+s.Port)
if err != nil {
......
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment