limit chunk count
This commit is contained in:
parent
0d1a50a010
commit
ac6603c22b
@ -1,4 +1,5 @@
|
|||||||
use std::{
|
use std::{
|
||||||
|
cmp::{max, min},
|
||||||
io::{stdout, Write},
|
io::{stdout, Write},
|
||||||
path::{Path, PathBuf},
|
path::{Path, PathBuf},
|
||||||
sync::Arc,
|
sync::Arc,
|
||||||
@ -392,10 +393,12 @@ async fn multipart_upload(
|
|||||||
|
|
||||||
let upload_id = multipart_upload_res.upload_id().unwrap().to_string();
|
let upload_id = multipart_upload_res.upload_id().unwrap().to_string();
|
||||||
|
|
||||||
let mut chunk_count = file_size / CHUNK_SIZE as u64;
|
let chunk_size = max(CHUNK_SIZE as u64, file_size / 10000);
|
||||||
let mut size_of_last_chunk = file_size % CHUNK_SIZE as u64;
|
|
||||||
|
let mut chunk_count = file_size / chunk_size;
|
||||||
|
let mut size_of_last_chunk = file_size % chunk_size;
|
||||||
if size_of_last_chunk == 0 {
|
if size_of_last_chunk == 0 {
|
||||||
size_of_last_chunk = CHUNK_SIZE as u64;
|
size_of_last_chunk = chunk_size;
|
||||||
chunk_count -= 1;
|
chunk_count -= 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user