From c2af87fd4f05c8845229dd77e5224a6cbf803554 Mon Sep 17 00:00:00 2001
From: Lijun Wang <83639177+lijunwangs@users.noreply.github.com>
Date: Thu, 19 Dec 2024 18:50:05 -0800
Subject: [PATCH] missing tpu_max_streams_per_ms

---
 validator/src/cli.rs  | 14 +++++++-------
 validator/src/main.rs |  2 +-
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/validator/src/cli.rs b/validator/src/cli.rs
index 31322d815375c2..c4c8d1b9fc82a2 100644
--- a/validator/src/cli.rs
+++ b/validator/src/cli.rs
@@ -953,14 +953,14 @@ pub fn app<'a>(version: &'a str, default_args: &'a DefaultArgs) -> App<'a, 'a> {
                 .help("Controls the max concurrent connections for TPU-forward from unstaked nodes."),
         )
         .arg(
-            Arg::with_name("max_streams_per_ms")
-                .long("max-streams-per-ms")
+            Arg::with_name("tpu_max_streams_per_ms")
+                .long("tpu-max-streams-per-ms")
                 .takes_value(true)
-                .default_value(&default_args.max_streams_per_ms)
+                .default_value(&default_args.tpu_max_streams_per_ms)
                 .validator(is_parsable::<usize>)
                 .hidden(hidden_unless_forced())
-                .help("Controls the max number of streams per steamer service."),
-        )        
+                .help("Controls the max number of streams for a TPU service."),
+        )
         .arg(
             Arg::with_name("num_quic_endpoints")
                 .long("num-quic-endpoints")
@@ -2362,7 +2362,7 @@ pub struct DefaultArgs {
     pub max_tpu_unstaked_connections: String,
     pub max_fwd_staked_connections: String,
     pub max_fwd_unstaked_connections: String,
-    pub max_streams_per_ms: String,
+    pub tpu_max_streams_per_ms: String,
 
     pub num_quic_endpoints: String,
     pub vote_use_quic: String,
@@ -2465,7 +2465,7 @@ impl DefaultArgs {
                 .saturating_add(DEFAULT_MAX_UNSTAKED_CONNECTIONS)
                 .to_string(),
             max_fwd_unstaked_connections: 0.to_string(),
-            max_streams_per_ms: DEFAULT_MAX_STREAMS_PER_MS.to_string(),
+            tpu_max_streams_per_ms: DEFAULT_MAX_STREAMS_PER_MS.to_string(),
             num_quic_endpoints: DEFAULT_QUIC_ENDPOINTS.to_string(),
             rpc_max_request_body_size: MAX_REQUEST_BODY_SIZE.to_string(),
             exit_min_idle_time: "10".to_string(),
diff --git a/validator/src/main.rs b/validator/src/main.rs
index 2f82764af5d79b..ed5f7a992341dc 100644
--- a/validator/src/main.rs
+++ b/validator/src/main.rs
@@ -1979,7 +1979,7 @@ pub fn main() {
 
     let tpu_max_connections_per_ipaddr_per_minute: u64 =
         value_t_or_exit!(matches, "tpu_max_connections_per_ipaddr_per_minute", u64);
-    let max_streams_per_ms = value_t_or_exit!(matches, "max_streams_per_ms", u64);
+    let max_streams_per_ms = value_t_or_exit!(matches, "tpu_max_streams_per_ms", u64);
 
     let node_config = NodeConfig {
         gossip_addr,