blob: 682fef69b7e259471ad43649838999a402b33388 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#pragma once
#include <exception>
#include <seastar/core/future.hh>
#include <seastar/core/future-util.hh>
#include "crimson/common/log.h"
#include "crimson/common/interruptible_future.h"
namespace crimson::common {
class interruption : public std::exception
{};
class system_shutdown_exception final : public interruption{
public:
const char* what() const noexcept final {
return "system shutting down";
}
};
class actingset_changed final : public interruption {
public:
actingset_changed(bool sp) : still_primary(sp) {}
const char* what() const noexcept final {
return "acting set changed";
}
bool is_primary() const {
return still_primary;
}
private:
const bool still_primary;
};
template<typename Func, typename... Args>
inline seastar::future<> handle_system_shutdown(Func&& func, Args&&... args)
{
return seastar::futurize_invoke(std::forward<Func>(func),
std::forward<Args>(args)...)
.handle_exception([](std::exception_ptr eptr) {
if (*eptr.__cxa_exception_type() ==
typeid(crimson::common::system_shutdown_exception)) {
crimson::get_logger(ceph_subsys_osd).debug(
"operation skipped, system shutdown");
return seastar::now();
}
std::rethrow_exception(eptr);
});
}
}
|
