This commit is contained in:
weisd
2024-12-28 22:41:51 +08:00
parent 5afc578951
commit c5b8a20092
5 changed files with 5 additions and 8 deletions

View File

@@ -50,8 +50,6 @@ use path_absolutize::Absolutize;
use std::collections::{HashMap, HashSet};
use std::fmt::Debug;
use std::io::Cursor;
#[cfg(target_family = "unix")]
use std::os::unix::fs::MetadataExt;
use std::sync::atomic::{AtomicU32, Ordering};
use std::sync::Arc;
use std::time::{Duration, SystemTime};

View File

@@ -1,4 +1,3 @@
use crate::config::error::ConfigError;
use crate::{disk::error::DiskError, error::Error};
use std::{collections::HashMap, fmt::Debug};
// pub type CheckErrorFn = fn(e: &Error) -> bool;

View File

@@ -3527,8 +3527,8 @@ impl ObjectIO for SetDisks {
// let disks = disks.clone();
let bucket = String::from(bucket);
let object = String::from(object);
let set_index = self.set_index.clone();
let pool_index = self.pool_index.clone();
let set_index = self.set_index;
let pool_index = self.pool_index;
tokio::spawn(async move {
if let Err(e) = Self::get_object_with_fileinfo(
&bucket, &object, offset, length, &mut wd, fi, files, &disks, set_index, pool_index,
@@ -5271,7 +5271,7 @@ fn get_complete_multipart_md5(parts: &[CompletePart]) -> String {
}
let mut hasher = Md5::new();
hasher.write(&buf);
let _ = hasher.write(&buf);
format!("{:x}-{}", hasher.finalize(), parts.len())
}

View File

@@ -16,7 +16,7 @@ use std::{
fmt::Debug,
};
use tracing::{debug, info, warn};
use tracing::{debug, warn};
use uuid::Uuid;
pub async fn init_disks(eps: &Endpoints, opt: &DiskOption) -> (Vec<Option<DiskStore>>, Vec<Option<Error>>) {

View File

@@ -391,7 +391,7 @@ impl S3 for FS {
.await
.map_err(to_s3_error)?;
warn!("head_object info {:?}", &info);
// warn!("head_object info {:?}", &info);
let content_type = {
if let Some(content_type) = info.content_type {