Skip to content

Commit

Permalink
archival: add a note about max_offset_override_exclusive
Browse files Browse the repository at this point in the history
Outrageously verbose but for a good reason.
  • Loading branch information
nvartolomei committed May 8, 2024
1 parent 2647d9f commit 15ac281
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 7 deletions.
6 changes: 3 additions & 3 deletions src/v/archival/ntp_archiver_service.cc
Original file line number Diff line number Diff line change
Expand Up @@ -2036,9 +2036,9 @@ model::offset ntp_archiver::max_uploadable_offset_exclusive() const {
}

ss::future<ntp_archiver::batch_result> ntp_archiver::upload_next_candidates(
std::optional<model::offset> max_offset_override_exclusive) {
auto max_offset_exclusive = max_offset_override_exclusive
? *max_offset_override_exclusive
std::optional<model::offset> unsafe_max_offset_override_exclusive) {
auto max_offset_exclusive = unsafe_max_offset_override_exclusive
? *unsafe_max_offset_override_exclusive
: max_uploadable_offset_exclusive();
vlog(
_rtclog.debug,
Expand Down
10 changes: 6 additions & 4 deletions src/v/archival/ntp_archiver_service.h
Original file line number Diff line number Diff line change
Expand Up @@ -187,12 +187,14 @@ class ntp_archiver {
/// will pick not more than '_concurrency' candidates and start
/// uploading them.
///
/// \param max_offset_override_exclusive Overrides the maximum offset
/// that can be uploaded. If nullopt, the maximum offset is
/// calculated automatically.
/// \param unsafe_max_offset_override_exclusive Overrides the maximum offset
/// that can be uploaded. ONLY FOR TESTING. It is not clamped to a
/// safe value/committed offset as some tests work directly with
/// segments bypassing the raft thus not advancing the committed
/// offset.
/// \return future that returns number of uploaded/failed segments
virtual ss::future<batch_result> upload_next_candidates(
std::optional<model::offset> max_offset_override_exclusive
std::optional<model::offset> unsafe_max_offset_override_exclusive
= std::nullopt);

ss::future<cloud_storage::download_result> sync_manifest();
Expand Down

0 comments on commit 15ac281

Please sign in to comment.