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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
*
*/
/* Metadata Server Monitor
*/
#ifndef CEPH_MDSMONITOR_H
#define CEPH_MDSMONITOR_H
#include "mon_types.h"
#include <map>
#include <set>
#include "msg/Messenger.h"
#include "mds/MDSMap.h"
#include "messages/MMDSBeacon.h"
#include "PaxosService.h"
#include "Session.h"
using namespace std;
class MMDSGetMap;
class MMonCommand;
class MMDSLoadTargets;
class MDSMonitor : public PaxosService {
public:
// mds maps
MDSMap mdsmap; // current
bufferlist mdsmap_bl; // encoded
MDSMap pending_mdsmap; // current + pending updates
// my helpers
void print_map(MDSMap &m, int dbl=7);
class C_Updated : public Context {
MDSMonitor *mm;
MMDSBeacon *m;
public:
C_Updated(MDSMonitor *a, MMDSBeacon *c) :
mm(a), m(c) {}
void finish(int r) {
if (r == -ECANCELED) {
if (m)
m->put();
return;
}
if (r >= 0)
mm->_updated(m); // success
else
mm->dispatch((PaxosServiceMessage*)m); // try again
}
};
void create_new_fs(MDSMap &m, int metadata_pool, int data_pool);
// service methods
void create_initial();
void update_from_paxos();
void create_pending();
void encode_pending(bufferlist &bl);
void update_logger();
void _updated(MMDSBeacon *m);
bool preprocess_query(PaxosServiceMessage *m); // true if processed.
bool prepare_update(PaxosServiceMessage *m);
bool should_propose(double& delay);
void on_active();
void _note_beacon(class MMDSBeacon *m);
bool preprocess_beacon(class MMDSBeacon *m);
bool prepare_beacon(class MMDSBeacon *m);
bool preprocess_offload_targets(MMDSLoadTargets *m);
bool prepare_offload_targets(MMDSLoadTargets *m);
void get_health(list<pair<health_status_t,string> >& summary,
list<pair<health_status_t,string> > *detail) const;
int fail_mds(std::ostream &ss, const std::string &arg);
int cluster_fail(std::ostream &ss);
bool preprocess_command(MMonCommand *m);
bool prepare_command(MMonCommand *m);
// beacons
struct beacon_info_t {
utime_t stamp;
uint64_t seq;
};
map<uint64_t, beacon_info_t> last_beacon;
bool try_standby_replay(MDSMap::mds_info_t& finfo, MDSMap::mds_info_t& ainfo);
public:
MDSMonitor(Monitor *mn, Paxos *p)
: PaxosService(mn, p)
{
}
void tick(); // check state, take actions
void do_stop();
void dump_info(Formatter *f);
void check_subs();
void check_sub(Subscription *sub);
};
#endif
|
