v4.5.1

changelog.md

@@ -1,5 +1,11 @@
 # Changelog
 
+## 2026-03-15 - 4.5.1 - fix(protocol)
+increase per-stream flow control window and channel buffers to improve high-RTT throughput
+
+- raise the initial stream window from 256 KB to 4 MB to allow more in-flight data per stream
+- increase edge and hub mpsc channel capacities from 16 to 128 to better absorb throughput under flow control
+
 ## 2026-03-15 - 4.5.0 - feat(remoteingress-core)
 add per-stream flow control for edge and hub tunnel data transfer
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@serve.zone/remoteingress",
-  "version": "4.5.0",
+  "version": "4.5.1",
   "private": false,
   "description": "Edge ingress tunnel for DcRouter - accepts incoming TCP connections at network edge and tunnels them to DcRouter SmartProxy preserving client IP via PROXY protocol v1.",
   "main": "dist_ts/index.js",

rust/crates/remoteingress-core/src/edge.rs

@@ -625,7 +625,7 @@ async fn handle_client_connection(
     }
 
     // Set up channel for data coming back from hub (capacity 16 is sufficient with flow control)
-    let (back_tx, mut back_rx) = mpsc::channel::<Vec<u8>>(16);
+    let (back_tx, mut back_rx) = mpsc::channel::<Vec<u8>>(128);
     let send_window = Arc::new(AtomicU32::new(INITIAL_STREAM_WINDOW));
     let window_notify = Arc::new(Notify::new());
     {

rust/crates/remoteingress-core/src/hub.rs

@@ -477,7 +477,7 @@ async fn handle_edge_connection(
                                 });
 
                                 // Create channel for data from edge to this stream (capacity 16 is sufficient with flow control)
-                                let (data_tx, mut data_rx) = mpsc::channel::<Vec<u8>>(16);
+                                let (data_tx, mut data_rx) = mpsc::channel::<Vec<u8>>(128);
                                 let send_window = Arc::new(AtomicU32::new(INITIAL_STREAM_WINDOW));
                                 let window_notify = Arc::new(Notify::new());
                                 {

rust/crates/remoteingress-protocol/src/lib.rs

@@ -19,8 +19,9 @@ pub const FRAME_HEADER_SIZE: usize = 9;
 pub const MAX_PAYLOAD_SIZE: u32 = 16 * 1024 * 1024;
 
 // Per-stream flow control constants
-/// Initial per-stream window size (256 KB). With 32KB frames, this allows ~8 frames in flight.
+/// Initial per-stream window size (4 MB). Sized for full throughput at high RTT:
-pub const INITIAL_STREAM_WINDOW: u32 = 256 * 1024;
+/// at 100ms RTT, this sustains ~40 MB/s per stream.
+pub const INITIAL_STREAM_WINDOW: u32 = 4 * 1024 * 1024;
 /// Send WINDOW_UPDATE after consuming this many bytes (half the initial window).
 pub const WINDOW_UPDATE_THRESHOLD: u32 = INITIAL_STREAM_WINDOW / 2;
 /// Maximum window size to prevent overflow.

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@serve.zone/remoteingress',
-  version: '4.5.0',
+  version: '4.5.1',
   description: 'Edge ingress tunnel for DcRouter - accepts incoming TCP connections at network edge and tunnels them to DcRouter SmartProxy preserving client IP via PROXY protocol v1.'
 }