blob: 2b73d8959d1ccc0dc5e7794208c56edc70deaa3c (
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#pragma once
#include <functional>
#include <map>
#include <optional>
#include <seastar/core/future.hh>
#include <seastar/core/shared_future.hh>
#include "include/types.h"
#include "crimson/osd/osd_operation.h"
namespace ceph {
class Formatter;
}
namespace crimson::osd {
class ShardServices;
class OSDMapGate {
struct OSDMapBlocker : public Blocker {
const char * type_name;
epoch_t epoch;
OSDMapBlocker(std::pair<const char *, epoch_t> args)
: type_name(args.first), epoch(args.second) {}
OSDMapBlocker(const OSDMapBlocker &) = delete;
OSDMapBlocker(OSDMapBlocker &&) = delete;
OSDMapBlocker &operator=(const OSDMapBlocker &) = delete;
OSDMapBlocker &operator=(OSDMapBlocker &&) = delete;
seastar::shared_promise<epoch_t> promise;
void dump_detail(Formatter *f) const final;
private:
const char *get_type_name() const final {
return type_name;
}
};
// order the promises in ascending order of the waited osdmap epoch,
// so we can access all the waiters expecting a map whose epoch is less
// than or equal to a given epoch
using waiting_peering_t = std::map<epoch_t,
OSDMapBlocker>;
const char *blocker_type;
waiting_peering_t waiting_peering;
epoch_t current = 0;
std::optional<std::reference_wrapper<ShardServices>> shard_services;
bool stopping = false;
public:
OSDMapGate(
const char *blocker_type,
std::optional<std::reference_wrapper<ShardServices>> shard_services)
: blocker_type(blocker_type), shard_services(shard_services) {}
// wait for an osdmap whose epoch is greater or equal to given epoch
blocking_future<epoch_t> wait_for_map(epoch_t epoch);
void got_map(epoch_t epoch);
seastar::future<> stop();
};
}
|
