gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-07-26 16:28:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix remote err && lock err

Browse Source 
Signed-off-by: junxiang Mu <1948535941@qq.com>
This commit is contained in:
junxiang Mu
2024-12-30 11:38:36 +08:00
parent f52882ede6
commit c749cda90d
4 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/lock/src/drwmutex.rs
+2 -2
View File
@@ -50,8 +50,8 @@ impl DRWMutex {
Self {
owner,
names,
write_locks: Vec::with_capacity(lockers.len()),
read_locks: Vec::with_capacity(lockers.len()),
write_locks: vec![String::new(); lockers.len()],
read_locks: vec![String::new(); lockers.len()],
cancel_refresh_sender: None,
// rng: rand::thread_rng(),
lockers,
ecstore/src/disk/mod.rs
+1 -1
View File
@@ -1561,7 +1561,7 @@ impl Reader for RemoteFileReader {
path: self.path.to_string(),
offset: offset.try_into().unwrap(),
// length: length.try_into().unwrap(),
length: 0,
length: buf.len().try_into().unwrap(),
};
self.tx.send(request).await?;
ecstore/src/heal/background_heal_ops.rs
+1 -1
View File
@@ -142,7 +142,7 @@ async fn monitor_local_disks_and_heal() {
}
async fn heal_fresh_disk(endpoint: &Endpoint) -> Result<()> {
let (pool_idx, set_idx) = (endpoint.pool_idx as usize, endpoint.disk_idx as usize);
let (pool_idx, set_idx) = (endpoint.pool_idx as usize, endpoint.set_idx as usize);
let disk = match get_disk_via_endpoint(endpoint).await {
Some(disk) => disk,
None => {
ecstore/src/set_disk.rs
+2 -2
View File
@@ -2250,8 +2250,8 @@ impl SetDisks {
if !lastest_meta.deleted && disks_to_heal_count > lastest_meta.erasure.parity_blocks {
error!(
"file part corrupt too much, can not to fix, disks_to_heal_count: {}, parity_blocks: {}",
disks_to_heal_count, lastest_meta.erasure.parity_blocks
"file({} : {}) part corrupt too much, can not to fix, disks_to_heal_count: {}, parity_blocks: {}",
bucket, object, disks_to_heal_count, lastest_meta.erasure.parity_blocks
);
let mut t_errs = vec![None; errs.len()];
// Allow for dangling deletes, on versions that have DataDir missing etc.