BlockStorage/repertory
1
0
Fork 0
Code Issues 8 Pull Requests Releases 6 Wiki Activity

refactor
All checks were successful
BlockStorage/repertory/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
Scott E. Graves
2024-12-24 14:26:18 -06:00
parent 9ae04b75c6
commit d578dbe141
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
repertory/librepertory/include/file_manager/open_file.hpp
View File

@ -78,7 +78,7 @@ private:
private:
void download_chunk(std::size_t chunk, bool skip_active, bool should_reset);
void download_range(std::size_t start_chunk, std::size_t end_chunk,
void download_range(std::size_t begin_chunk, std::size_t end_chunk,
bool should_reset);
void set_modified();

16
repertory/librepertory/src/file_manager/open_file.cpp
View File

@ -311,9 +311,9 @@ void open_file::download_chunk(std::size_t chunk, bool skip_active,
}
}
void open_file::download_range(std::size_t start_chunk, std::size_t end_chunk,
void open_file::download_range(std::size_t begin_chunk, std::size_t end_chunk,
bool should_reset) {
for (std::size_t chunk = start_chunk;
for (std::size_t chunk = begin_chunk;
(get_api_error() == api_error::success) && (chunk <= end_chunk);
++chunk) {
download_chunk(chunk, false, should_reset);
@ -487,13 +487,13 @@ auto open_file::read(std::size_t read_size, std::uint64_t read_offset,
return read_from_source();
}
auto start_chunk = static_cast<std::size_t>(read_offset / chunk_size_);
auto begin_chunk = static_cast<std::size_t>(read_offset / chunk_size_);
auto end_chunk =
static_cast<std::size_t>((read_size + read_offset) / chunk_size_);
update_background_reader(start_chunk);
update_background_reader(begin_chunk);
download_range(start_chunk, end_chunk, true);
download_range(begin_chunk, end_chunk, true);
if (get_api_error() != api_error::success) {
return get_api_error();
}
@ -624,13 +624,13 @@ auto open_file::write(std::uint64_t write_offset, const data_buffer &data,
return api_error::download_stopped;
}
auto start_chunk = static_cast<std::size_t>(write_offset / chunk_size_);
auto begin_chunk = static_cast<std::size_t>(write_offset / chunk_size_);
auto end_chunk =
static_cast<std::size_t>((write_offset + data.size()) / chunk_size_);
update_background_reader(start_chunk);
update_background_reader(begin_chunk);
download_range(start_chunk, std::min(get_read_state().size() - 1U, end_chunk),
download_range(begin_chunk, std::min(get_read_state().size() - 1U, end_chunk),
true);
if (get_api_error() != api_error::success) {
return get_api_error();