Skip to content

Commit 59f1735

Browse files
committed
also wire up wsPeer creation in p2pNetwork
1 parent 409b2a7 commit 59f1735

File tree

1 file changed

+9
-8
lines changed

1 file changed

+9
-8
lines changed

network/p2pNetwork.go

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -917,14 +917,15 @@ func (n *P2PNetwork) baseWsStreamHandler(ctx context.Context, p2pPeer peer.ID, s
917917
}
918918
peerCore := makePeerCore(ctx, n, n.log, n.handler.readBuffer, addr, client, addr)
919919
wsp := &wsPeer{
920-
wsPeerCore: peerCore,
921-
conn: &wsPeerConnP2P{stream: stream},
922-
outgoing: !incoming,
923-
identity: netIdentPeerID,
924-
peerType: peerTypeP2P,
925-
TelemetryGUID: pmi.telemetryID,
926-
InstanceName: pmi.instanceName,
927-
features: decodePeerFeatures(pmi.version, pmi.features),
920+
wsPeerCore: peerCore,
921+
conn: &wsPeerConnP2P{stream: stream},
922+
outgoing: !incoming,
923+
identity: netIdentPeerID,
924+
peerType: peerTypeP2P,
925+
TelemetryGUID: pmi.telemetryID,
926+
InstanceName: pmi.instanceName,
927+
features: decodePeerFeatures(pmi.version, pmi.features),
928+
enableVoteCompression: n.config.EnableVoteCompression,
928929
}
929930

930931
localAddr, has := n.Address()

0 commit comments

Comments
 (0)