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
55
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#pragma once
#include <seastar/core/gate.hh>
#include <seastar/core/future.hh>
#include <seastar/core/future-util.hh>
#include "crimson/common/exception.h"
#include "crimson/common/log.h"
#include "include/ceph_assert.h"
namespace crimson::common {
class Gated {
public:
static seastar::logger& gated_logger() {
return crimson::get_logger(ceph_subsys_osd);
}
template <typename Func, typename T>
inline void dispatch_in_background(const char* what, T& who, Func&& func) {
(void) dispatch(what, who, func);
}
template <typename Func, typename T>
inline seastar::future<> dispatch(const char* what, T& who, Func&& func) {
return seastar::with_gate(pending_dispatch, std::forward<Func>(func)
).handle_exception([what, &who] (std::exception_ptr eptr) {
if (*eptr.__cxa_exception_type() == typeid(system_shutdown_exception)) {
gated_logger().debug(
"{}, {} skipped, system shutdown", who, what);
return;
}
try {
std::rethrow_exception(eptr);
} catch (std::exception& e) {
gated_logger().error(
"{} dispatch() {} caught exception: {}", who, what, e.what());
}
assert(*eptr.__cxa_exception_type()
== typeid(seastar::gate_closed_exception));
});
}
seastar::future<> close() {
return pending_dispatch.close();
}
bool is_closed() const {
return pending_dispatch.is_closed();
}
private:
seastar::gate pending_dispatch;
};
}// namespace crimson::common
|
