resolved final comment from review
This commit is contained in:
parent
8ef28c905d
commit
dcc70c5259
|
@ -1027,7 +1027,7 @@ proc subscribe*[MsgType](node: Eth2Node,
|
||||||
trace "Incoming pubsub message received",
|
trace "Incoming pubsub message received",
|
||||||
peer = peerExpr, len = gossipBytes.len, topic = gossipTopic,
|
peer = peerExpr, len = gossipBytes.len, topic = gossipTopic,
|
||||||
message_id = `$`(sha256.digest(gossipBytes))
|
message_id = `$`(sha256.digest(gossipBytes))
|
||||||
if useSnappy:
|
when useSnappy:
|
||||||
msgHandler SSZ.decode(snappy.decode(gossipBytes), MsgType)
|
msgHandler SSZ.decode(snappy.decode(gossipBytes), MsgType)
|
||||||
else:
|
else:
|
||||||
msgHandler SSZ.decode(gossipBytes, MsgType)
|
msgHandler SSZ.decode(gossipBytes, MsgType)
|
||||||
|
@ -1038,7 +1038,7 @@ proc subscribe*[MsgType](node: Eth2Node,
|
||||||
trace "Incoming pubsub message received for validation",
|
trace "Incoming pubsub message received for validation",
|
||||||
len = gossipBytes.len, topic = gossipTopic,
|
len = gossipBytes.len, topic = gossipTopic,
|
||||||
message_id = `$`(sha256.digest(gossipBytes))
|
message_id = `$`(sha256.digest(gossipBytes))
|
||||||
if useSnappy:
|
when useSnappy:
|
||||||
msgValidator SSZ.decode(snappy.decode(gossipBytes), MsgType)
|
msgValidator SSZ.decode(snappy.decode(gossipBytes), MsgType)
|
||||||
else:
|
else:
|
||||||
msgValidator SSZ.decode(gossipBytes, MsgType)
|
msgValidator SSZ.decode(gossipBytes, MsgType)
|
||||||
|
|
Loading…
Reference in New Issue