]>
Commit | Line | Data |
---|---|---|
1 | // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- | |
2 | // vim: ts=8 sw=2 smarttab | |
3 | /* | |
4 | * Ceph - scalable distributed file system | |
5 | * | |
6 | * Copyright (C) 2016 John Spray <john.spray@redhat.com> | |
7 | * | |
8 | * This is free software; you can redistribute it and/or | |
9 | * modify it under the terms of the GNU Lesser General Public | |
10 | * License version 2.1, as published by the Free Software | |
11 | * Foundation. See file COPYING. | |
12 | */ | |
13 | ||
14 | #ifndef CEPH_MGRMONITOR_H | |
15 | #define CEPH_MGRMONITOR_H | |
16 | ||
17 | #include <map> | |
18 | #include <set> | |
19 | ||
20 | #include "include/Context.h" | |
21 | #include "MgrMap.h" | |
22 | #include "PaxosService.h" | |
23 | #include "MonCommand.h" | |
24 | ||
25 | class MgrMonitor: public PaxosService | |
26 | { | |
27 | MgrMap map; | |
28 | MgrMap pending_map; | |
29 | bool ever_had_active_mgr = false; | |
30 | ||
31 | std::map<std::string, bufferlist> pending_metadata; | |
32 | std::set<std::string> pending_metadata_rm; | |
33 | ||
34 | utime_t first_seen_inactive; | |
35 | ||
36 | std::map<uint64_t, ceph::coarse_mono_clock::time_point> last_beacon; | |
37 | ||
38 | /** | |
39 | * If a standby is available, make it active, given that | |
40 | * there is currently no active daemon. | |
41 | * | |
42 | * @return true if a standby was promoted | |
43 | */ | |
44 | bool promote_standby(); | |
45 | void drop_active(); | |
46 | ||
47 | /** | |
48 | * Remove this gid from the list of standbys. By default, | |
49 | * also remove metadata (i.e. forget the daemon entirely). | |
50 | * | |
51 | * Set `drop_meta` to false if you would like to keep | |
52 | * the daemon's metadata, for example if you're dropping | |
53 | * it as a standby before reinstating it as the active daemon. | |
54 | */ | |
55 | void drop_standby(uint64_t gid, bool drop_meta=true); | |
56 | ||
57 | Context *digest_event = nullptr; | |
58 | void cancel_timer(); | |
59 | ||
60 | bool check_caps(MonOpRequestRef op, const uuid_d& fsid); | |
61 | ||
62 | health_status_t should_warn_about_mgr_down(); | |
63 | ||
64 | // Command descriptions we've learned from the active mgr | |
65 | std::vector<MonCommand> command_descs; | |
66 | std::vector<MonCommand> pending_command_descs; | |
67 | ||
68 | public: | |
69 | MgrMonitor(Monitor *mn, Paxos *p, const string& service_name) | |
70 | : PaxosService(mn, p, service_name) | |
71 | {} | |
72 | ~MgrMonitor() override {} | |
73 | ||
74 | void init() override; | |
75 | void on_shutdown() override; | |
76 | ||
77 | const MgrMap &get_map() const { return map; } | |
78 | ||
79 | bool in_use() const { return map.epoch > 0; } | |
80 | ||
81 | void create_initial() override; | |
82 | void get_store_prefixes(std::set<string>& s) override; | |
83 | void update_from_paxos(bool *need_bootstrap) override; | |
84 | void create_pending() override; | |
85 | void encode_pending(MonitorDBStore::TransactionRef t) override; | |
86 | ||
87 | bool preprocess_query(MonOpRequestRef op) override; | |
88 | bool prepare_update(MonOpRequestRef op) override; | |
89 | ||
90 | bool preprocess_command(MonOpRequestRef op); | |
91 | bool prepare_command(MonOpRequestRef op); | |
92 | ||
93 | void encode_full(MonitorDBStore::TransactionRef t) override { } | |
94 | ||
95 | bool preprocess_beacon(MonOpRequestRef op); | |
96 | bool prepare_beacon(MonOpRequestRef op); | |
97 | ||
98 | void check_sub(Subscription *sub); | |
99 | void check_subs(); | |
100 | void send_digests(); | |
101 | ||
102 | void on_active() override; | |
103 | void on_restart() override; | |
104 | ||
105 | void get_health(list<pair<health_status_t,string> >& summary, | |
106 | list<pair<health_status_t,string> > *detail, | |
107 | CephContext *cct) const override; | |
108 | void tick() override; | |
109 | ||
110 | void print_summary(Formatter *f, std::ostream *ss) const; | |
111 | ||
112 | const std::vector<MonCommand> &get_command_descs() const; | |
113 | ||
114 | int load_metadata(const string& name, std::map<string, string>& m, | |
115 | ostream *err); | |
116 | int dump_metadata(const string& name, Formatter *f, ostream *err); | |
117 | void count_metadata(const string& field, Formatter *f); | |
118 | void count_metadata(const string& field, std::map<string,int> *out); | |
119 | ||
120 | friend class C_Updated; | |
121 | ||
122 | // When did the mon last call into our tick() method? Used for detecting | |
123 | // when the mon was not updating us for some period (e.g. during slow | |
124 | // election) to reset last_beacon timeouts | |
125 | ceph::coarse_mono_clock::time_point last_tick; | |
126 | }; | |
127 | ||
128 | #endif |