void set_push_failed(pg_shard_t shard, std::exception_ptr e) {
pushes.at(shard).set_exception(e);
}
- void interrupt(const std::string& why) {
+ void interrupt(std::string_view why) {
readable.set_exception(std::system_error(
- std::make_error_code(std::errc::interrupted), why));
+ std::make_error_code(std::errc::interrupted), why.data()));
recovered.set_exception(std::system_error(
- std::make_error_code(std::errc::interrupted), why));
+ std::make_error_code(std::errc::interrupted), why.data()));
pulled.set_exception(std::system_error(
- std::make_error_code(std::errc::interrupted), why));
+ std::make_error_code(std::errc::interrupted), why.data()));
for (auto& [pg_shard, pr] : pushes) {
- pr.set_exception(std::system_error(
- std::make_error_code(std::errc::interrupted), why));
+ pr.set_exception(std::system_error(
+ std::make_error_code(std::errc::interrupted), why.data()));
}
}
void stop();
void clear_temp_obj(const hobject_t &oid) {
temp_contents.erase(oid);
}
- void clean_up(ceph::os::Transaction& t, const std::string& why);
+ void clean_up(ceph::os::Transaction& t, std::string_view why);
virtual seastar::future<> on_stop() = 0;
};