quic: add initial RTT option to session options · nodejs/node@84d3100 · GitHub
Skip to content

Commit 84d3100

Browse files
jasnelladuh95
jasnell
authored and
aduh95
committed
quic: add initial RTT option to session options
Signed-off-by: James M Snell <jasnell@gmail.com> Assisted-by: OpenCode:Opus 4.6 PR-URL: #63267 Backport-PR-URL: #64675 Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
1 parent a2b6a81 commit 84d3100

6 files changed

Lines changed: 109 additions & 4 deletions

File tree

‎doc/api/quic.md‎

Lines changed: 17 additions & 0 deletions

‎lib/internal/quic/quic.js‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -404,6 +404,9 @@ const endpointRegistry = new SafeSet();
404404
* @property {ArrayBufferView} [token] An opaque address validation token
405405
* previously received from the server via `onnewtoken` (client only).
406406
* @property {bigint|number} [handshakeTimeout] The handshake timeout
407+
* @property {bigint|number} [initialRtt] The initial round-trip time estimate in milliseconds.
408+
* Used for PTO computation and initial pacing before the first RTT sample. Default uses
409+
* ngtcp2's built-in default of 333ms. Set lower for low-latency environments.
407410
* @property {bigint|number} [keepAlive] The keep-alive timeout in milliseconds. When set,
408411
* PING frames will be sent automatically to prevent idle timeout.
409412
* @property {bigint|number} [maxStreamWindow] The maximum stream window
@@ -4875,6 +4878,7 @@ function processSessionOptions(options, config = kEmptyObject) {
48754878
maxPayloadSize,
48764879
unacknowledgedPacketThreshold = 0,
48774880
handshakeTimeout,
4881+
initialRtt,
48784882
keepAlive,
48794883
maxStreamWindow,
48804884
maxWindow,
@@ -4982,6 +4986,7 @@ function processSessionOptions(options, config = kEmptyObject) {
49824986
maxPayloadSize,
49834987
unacknowledgedPacketThreshold,
49844988
handshakeTimeout,
4989+
initialRtt,
49854990
keepAlive,
49864991
maxStreamWindow,
49874992
maxWindow,

‎src/quic/bindingdata.h‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,6 +93,7 @@ class SessionManager;
9393
V(groups, "groups") \
9494
V(handshake_timeout, "handshakeTimeout") \
9595
V(http3_alpn, &NGHTTP3_ALPN_H3[1]) \
96+
V(initial_rtt, "initialRtt") \
9697
V(keep_alive_timeout, "keepAlive") \
9798
V(initial_max_data, "initialMaxData") \
9899
V(initial_max_stream_data_bidi_local, "initialMaxStreamDataBidiLocal") \

‎src/quic/session.cc‎

Lines changed: 17 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -513,6 +513,12 @@ Session::Config::Config(Environment* env,
513513
options.handshake_timeout == UINT64_MAX
514514
? UINT64_MAX
515515
: options.handshake_timeout * NGTCP2_MILLISECONDS;
516+
517+
// The initial_rtt option is in milliseconds; ngtcp2 expects nanoseconds.
518+
// A value of 0 leaves the ngtcp2 default (333ms) unchanged.
519+
if (options.initial_rtt > 0)
520+
settings.initial_rtt = options.initial_rtt * NGTCP2_MILLISECONDS;
521+
516522
settings.max_stream_window = options.max_stream_window;
517523
settings.max_window = options.max_window;
518524
settings.ack_thresh = options.unacknowledged_packet_threshold;
@@ -604,10 +610,11 @@ Maybe<Session::Options> Session::Options::From(Environment* env,
604610

605611
if (!SET(version) || !SET(min_version) || !SET(preferred_address_strategy) ||
606612
!SET(transport_params) || !SET(tls_options) || !SET(qlog) ||
607-
!SET(handshake_timeout) || !SET(keep_alive_timeout) ||
608-
!SET(max_stream_window) || !SET(max_window) || !SET(max_payload_size) ||
609-
!SET(unacknowledged_packet_threshold) || !SET(cc_algorithm) ||
610-
!SET(draining_period_multiplier) || !SET(max_datagram_send_attempts)) {
613+
!SET(handshake_timeout) || !SET(initial_rtt) ||
614+
!SET(keep_alive_timeout) || !SET(max_stream_window) || !SET(max_window) ||
615+
!SET(max_payload_size) || !SET(unacknowledged_packet_threshold) ||
616+
!SET(cc_algorithm) || !SET(draining_period_multiplier) ||
617+
!SET(max_datagram_send_attempts)) {
611618
return Nothing<Options>();
612619
}
613620

@@ -726,6 +733,12 @@ std::string Session::Options::ToString() const {
726733
res += prefix + "handshake timeout: " + std::to_string(handshake_timeout) +
727734
" nanoseconds";
728735
}
736+
if (initial_rtt > 0) {
737+
res += prefix + "initial rtt: " + std::to_string(initial_rtt) +
738+
" milliseconds";
739+
} else {
740+
res += prefix + "initial rtt: <default>";
741+
}
729742
res += prefix + "max stream window: " + std::to_string(max_stream_window);
730743
res += prefix + "max window: " + std::to_string(max_window);
731744
res += prefix + "max payload size: " + std::to_string(max_payload_size);

‎src/quic/session.h‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -163,6 +163,15 @@ class Session final : public AsyncWrap, private SessionTicket::AppData::Source {
163163
static constexpr uint64_t DEFAULT_HANDSHAKE_TIMEOUT = 10'000;
164164
uint64_t handshake_timeout = DEFAULT_HANDSHAKE_TIMEOUT;
165165

166+
// The initial round-trip time estimate in milliseconds. ngtcp2 uses this
167+
// for PTO computation, initial pacing, and early loss detection before
168+
// the first RTT sample is collected. The default of 0 uses ngtcp2's
169+
// built-in default of 333ms, which is appropriate for the general
170+
// internet. For low-latency environments (e.g., loopback or same-rack
171+
// deployments), setting a value closer to the actual RTT avoids
172+
// unnecessarily conservative initial behavior.
173+
uint64_t initial_rtt = 0;
174+
166175
// The keep-alive timeout in milliseconds. When set to a non-zero value,
167176
// ngtcp2 will automatically send PING frames to keep the connection alive
168177
// before the idle timeout fires. Set to 0 to disable (default).

‎test/parallel/test-quic-session-initial-rtt.mjs‎

Lines changed: 60 additions & 0 deletions

0 commit comments

Comments
 (0)