aboutsummaryrefslogtreecommitdiffstats
path: root/peer.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-02-03 03:00:09 +0800
committerobscuren <geffobscura@gmail.com>2014-02-03 03:00:09 +0800
commitaa9341570b8e63c907c0f9d917508610c7daa1ae (patch)
tree2c5598f34104f616ed824f5d576876a8df92fecd /peer.go
parentf4a96ca588a4c7e1382e9c2265ca306a5b0d0adf (diff)
downloadgo-tangerine-aa9341570b8e63c907c0f9d917508610c7daa1ae.tar
go-tangerine-aa9341570b8e63c907c0f9d917508610c7daa1ae.tar.gz
go-tangerine-aa9341570b8e63c907c0f9d917508610c7daa1ae.tar.bz2
go-tangerine-aa9341570b8e63c907c0f9d917508610c7daa1ae.tar.lz
go-tangerine-aa9341570b8e63c907c0f9d917508610c7daa1ae.tar.xz
go-tangerine-aa9341570b8e63c907c0f9d917508610c7daa1ae.tar.zst
go-tangerine-aa9341570b8e63c907c0f9d917508610c7daa1ae.zip
Disconnection reasons
Diffstat (limited to 'peer.go')
-rw-r--r--peer.go51
1 files changed, 38 insertions, 13 deletions
diff --git a/peer.go b/peer.go
index e9a8f6c03..0f6afebfe 100644
--- a/peer.go
+++ b/peer.go
@@ -17,27 +17,53 @@ const (
outputBufferSize = 50
)
-// Peer capabillities
+type DiscReason byte
+
+const (
+ DiscReRequested = 0x00
+ DiscReTcpSysErr = 0x01
+ DiscBadProto = 0x02
+ DiscBadPeer = 0x03
+ DiscTooManyPeers = 0x04
+)
+
+var discReasonToString = []string{
+ "Disconnect requested",
+ "Disconnect TCP sys error",
+ "Disconnect Bad protocol",
+ "Disconnect Useless peer",
+ "Disconnect Too many peers",
+}
+
+func (d DiscReason) String() string {
+ if len(discReasonToString) > int(d) {
+ return "Unknown"
+ }
+
+ return discReasonToString[d]
+}
+
+// Peer capabilities
type Caps byte
const (
- CapDiscoveryTy = 0x01
- CapTxTy = 0x02
- CapChainTy = 0x04
+ CapPeerDiscTy = 0x01
+ CapTxTy = 0x02
+ CapChainTy = 0x04
- CapDefault = CapChainTy | CapTxTy | CapDiscoveryTy
+ CapDefault = CapChainTy | CapTxTy | CapPeerDiscTy
)
var capsToString = map[Caps]string{
- CapDiscoveryTy: "Peer discovery",
- CapTxTy: "Transaction relaying",
- CapChainTy: "Block chain relaying",
+ CapPeerDiscTy: "Peer discovery",
+ CapTxTy: "Transaction relaying",
+ CapChainTy: "Block chain relaying",
}
func (c Caps) String() string {
var caps []string
- if c&CapDiscoveryTy > 0 {
- caps = append(caps, capsToString[CapDiscoveryTy])
+ if c&CapPeerDiscTy > 0 {
+ caps = append(caps, capsToString[CapPeerDiscTy])
}
if c&CapChainTy > 0 {
caps = append(caps, capsToString[CapChainTy])
@@ -175,7 +201,7 @@ out:
// Service timer takes care of peer broadcasting, transaction
// posting or block posting
case <-serviceTimer.C:
- if p.caps&CapDiscoveryTy > 0 {
+ if p.caps&CapPeerDiscTy > 0 {
msg := p.peersMessage()
p.ethereum.BroadcastMsg(msg)
}
@@ -220,6 +246,7 @@ out:
p.QueueMessage(ethwire.NewMessage(ethwire.MsgGetPeersTy, ""))
case ethwire.MsgDiscTy:
p.Stop()
+ log.Println("Disconnect peer:", DiscReason(msg.Data.Get(0).AsUint()))
case ethwire.MsgPingTy:
// Respond back with pong
p.QueueMessage(ethwire.NewMessage(ethwire.MsgPongTy, ""))
@@ -381,8 +408,6 @@ func (p *Peer) Stop() {
p.writeMessage(ethwire.NewMessage(ethwire.MsgDiscTy, ""))
p.conn.Close()
}
-
- log.Println("Peer shutdown")
}
func (p *Peer) pushHandshake() error {