gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-08-31 17:28:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(http): Enable dynamic window adjustment (#1549)

Browse Source
This commit is contained in:
houseme
2026-01-19 09:53:17 +08:00
committed by GitHub
parent a9f499282c
commit 99be71e4c2
3 changed files with 53 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Cargo.lock
Generated
+51 -52
View File
@@ -511,7 +511,7 @@ dependencies = [
"nom 7.1.3", "nom 7.1.3",
"num-traits", "num-traits",
"rusticata-macros", "rusticata-macros",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
] ]
@@ -1433,7 +1433,7 @@ dependencies = [
"semver", "semver",
"serde", "serde",
"serde_json", "serde_json",
"thiserror 2.0.17", "thiserror 2.0.18",
] ]
[[package]] [[package]]
@@ -3555,14 +3555,13 @@ checksum = "64cd1e32ddd350061ae6edb1b082d7c54915b5c672c389143b9a63403a109f24"
[[package]] [[package]]
name = "filetime" name = "filetime"
version = "0.2.26" version = "0.2.27"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bc0505cd1b6fa6580283f6bdf70a73fcf4aba1184038c90902b92b3dd0df63ed" checksum = "f98844151eee8917efc50bd9e8318cb963ae8b297431495d3f758616ea5c57db"
dependencies = [ dependencies = [
"cfg-if", "cfg-if",
"libc", "libc",
"libredox", "libredox",
"windows-sys 0.60.2",
] ]
[[package]] [[package]]
@@ -3628,7 +3627,7 @@ dependencies = [
"serde", "serde",
"serde_derive", "serde_derive",
"serde_json", "serde_json",
"thiserror 2.0.17", "thiserror 2.0.18",
"toml", "toml",
"tracing", "tracing",
"tracing-subscriber", "tracing-subscriber",
@@ -3933,7 +3932,7 @@ dependencies = [
"rustls-pki-types", "rustls-pki-types",
"serde", "serde",
"serde_json", "serde_json",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
"tokio", "tokio",
] ]
@@ -3954,7 +3953,7 @@ dependencies = [
"rand 0.9.2", "rand 0.9.2",
"serde", "serde",
"serde_json", "serde_json",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
] ]
@@ -3983,7 +3982,7 @@ dependencies = [
"rustc_version", "rustc_version",
"serde", "serde",
"serde_json", "serde_json",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tokio-stream", "tokio-stream",
"tonic", "tonic",
@@ -4096,7 +4095,7 @@ dependencies = [
"serde_json", "serde_json",
"serde_with", "serde_with",
"sha2 0.10.9", "sha2 0.10.9",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tokio-stream", "tokio-stream",
"tonic", "tonic",
@@ -4129,7 +4128,7 @@ dependencies = [
"serde", "serde",
"serde_json", "serde_json",
"serde_with", "serde_with",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
"url", "url",
] ]
@@ -5211,7 +5210,7 @@ dependencies = [
"once_cell", "once_cell",
"serde", "serde",
"sha2 0.10.9", "sha2 0.10.9",
"thiserror 2.0.17", "thiserror 2.0.18",
"uuid", "uuid",
] ]
@@ -5240,7 +5239,7 @@ dependencies = [
"rustls-pemfile", "rustls-pemfile",
"slog", "slog",
"slog-stdlog", "slog-stdlog",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tokio-rustls", "tokio-rustls",
"tokio-util", "tokio-util",
@@ -5896,7 +5895,7 @@ dependencies = [
"itertools 0.14.0", "itertools 0.14.0",
"parking_lot", "parking_lot",
"percent-encoding", "percent-encoding",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tracing", "tracing",
"url", "url",
@@ -5954,7 +5953,7 @@ dependencies = [
"futures-sink", "futures-sink",
"js-sys", "js-sys",
"pin-project-lite", "pin-project-lite",
"thiserror 2.0.17", "thiserror 2.0.18",
"tracing", "tracing",
] ]
@@ -5999,7 +5998,7 @@ dependencies = [
"opentelemetry_sdk", "opentelemetry_sdk",
"prost 0.14.3", "prost 0.14.3",
"reqwest", "reqwest",
"thiserror 2.0.17", "thiserror 2.0.18",
"tracing", "tracing",
] ]
@@ -6045,7 +6044,7 @@ dependencies = [
"opentelemetry", "opentelemetry",
"percent-encoding", "percent-encoding",
"rand 0.9.2", "rand 0.9.2",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tokio-stream", "tokio-stream",
] ]
@@ -6637,7 +6636,7 @@ dependencies = [
"spin 0.10.0", "spin 0.10.0",
"symbolic-demangle", "symbolic-demangle",
"tempfile", "tempfile",
"thiserror 2.0.17", "thiserror 2.0.18",
] ]
[[package]] [[package]]
@@ -6735,7 +6734,7 @@ dependencies = [
"lazy_static", "lazy_static",
"memchr", "memchr",
"parking_lot", "parking_lot",
"thiserror 2.0.17", "thiserror 2.0.18",
] ]
[[package]] [[package]]
@@ -6958,7 +6957,7 @@ dependencies = [
"rustc-hash", "rustc-hash",
"rustls", "rustls",
"socket2", "socket2",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tracing", "tracing",
"web-time", "web-time",
@@ -6979,7 +6978,7 @@ dependencies = [
"rustls", "rustls",
"rustls-pki-types", "rustls-pki-types",
"slab", "slab",
"thiserror 2.0.17", "thiserror 2.0.18",
"tinyvec", "tinyvec",
"tracing", "tracing",
"web-time", "web-time",
@@ -7177,7 +7176,7 @@ checksum = "a4e608c6638b9c18977b00b475ac1f28d14e84b27d8d42f70e0bf1e3dec127ac"
dependencies = [ dependencies = [
"getrandom 0.2.17", "getrandom 0.2.17",
"libredox", "libredox",
"thiserror 2.0.17", "thiserror 2.0.18",
] ]
[[package]] [[package]]
@@ -7354,7 +7353,7 @@ dependencies = [
"schemars 1.2.0", "schemars 1.2.0",
"serde", "serde",
"serde_json", "serde_json",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tokio-util", "tokio-util",
"tracing", "tracing",
@@ -7425,7 +7424,7 @@ dependencies = [
"rustls-native-certs", "rustls-native-certs",
"rustls-pemfile", "rustls-pemfile",
"rustls-webpki 0.102.8", "rustls-webpki 0.102.8",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tokio-rustls", "tokio-rustls",
"tokio-stream", "tokio-stream",
@@ -7518,7 +7517,7 @@ dependencies = [
"flurry", "flurry",
"log", "log",
"serde", "serde",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tokio-util", "tokio-util",
] ]
@@ -7668,7 +7667,7 @@ dependencies = [
"ssh-key", "ssh-key",
"subtle", "subtle",
"sysinfo", "sysinfo",
"thiserror 2.0.17", "thiserror 2.0.18",
"tikv-jemalloc-ctl", "tikv-jemalloc-ctl",
"tikv-jemallocator", "tikv-jemallocator",
"time", "time",
@@ -7708,7 +7707,7 @@ dependencies = [
"serde_json", "serde_json",
"serial_test", "serial_test",
"tempfile", "tempfile",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
"tokio", "tokio",
"tokio-util", "tokio-util",
@@ -7745,7 +7744,7 @@ dependencies = [
"rustfs-targets", "rustfs-targets",
"serde", "serde",
"serde_json", "serde_json",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tracing", "tracing",
"url", "url",
@@ -7815,7 +7814,7 @@ dependencies = [
"serde_json", "serde_json",
"sha2 0.11.0-rc.3", "sha2 0.11.0-rc.3",
"test-case", "test-case",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
] ]
@@ -7889,7 +7888,7 @@ dependencies = [
"smallvec", "smallvec",
"temp-env", "temp-env",
"tempfile", "tempfile",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
"tokio", "tokio",
"tokio-util", "tokio-util",
@@ -7917,7 +7916,7 @@ dependencies = [
"rustfs-utils", "rustfs-utils",
"s3s", "s3s",
"serde", "serde",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
"tokio", "tokio",
"tracing", "tracing",
@@ -7944,7 +7943,7 @@ dependencies = [
"rustfs-utils", "rustfs-utils",
"serde", "serde",
"serde_json", "serde_json",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
"tokio", "tokio",
"tokio-util", "tokio-util",
@@ -7968,7 +7967,7 @@ dependencies = [
"serde_json", "serde_json",
"sha2 0.11.0-rc.3", "sha2 0.11.0-rc.3",
"tempfile", "tempfile",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tracing", "tracing",
"url", "url",
@@ -7990,7 +7989,7 @@ dependencies = [
"serde_json", "serde_json",
"smallvec", "smallvec",
"smartstring", "smartstring",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tonic", "tonic",
"tracing", "tracing",
@@ -8048,7 +8047,7 @@ dependencies = [
"serde", "serde",
"serde_json", "serde_json",
"starshard", "starshard",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tracing", "tracing",
"tracing-subscriber", "tracing-subscriber",
@@ -8075,7 +8074,7 @@ dependencies = [
"serde", "serde",
"smallvec", "smallvec",
"sysinfo", "sysinfo",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tracing", "tracing",
"tracing-appender", "tracing-appender",
@@ -8106,7 +8105,7 @@ dependencies = [
"strum", "strum",
"temp-env", "temp-env",
"test-case", "test-case",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
"tokio", "tokio",
"tracing", "tracing",
@@ -8148,7 +8147,7 @@ dependencies = [
"serde_json", "serde_json",
"sha1 0.11.0-rc.3", "sha1 0.11.0-rc.3",
"sha2 0.11.0-rc.3", "sha2 0.11.0-rc.3",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tokio-test", "tokio-test",
"tokio-util", "tokio-util",
@@ -8224,7 +8223,7 @@ dependencies = [
"serde", "serde",
"serde_json", "serde_json",
"snap", "snap",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tracing", "tracing",
"url", "url",
@@ -8270,7 +8269,7 @@ dependencies = [
"snap", "snap",
"sysinfo", "sysinfo",
"tempfile", "tempfile",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tracing", "tracing",
"transform-stream", "transform-stream",
@@ -8488,7 +8487,7 @@ dependencies = [
"std-next", "std-next",
"subtle", "subtle",
"sync_wrapper", "sync_wrapper",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
"tokio", "tokio",
"tower", "tower",
@@ -8982,7 +8981,7 @@ checksum = "297f631f50729c8c99b84667867963997ec0b50f32b2a7dbcab828ef0541e8bb"
dependencies = [ dependencies = [
"num-bigint", "num-bigint",
"num-traits", "num-traits",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
] ]
@@ -9303,7 +9302,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "04082e93ed1a06debd9148c928234b46d2cf260bc65f44e1d1d3fa594c5beebc" checksum = "04082e93ed1a06debd9148c928234b46d2cf260bc65f44e1d1d3fa594c5beebc"
dependencies = [ dependencies = [
"simdutf8", "simdutf8",
"thiserror 2.0.17", "thiserror 2.0.18",
] ]
[[package]] [[package]]
@@ -9365,7 +9364,7 @@ dependencies = [
"pin-project", "pin-project",
"rustls", "rustls",
"rustls-pki-types", "rustls-pki-types",
"thiserror 2.0.17", "thiserror 2.0.18",
"tokio", "tokio",
"tokio-rustls", "tokio-rustls",
] ]
@@ -9642,11 +9641,11 @@ dependencies = [
[[package]] [[package]]
name = "thiserror" name = "thiserror"
version = "2.0.17" version = "2.0.18"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f63587ca0f12b72a0600bcba1d40081f830876000bb46dd2337a3051618f4fc8" checksum = "4288b5bcbc7920c07a1149a35cf9590a2aa808e0bc1eafaade0b80947865fbc4"
dependencies = [ dependencies = [
"thiserror-impl 2.0.17", "thiserror-impl 2.0.18",
] ]
[[package]] [[package]]
@@ -9662,9 +9661,9 @@ dependencies = [
[[package]] [[package]]
name = "thiserror-impl" name = "thiserror-impl"
version = "2.0.17" version = "2.0.18"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "3ff15c8ecd7de3849db632e14d18d2571fa09dfc5ed93479bc4485c7a517c913" checksum = "ebc4ee7f67670e9b64d05fa4253e753e016c6c95ff35b89b7941d6b856dec1d5"
dependencies = [ dependencies = [
"proc-macro2", "proc-macro2",
"quote", "quote",
@@ -10079,7 +10078,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "786d480bce6247ab75f005b14ae1624ad978d3029d9113f0a22fa1ac773faeaf" checksum = "786d480bce6247ab75f005b14ae1624ad978d3029d9113f0a22fa1ac773faeaf"
dependencies = [ dependencies = [
"crossbeam-channel", "crossbeam-channel",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
"tracing-subscriber", "tracing-subscriber",
] ]
@@ -11029,7 +11028,7 @@ dependencies = [
"nom 7.1.3", "nom 7.1.3",
"oid-registry", "oid-registry",
"rusticata-macros", "rusticata-macros",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
] ]
@@ -11047,7 +11046,7 @@ dependencies = [
"oid-registry", "oid-registry",
"ring", "ring",
"rusticata-macros", "rusticata-macros",
"thiserror 2.0.17", "thiserror 2.0.18",
"time", "time",
] ]
Cargo.toml
+1 -1
View File
@@ -239,7 +239,7 @@ sysinfo = "0.37.2"
temp-env = "0.3.6" temp-env = "0.3.6"
tempfile = "3.24.0" tempfile = "3.24.0"
test-case = "3.3.1" test-case = "3.3.1"
thiserror = "2.0.17" thiserror = "2.0.18"
tracing = { version = "0.1.44" } tracing = { version = "0.1.44" }
tracing-appender = "0.2.4" tracing-appender = "0.2.4"
tracing-error = "0.2.1" tracing-error = "0.2.1"
rustfs/src/server/http.rs
+1
View File
@@ -280,6 +280,7 @@ pub async fn start_http_server(
conn_builder conn_builder
.http2() .http2()
.timer(TokioTimer::new()) .timer(TokioTimer::new())
.adaptive_window(true)
.initial_stream_window_size(H2_INITIAL_STREAM_WINDOW_SIZE) .initial_stream_window_size(H2_INITIAL_STREAM_WINDOW_SIZE)
.initial_connection_window_size(H2_INITIAL_CONN_WINDOW_SIZE) .initial_connection_window_size(H2_INITIAL_CONN_WINDOW_SIZE)
.max_frame_size(H2_MAX_FRAME_SIZE) .max_frame_size(H2_MAX_FRAME_SIZE)