Skip to content

Commit ff03541

Browse files
committed
configure dynamic vote compression for p2p wsPeers
1 parent e07aa4f commit ff03541

File tree

1 file changed

+10
-9
lines changed

1 file changed

+10
-9
lines changed

network/p2pNetwork.go

Lines changed: 10 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -939,15 +939,16 @@ func (n *P2PNetwork) baseWsStreamHandler(ctx context.Context, p2pPeer peer.ID, s
939939
}
940940
peerCore := makePeerCore(ctx, n, n.log, n.handler.readBuffer, addr, client, addr)
941941
wsp := &wsPeer{
942-
wsPeerCore: peerCore,
943-
conn: &wsPeerConnP2P{stream: stream},
944-
outgoing: !incoming,
945-
identity: netIdentPeerID,
946-
peerType: peerTypeP2P,
947-
TelemetryGUID: pmi.telemetryID,
948-
InstanceName: pmi.instanceName,
949-
features: decodePeerFeatures(pmi.version, pmi.features),
950-
enableVoteCompression: n.config.EnableVoteCompression,
942+
wsPeerCore: peerCore,
943+
conn: &wsPeerConnP2P{stream: stream},
944+
outgoing: !incoming,
945+
identity: netIdentPeerID,
946+
peerType: peerTypeP2P,
947+
TelemetryGUID: pmi.telemetryID,
948+
InstanceName: pmi.instanceName,
949+
features: decodePeerFeatures(pmi.version, pmi.features),
950+
enableVoteCompression: n.config.EnableVoteCompression,
951+
voteCompressionDynamicTableSize: n.voteCompressionDynamicTableSize,
951952
}
952953

953954
localAddr, has := n.Address()

0 commit comments

Comments
 (0)