status-im/nim-eth-p2p
2
0
Fork 0
mirror of https://github.com/status-im/nim-eth-p2p.git synced 2025-01-30 00:25:10 +00:00
Code Issues Projects Releases Wiki Activity

Added magic constant.

Browse Source
This commit is contained in:
Your Name 2018-05-17 11:39:10 +03:00
parent b715adae7d
commit 407e6c43ef
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ethp2p/rlpx.nim
View File

@ -555,7 +555,8 @@ proc rlpxConnect*(myKeys: KeyPair, listenPort: Port, remote: Node): Future[Peer]
await result.socket.send(addr authMsg[0], authMsgLen) await result.socket.send(addr authMsg[0], authMsgLen)
let initialSize = handshake.expectedLength let initialSize = handshake.expectedLength
var ackMsg = newSeq[byte](initialSize) var ackMsg = newSeqOfCap[byte](1024)
ackMsg.setLen(initialSize)
await result.socket.fullRecvInto(ackMsg) await result.socket.fullRecvInto(ackMsg)
var ret = handshake.decodeAckMessage(ackMsg) var ret = handshake.decodeAckMessage(ackMsg)
if ret == AuthStatus.IncompleteError: if ret == AuthStatus.IncompleteError:
@ -587,7 +588,8 @@ proc rlpxConnectIncoming*(myKeys: KeyPair, listenPort: Port, address: IpAddress,
handshake.host = myKeys handshake.host = myKeys
let initialSize = handshake.expectedLength let initialSize = handshake.expectedLength
var authMsg = newSeq[byte](initialSize) var authMsg = newSeqOfCap[byte](1024)
authMsg.setLen(initialSize)
await s.fullRecvInto(authMsg) await s.fullRecvInto(authMsg)
var ret = handshake.decodeAuthMessage(authMsg) var ret = handshake.decodeAuthMessage(authMsg)
if ret == AuthStatus.IncompleteError: # Eip8 auth message is likely if ret == AuthStatus.IncompleteError: # Eip8 auth message is likely