mirror/go-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/go-pulse.git synced 2024-12-24 12:27:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Protocol bump

Browse Source
This commit is contained in:
obscuren 2014-10-08 12:00:03 +02:00
parent b417766b36
commit 6de726f16c
1 changed files with 15 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
peer.go
View File

@ -24,7 +24,7 @@ const (
// The size of the output buffer for writing messages // The size of the output buffer for writing messages
outputBufferSize = 50 outputBufferSize = 50
// Current protocol version // Current protocol version
ProtocolVersion = 33 ProtocolVersion = 34
// Current P2P version // Current P2P version
P2PVersion = 0 P2PVersion = 0
// Ethereum network version // Ethereum network version
@ -848,26 +848,23 @@ func (p *Peer) RlpData() []interface{} {
return []interface{}{p.host, p.port, p.pubkey} return []interface{}{p.host, p.port, p.pubkey}
} }
func packAddr(address, port string) ([]byte, uint16) { func packAddr(address, _port string) (host []byte, port uint16) {
addr := strings.Split(address, ".") p, _ := strconv.Atoi(_port)
a, _ := strconv.Atoi(addr[0]) port = uint16(p)
b, _ := strconv.Atoi(addr[1])
c, _ := strconv.Atoi(addr[2])
d, _ := strconv.Atoi(addr[3])
host := []byte{byte(a), byte(b), byte(c), byte(d)}
prt, _ := strconv.Atoi(port)
return host, uint16(prt) h := net.ParseIP(address)
if ip := h.To4(); ip != nil {
host = []byte(ip)
} else {
host = []byte(h)
}
return
} }
func unpackAddr(value *ethutil.Value, p uint64) string { func unpackAddr(value *ethutil.Value, p uint64) string {
byts := value.Bytes() host, _ := net.IP(value.Bytes()).MarshalText()
a := strconv.Itoa(int(byts[0])) prt := strconv.Itoa(int(p))
b := strconv.Itoa(int(byts[1]))
c := strconv.Itoa(int(byts[2]))
d := strconv.Itoa(int(byts[3]))
host := strings.Join([]string{a, b, c, d}, ".")
port := strconv.Itoa(int(p))
return net.JoinHostPort(host, port) return net.JoinHostPort(string(host), prt)
} }