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

fix fmt check

Browse Source
This commit is contained in:
weisd
2025-06-09 17:35:42 +08:00
parent cecde068e1
commit 4bbf1c33b8
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ecstore/src/cmd/bucket_replication.rs
+9 -8
View File
@@ -1,7 +1,6 @@
#![allow(unused_variables)] #![allow(unused_variables)]
#![allow(dead_code)] #![allow(dead_code)]
// use error::Error; // use error::Error;
use crate::StorageAPI;
use crate::bucket::metadata_sys::get_replication_config; use crate::bucket::metadata_sys::get_replication_config;
use crate::bucket::versioning_sys::BucketVersioningSys; use crate::bucket::versioning_sys::BucketVersioningSys;
use crate::new_object_layer_fn; use crate::new_object_layer_fn;
@@ -11,26 +10,27 @@ use crate::store_api::ObjectIO;
use crate::store_api::ObjectInfo; use crate::store_api::ObjectInfo;
use crate::store_api::ObjectOptions; use crate::store_api::ObjectOptions;
use crate::store_api::ObjectToDelete; use crate::store_api::ObjectToDelete;
use aws_sdk_s3::Client as S3Client; use crate::StorageAPI;
use aws_sdk_s3::Config;
use aws_sdk_s3::config::BehaviorVersion; use aws_sdk_s3::config::BehaviorVersion;
use aws_sdk_s3::config::Credentials; use aws_sdk_s3::config::Credentials;
use aws_sdk_s3::config::Region; use aws_sdk_s3::config::Region;
use aws_sdk_s3::Client as S3Client;
use aws_sdk_s3::Config;
use bytes::Bytes; use bytes::Bytes;
use chrono::DateTime; use chrono::DateTime;
use chrono::Duration; use chrono::Duration;
use chrono::Utc; use chrono::Utc;
use common::error::Error; use common::error::Error;
use futures::StreamExt;
use futures::stream::FuturesUnordered; use futures::stream::FuturesUnordered;
use futures::StreamExt;
use http::HeaderMap; use http::HeaderMap;
use http::Method; use http::Method;
use lazy_static::lazy_static; use lazy_static::lazy_static;
// use std::time::SystemTime; // use std::time::SystemTime;
use once_cell::sync::Lazy; use once_cell::sync::Lazy;
use regex::Regex; use regex::Regex;
use rustfs_rsc::Minio;
use rustfs_rsc::provider::StaticProvider; use rustfs_rsc::provider::StaticProvider;
use rustfs_rsc::Minio;
use s3s::dto::DeleteMarkerReplicationStatus; use s3s::dto::DeleteMarkerReplicationStatus;
use s3s::dto::DeleteReplicationStatus; use s3s::dto::DeleteReplicationStatus;
use s3s::dto::ExistingObjectReplicationStatus; use s3s::dto::ExistingObjectReplicationStatus;
@@ -42,14 +42,14 @@ use std::collections::HashMap;
use std::collections::HashSet; use std::collections::HashSet;
use std::fmt; use std::fmt;
use std::iter::Iterator; use std::iter::Iterator;
use std::sync::Arc;
use std::sync::atomic::AtomicI32; use std::sync::atomic::AtomicI32;
use std::sync::atomic::Ordering; use std::sync::atomic::Ordering;
use std::sync::Arc;
use std::vec; use std::vec;
use time::OffsetDateTime; use time::OffsetDateTime;
use tokio::sync::mpsc::{Receiver, Sender};
use tokio::sync::Mutex; use tokio::sync::Mutex;
use tokio::sync::RwLock; use tokio::sync::RwLock;
use tokio::sync::mpsc::{Receiver, Sender};
use tokio::task; use tokio::task;
use tracing::{debug, error, info, warn}; use tracing::{debug, error, info, warn};
use uuid::Uuid; use uuid::Uuid;
@@ -834,7 +834,8 @@ impl ReplicationPool {
fn get_worker_ch(&self, bucket: &str, object: &str, _sz: i64) -> Option<&Sender<Box<dyn ReplicationWorkerOperation>>> { fn get_worker_ch(&self, bucket: &str, object: &str, _sz: i64) -> Option<&Sender<Box<dyn ReplicationWorkerOperation>>> {
let h = xxh3_64(format!("{}{}", bucket, object).as_bytes()); // 计算哈希值 let h = xxh3_64(format!("{}{}", bucket, object).as_bytes()); // 计算哈希值
//need lock;
// need lock;
let workers = &self.workers_sender; // 读锁 let workers = &self.workers_sender; // 读锁
if workers.is_empty() { if workers.is_empty() {