sdgoij/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-01-16 17:20:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
houseme
2025-12-25 11:35:40 +08:00
parent 04833f35cf
commit cd9b5ad3f3
2 changed files with 15 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
crates/utils/src/http/ip.rs
View File

@@ -60,10 +60,12 @@ pub struct TrustedProxies {
impl TrustedProxies {
/// Create a new TrustedProxies configuration
pub fn new(cidrs: Vec<String>, enable_validation: bool, max_chain_length: usize) -> Self {
let cidrs = cidrs.into_iter()
.filter_map(|s| s.parse::<IpNet>().ok())
.collect();
Self { cidrs, enable_validation, max_chain_length }
let cidrs = cidrs.into_iter().filter_map(|s| s.parse::<IpNet>().ok()).collect();
Self {
cidrs,
enable_validation,
max_chain_length,
}
}
/// Check if an IP address is within the trusted proxy ranges
@@ -310,11 +312,7 @@ mod tests {
#[test]
fn test_trusted_proxies_validation() {
let trusted_proxies = TrustedProxies::new(
vec!["192.168.1.0/24".to_string(), "10.0.0.0/8".to_string()],
true,
5,
);
let trusted_proxies = TrustedProxies::new(vec!["192.168.1.0/24".to_string(), "10.0.0.0/8".to_string()], true, 5);
// Trusted IPs
assert!(trusted_proxies.is_trusted_proxy("192.168.1.1".parse().unwrap()));
@@ -395,6 +393,9 @@ mod tests {
assert!(is_valid_client_ip("203.0.113.1, 198.51.100.1", 5));
// Invalid chain (too long)
assert!(!is_valid_client_ip("203.0.113.1, 198.51.100.1, 192.0.2.1, 192.0.2.2, 192.0.2.3, 192.0.2.4", 5));
assert!(!is_valid_client_ip(
"203.0.113.1, 198.51.100.1, 192.0.2.1, 192.0.2.2, 192.0.2.3, 192.0.2.4",
5
));
}
}
}

6
rustfs/src/main.rs
View File

@@ -329,14 +329,14 @@ async fn run(opt: config::Opt) -> Result<()> {
init_update_check();
info!(target: "rustfs::main::run","server started successfully at {}", &server_address);
// 4. Mark as Full Ready now that critical components are warm
readiness.mark_stage(SystemStage::FullReady);
println!(
"RustFS server started successfully at {}, current time: {}",
&server_address,
chrono::offset::Utc::now().to_string()
);
info!(target: "rustfs::main::run","server started successfully at {}", &server_address);
// 4. Mark as Full Ready now that critical components are warm
readiness.mark_stage(SystemStage::FullReady);
// Perform hibernation for 1 second
tokio::time::sleep(SHUTDOWN_TIMEOUT).await;