Skip to content

Commit 88fe8ae

Browse files
committed
cleanups
1 parent 851d2c6 commit 88fe8ae

File tree

3 files changed

+2
-9
lines changed

3 files changed

+2
-9
lines changed

libp2p/src/test/kotlin/io/libp2p/pubsub/gossip/GossipV1_1Tests.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -716,7 +716,7 @@ class GossipV1_1Tests : GossipTestsBase() {
716716
@Test
717717
fun testOutboundMeshQuotas1() {
718718
val appScore = mutableMapOf<PeerId, Double>().withDefault { 0.0 }
719-
val coreParams = GossipParams(3, 3, 3, DLazy = 3, DOut = 1, floodPublishMaxMessageSizeThreshold = 0)
719+
val coreParams = GossipParams(3, 3, 3, DLazy = 3, DOut = 1, floodPublishMaxMessageSizeThreshold = NEVER_FLOOD_PUBLISH)
720720
val peerScoreParams = GossipPeerScoreParams(appSpecificScore = { appScore.getValue(it) })
721721
val scoreParams = GossipScoreParams(peerScoreParams = peerScoreParams)
722722
val test = ManyRoutersTest(params = coreParams, scoreParams = scoreParams)

libp2p/src/test/kotlin/io/libp2p/pubsub/gossip/SubscriptionsLimitTest.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ import org.junit.jupiter.api.Test
1010
import org.junit.jupiter.api.assertDoesNotThrow
1111

1212
class SubscriptionsLimitTest : TwoGossipHostTestBase() {
13-
override val params = GossipParams(maxSubscriptions = 5, floodPublishMaxMessageSizeThreshold = 16384)
13+
override val params = GossipParams(maxSubscriptions = 5, floodPublishMaxMessageSizeThreshold = ALWAYS_FLOOD_PUBLISH)
1414

1515
@Test
1616
fun `new peer subscribed to many topics`() {

tools/simulator/src/main/kotlin/io/libp2p/simulate/main/BlobDecouplingSimulation.kt

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,6 @@ class BlobDecouplingSimulation(
4141
val randomSeed: Long = 3L,
4242
val rnd: Random = Random(randomSeed),
4343

44-
val floodPublishMaxMessageSizeThreshold: Int = 16384,
45-
4644
val sendingPeerBand: Bandwidth = Bandwidth.mbitsPerSec(100),
4745

4846
val peerBands: Iterator<Bandwidth> = iterator {
@@ -83,10 +81,6 @@ class BlobDecouplingSimulation(
8381
)
8482

8583
val gossipParams = Eth2DefaultGossipParams
86-
.copy(
87-
// heartbeatInterval = 1.minutes
88-
floodPublishMaxMessageSizeThreshold = floodPublishMaxMessageSizeThreshold
89-
)
9084
val gossipScoreParams = Eth2DefaultScoreParams
9185
val gossipRouterCtor = { _: Int ->
9286
SimGossipRouterBuilder().also {
@@ -294,7 +288,6 @@ fun main() {
294288
// logger = {},
295289
nodeCount = 1000,
296290
peerBands = band,
297-
floodPublishMaxMessageSizeThreshold = 0,
298291
// randomSeed = 2
299292
)
300293

0 commit comments

Comments
 (0)