aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-09-23 01:34:49 +0800
committerobscuren <geffobscura@gmail.com>2014-09-23 01:34:49 +0800
commitdf30588eb61b423a60d805b3d68d5a4e556e2a87 (patch)
treeac183aa3312a4589cb3e4995cc103cfa58ef95da
parentb65f29f8faa20a93bd83c18232326c935cb16981 (diff)
parent7d08e4f7d14600ee4ed38fc9d435e9c2e0e0fdac (diff)
downloaddexon-df30588eb61b423a60d805b3d68d5a4e556e2a87.tar.gz
dexon-df30588eb61b423a60d805b3d68d5a4e556e2a87.tar.zst
dexon-df30588eb61b423a60d805b3d68d5a4e556e2a87.zip
Merge branch 'release/0.6.5' into develop
-rw-r--r--ethereum.go2
-rw-r--r--ethwire/messaging.go2
-rw-r--r--peer.go26
3 files changed, 16 insertions, 14 deletions
diff --git a/ethereum.go b/ethereum.go
index 4cf1ce9e7..79e722c26 100644
--- a/ethereum.go
+++ b/ethereum.go
@@ -25,7 +25,7 @@ import (
const (
seedTextFileUri string = "http://www.ethereum.org/servers.poc3.txt"
- seedNodeAddress = "54.76.56.74:30303"
+ seedNodeAddress = "poc-6.ethdev.com:30303"
)
var ethlogger = ethlog.NewLogger("SERV")
diff --git a/ethwire/messaging.go b/ethwire/messaging.go
index b1cefc0ae..2ef53c003 100644
--- a/ethwire/messaging.go
+++ b/ethwire/messaging.go
@@ -111,7 +111,7 @@ func ReadMessages(conn net.Conn) (msgs []*Msg, err error) {
if n == 0 && len(buff) == 0 {
// If there's nothing on the wire wait for a bit
- time.Sleep(200)
+ time.Sleep(200 * time.Millisecond)
continue
}
diff --git a/peer.go b/peer.go
index 8c04864d0..67bf4e555 100644
--- a/peer.go
+++ b/peer.go
@@ -362,22 +362,24 @@ clean:
}
func formatMessage(msg *ethwire.Msg) (ret string) {
- ret = fmt.Sprintf("%v ", msg.Type)
+ ret = fmt.Sprintf("%v %v", msg.Type, msg.Data)
/*
XXX Commented out because I need the log level here to determine
if i should or shouldn't generate this message
*/
- switch msg.Type {
- case ethwire.MsgPeersTy:
- ret += fmt.Sprintf("(%d entries)", msg.Data.Len())
- case ethwire.MsgBlockTy:
- b1, b2 := ethchain.NewBlockFromRlpValue(msg.Data.Get(0)), ethchain.NewBlockFromRlpValue(msg.Data.Get(msg.Data.Len()-1))
- ret += fmt.Sprintf("(%d entries) %x - %x", msg.Data.Len(), b1.Hash()[0:4], b2.Hash()[0:4])
- case ethwire.MsgBlockHashesTy:
- h1, h2 := msg.Data.Get(0).Bytes(), msg.Data.Get(msg.Data.Len()-1).Bytes()
- ret += fmt.Sprintf("(%d entries) %x - %x", msg.Data.Len(), h1[0:4], h2[0:4])
- }
+ /*
+ switch msg.Type {
+ case ethwire.MsgPeersTy:
+ ret += fmt.Sprintf("(%d entries)", msg.Data.Len())
+ case ethwire.MsgBlockTy:
+ b1, b2 := ethchain.NewBlockFromRlpValue(msg.Data.Get(0)), ethchain.NewBlockFromRlpValue(msg.Data.Get(msg.Data.Len()-1))
+ ret += fmt.Sprintf("(%d entries) %x - %x", msg.Data.Len(), b1.Hash()[0:4], b2.Hash()[0:4])
+ case ethwire.MsgBlockHashesTy:
+ h1, h2 := msg.Data.Get(0).Bytes(), msg.Data.Get(msg.Data.Len()-1).Bytes()
+ ret += fmt.Sprintf("(%d entries) %x - %x", msg.Data.Len(), h1, h2)
+ }
+ */
return
}
@@ -512,7 +514,7 @@ func (p *Peer) HandleInbound() {
p.lastBlockReceived = time.Now()
}
- if foundCommonHash {
+ if foundCommonHash || msg.Data.Len() == 0 {
p.FetchBlocks()
} else {
p.FetchHashes()