Disable flood publishing (#4383)

* Disable flood publish * Change default configuration
sigp · Dec 11, 2023 · 69f1b7a · 69f1b7a
1 parent 78ffa37
commit 69f1b7a
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/beacon_node/lighthouse_network/src/config.rs b/beacon_node/lighthouse_network/src/config.rs
@@ -363,7 +363,7 @@ impl Default for Config {
             disable_discovery: false,
             disable_quic_support: false,
             upnp_enabled: true,
-            network_load: 3,
+            network_load: 4,
             private: false,
             subscribe_all_subnets: false,
             import_all_attestations: false,
@@ -422,7 +422,7 @@ impl From<u8> for NetworkLoad {
                 mesh_n_high: 10,
                 gossip_lazy: 3,
                 history_gossip: 3,
-                heartbeat_interval: Duration::from_millis(700),
+                heartbeat_interval: Duration::from_millis(1000),
             },
             4 => NetworkLoad {
                 name: "Average",
@@ -432,7 +432,7 @@ impl From<u8> for NetworkLoad {
                 mesh_n_high: 12,
                 gossip_lazy: 3,
                 history_gossip: 3,
-                heartbeat_interval: Duration::from_millis(700),
+                heartbeat_interval: Duration::from_millis(1000),
             },
             // 5 and above
             _ => NetworkLoad {
@@ -443,7 +443,7 @@ impl From<u8> for NetworkLoad {
                 mesh_n_high: 15,
                 gossip_lazy: 5,
                 history_gossip: 6,
-                heartbeat_interval: Duration::from_millis(500),
+                heartbeat_interval: Duration::from_millis(700),
             },
         }
     }
@@ -506,6 +506,7 @@ pub fn gossipsub_config(
         .gossip_lazy(load.gossip_lazy)
         .fanout_ttl(Duration::from_secs(60))
         .history_length(12)
+        .flood_publish(false)
         .max_messages_per_rpc(Some(500)) // Responses to IWANT can be quite large
         .history_gossip(load.history_gossip)
         .validate_messages() // require validation before propagation