Skip to content

Commit

Permalink
Merge pull request #18765 from andrwng/backport-18732-v23.2.x-737
Browse files Browse the repository at this point in the history
[v23.2.x] admin: fix cache trim parameter order
  • Loading branch information
andrwng authored Jun 4, 2024
2 parents 8be1a72 + 66251be commit 9c59eeb
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 6 deletions.
6 changes: 6 additions & 0 deletions src/v/cloud_storage/cache_service.cc
Original file line number Diff line number Diff line change
Expand Up @@ -287,6 +287,12 @@ ss::future<> cache::trim_manually(
std::optional<size_t> object_limit_override) {
vassert(ss::this_shard_id() == 0, "Method can only be invoked on shard 0");
auto units = co_await ss::get_units(_cleanup_sm, 1);
vlog(
cst_log.info,
"Beginning manual trim, requested bytes limit: {}, requested object "
"limit: {}",
size_limit_override,
object_limit_override);
co_return co_await trim(size_limit_override, object_limit_override);
}

Expand Down
12 changes: 6 additions & 6 deletions src/v/redpanda/admin_server.cc
Original file line number Diff line number Diff line change
Expand Up @@ -482,7 +482,7 @@ get_integer_query_param(const ss::http::request& req, std::string_view name) {

const ss::sstring& str_param = req.query_parameters.at(key);
try {
return std::stoi(str_param);
return std::stoull(str_param);
} catch (const std::invalid_argument&) {
throw ss::httpd::bad_request_exception(
fmt::format("Parameter {} must be an integer", name));
Expand Down Expand Up @@ -5194,7 +5194,7 @@ admin_server::delete_cloud_storage_lifecycle(
model::initial_revision_id revision;
try {
revision = model::initial_revision_id(
std::stoi(req->param["revision"]));
std::stoll(req->param["revision"]));
} catch (...) {
throw ss::httpd::bad_param_exception(fmt::format(
"Revision id must be an integer: {}", req->param["revision"]));
Expand All @@ -5213,13 +5213,13 @@ admin_server::delete_cloud_storage_lifecycle(
ss::future<ss::json::json_return_type>
admin_server::post_cloud_storage_cache_trim(
std::unique_ptr<ss::http::request> req) {
auto size_limit = get_integer_query_param(*req, "objects");
auto bytes_limit = static_cast<std::optional<size_t>>(
auto max_objects = get_integer_query_param(*req, "objects");
auto max_bytes = static_cast<std::optional<size_t>>(
get_integer_query_param(*req, "bytes"));

co_await _cloud_storage_cache.invoke_on(
ss::shard_id{0}, [size_limit, bytes_limit](auto& c) {
return c.trim_manually(size_limit, bytes_limit);
ss::shard_id{0}, [max_objects, max_bytes](auto& c) {
return c.trim_manually(max_bytes, max_objects);
});

co_return ss::json::json_return_type(ss::json::json_void());
Expand Down

0 comments on commit 9c59eeb

Please sign in to comment.