]>
git.proxmox.com Git - ceph.git/blob - ceph/src/mon/MDSMonitor.h
f17f58f96f2c42f64361bbd06581b40173335ecf
1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 * Ceph - scalable distributed file system
6 * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
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.
15 /* Metadata Server Monitor
18 #ifndef CEPH_MDSMONITOR_H
19 #define CEPH_MDSMONITOR_H
25 #include "include/types.h"
26 #include "mds/FSMap.h"
27 #include "mds/MDSMap.h"
28 #include "PaxosService.h"
29 #include "msg/Messenger.h"
30 #include "messages/MMDSBeacon.h"
33 class MMDSLoadTargets
;
35 class FileSystemCommandHandler
;
37 #define MDS_HEALTH_PREFIX "mds_health"
39 class MDSMonitor
: public PaxosService
{
41 MDSMonitor(Monitor
*mn
, Paxos
*p
, string service_name
);
44 void create_initial() override
;
45 void update_from_paxos(bool *need_bootstrap
) override
;
47 void create_pending() override
;
48 void encode_pending(MonitorDBStore::TransactionRef t
) override
;
49 // we don't require full versions; don't encode any.
50 void encode_full(MonitorDBStore::TransactionRef t
) override
{ }
51 version_t
get_trim_to() override
;
53 bool preprocess_query(MonOpRequestRef op
) override
; // true if processed.
54 bool prepare_update(MonOpRequestRef op
) override
;
55 bool should_propose(double& delay
) override
;
57 void on_active() override
;
58 void on_restart() override
;
61 void check_sub(Subscription
*sub
);
63 const FSMap
&get_pending() const { return pending_fsmap
; }
64 const FSMap
&get_fsmap() const { return fsmap
; }
65 void dump_info(Formatter
*f
);
66 int print_nodes(Formatter
*f
);
69 * Return true if a blacklist was done (i.e. OSD propose needed)
71 bool fail_mds_gid(mds_gid_t gid
);
74 FSMap fsmap
; // current
75 FSMap pending_fsmap
; // current + pending updates
78 void print_map(FSMap
&m
, int dbl
=7);
81 void _updated(MonOpRequestRef op
);
83 void _note_beacon(class MMDSBeacon
*m
);
84 bool preprocess_beacon(MonOpRequestRef op
);
85 bool prepare_beacon(MonOpRequestRef op
);
87 bool preprocess_offload_targets(MonOpRequestRef op
);
88 bool prepare_offload_targets(MonOpRequestRef op
);
90 void get_health(list
<pair
<health_status_t
,string
> >& summary
,
91 list
<pair
<health_status_t
,string
> > *detail
,
92 CephContext
*cct
) const override
;
93 int fail_mds(std::ostream
&ss
, const std::string
&arg
);
95 bool preprocess_command(MonOpRequestRef op
);
96 bool prepare_command(MonOpRequestRef op
);
99 const std::string
&role_str
,
103 void modify_legacy_filesystem(
104 std::function
<void(std::shared_ptr
<Filesystem
> )> fn
);
105 int legacy_filesystem_command(
107 std::string
const &prefix
,
108 map
<string
, cmd_vartype
> &cmdmap
,
109 std::stringstream
&ss
);
110 int filesystem_command(
112 std::string
const &prefix
,
113 map
<string
, cmd_vartype
> &cmdmap
,
114 std::stringstream
&ss
);
117 struct beacon_info_t
{
121 map
<mds_gid_t
, beacon_info_t
> last_beacon
;
123 bool try_standby_replay(
124 const MDSMap::mds_info_t
& finfo
,
125 const Filesystem
&leader_fs
,
126 const MDSMap::mds_info_t
& ainfo
);
128 std::list
<std::shared_ptr
<FileSystemCommandHandler
> > handlers
;
130 bool maybe_promote_standby(std::shared_ptr
<Filesystem
> fs
);
131 bool maybe_expand_cluster(std::shared_ptr
<Filesystem
> fs
);
132 void maybe_replace_gid(mds_gid_t gid
, const MDSMap::mds_info_t
& info
,
133 bool *mds_propose
, bool *osd_propose
);
134 void tick() override
; // check state, take actions
136 int dump_metadata(const string
& who
, Formatter
*f
, ostream
& err
);
138 void update_metadata(mds_gid_t gid
, const Metadata
& metadata
);
139 void remove_from_metadata(MonitorDBStore::TransactionRef t
);
140 int load_metadata(map
<mds_gid_t
, Metadata
>& m
);
141 void count_metadata(const string
& field
, Formatter
*f
);
143 void count_metadata(const string
& field
, map
<string
,int> *out
);
146 // MDS daemon GID to latest health state from that GID
147 std::map
<uint64_t, MDSHealth
> pending_daemon_health
;
148 std::set
<uint64_t> pending_daemon_health_rm
;
150 map
<mds_gid_t
, Metadata
> pending_metadata
;
152 mds_gid_t
gid_from_arg(const std::string
& arg
, std::ostream
& err
);
154 // When did the mon last call into our tick() method? Used for detecting
155 // when the mon was not updating us for some period (e.g. during slow
156 // election) to reset last_beacon timeouts