Skip to content

Commit

Permalink
[process] Fix accidental removal of line
Browse files Browse the repository at this point in the history
  • Loading branch information
mcopik committed Oct 18, 2024
1 parent dce20c6 commit c4d3b63
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions process/controller/src/swapper.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -76,6 +76,7 @@ namespace praas::process::swapper {
if(ptr == nullptr) {
spdlog::error("Disk swapper created but no location specified!");
}
swap_location = std::string{ptr};
}

template<typename F>
Expand Down Expand Up @@ -188,7 +189,7 @@ namespace praas::process::swapper {
full_path = fs::path{swap_location} / location / "messages" / fmt::format("{}({}", key, message.source);
}

spdlog::debug("Swapping out to {}", full_path.string());
spdlog::debug("Swapping out disk to {}", full_path.string());

fs::create_directories(full_path.parent_path());

Expand Down Expand Up @@ -441,7 +442,7 @@ namespace praas::process::swapper {
} else {
new_path = full_path / "messages" / fmt::format("{}({}", key, message.source);
}
spdlog::debug("Swapping out to location {}", new_path.string());
spdlog::debug("Swapping out S3 to location {}", new_path.string());

std::shared_ptr<Aws::IOStream> input_data = std::make_shared<boost::interprocess::bufferstream>(message.data.data(), message.data.len);
make_request(new_path, std::move(input_data));
Expand Down

0 comments on commit c4d3b63

Please sign in to comment.