mirror of
https://github.com/rustfs/rustfs.git
synced 2026-08-22 12:26:37 +00:00
fix(main): update dns_init startup logic and remove unused code in http.rs (#531)
- Refactored the DNS resolver initialization logic in `main.rs` for improved startup reliability and error handling. - Removed unused code from `http.rs` to keep the codebase clean and maintainable.
This commit is contained in:
+3
-3
@@ -136,6 +136,9 @@ async fn run(opt: config::Opt) -> Result<()> {
|
|||||||
|
|
||||||
set_global_addr(&opt.address).await;
|
set_global_addr(&opt.address).await;
|
||||||
|
|
||||||
|
// Wait for DNS initialization to complete before network-heavy operations
|
||||||
|
dns_init.await.map_err(Error::other)?;
|
||||||
|
|
||||||
// For RPC
|
// For RPC
|
||||||
let (endpoint_pools, setup_type) = EndpointServerPools::from_volumes(server_address.clone().as_str(), opt.volumes.clone())
|
let (endpoint_pools, setup_type) = EndpointServerPools::from_volumes(server_address.clone().as_str(), opt.volumes.clone())
|
||||||
.await
|
.await
|
||||||
@@ -230,9 +233,6 @@ async fn run(opt: config::Opt) -> Result<()> {
|
|||||||
// Initialize event notifier
|
// Initialize event notifier
|
||||||
init_event_notifier().await;
|
init_event_notifier().await;
|
||||||
|
|
||||||
// Wait for DNS initialization to complete before network-heavy operations
|
|
||||||
dns_init.await.map_err(Error::other)?;
|
|
||||||
|
|
||||||
let buckets_list = store
|
let buckets_list = store
|
||||||
.list_bucket(&BucketOptions {
|
.list_bucket(&BucketOptions {
|
||||||
no_metadata: true,
|
no_metadata: true,
|
||||||
|
|||||||
@@ -128,7 +128,6 @@ pub async fn start_http_server(
|
|||||||
) -> Result<tokio::sync::broadcast::Sender<()>> {
|
) -> Result<tokio::sync::broadcast::Sender<()>> {
|
||||||
let server_addr = parse_and_resolve_address(opt.address.as_str()).map_err(Error::other)?;
|
let server_addr = parse_and_resolve_address(opt.address.as_str()).map_err(Error::other)?;
|
||||||
let server_port = server_addr.port();
|
let server_port = server_addr.port();
|
||||||
let _server_address = server_addr.to_string();
|
|
||||||
|
|
||||||
// The listening address and port are obtained from the parameters
|
// The listening address and port are obtained from the parameters
|
||||||
let listener = {
|
let listener = {
|
||||||
|
|||||||
Reference in New Issue
Block a user