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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
|
// -*- 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.
*
*/
#ifndef CEPH_MDS_SERVER_H
#define CEPH_MDS_SERVER_H
#include "MDS.h"
class ProfLogger;
class LogEvent;
class MDRequest;
class Mutation;
class EMetaBlob;
class EUpdate;
class MMDSSlaveRequest;
struct SnapInfo;
enum {
l_mdss_first = 1000,
l_mdss_hcreq,
l_mdss_hsreq,
l_mdss_hcsess,
l_mdss_dcreq,
l_mdss_dsreq,
l_mdss_last,
};
class Server {
MDS *mds;
MDCache *mdcache;
MDLog *mdlog;
Messenger *messenger;
ProfLogger *logger;
public:
int failed_reconnects;
bool terminating_sessions;
Server(MDS *m) :
mds(m),
mdcache(mds->mdcache), mdlog(mds->mdlog),
messenger(mds->messenger),
logger(0),
failed_reconnects(0),
terminating_sessions(false) {
}
~Server() {
logger_remove(logger);
delete logger;
}
void open_logger();
// message handler
void dispatch(Message *m);
// -- sessions and recovery --
utime_t reconnect_start;
set<client_t> client_reconnect_gather; // clients i need a reconnect msg from.
Session *get_session(Message *m);
void handle_client_session(class MClientSession *m);
void _session_logged(Session *session, uint64_t state_seq,
bool open, version_t pv, interval_set<inodeno_t>& inos,version_t piv);
version_t prepare_force_open_sessions(map<client_t,entity_inst_t> &cm,
map<client_t,uint64_t>& sseqmap);
void finish_force_open_sessions(map<client_t,entity_inst_t> &cm,
map<client_t,uint64_t>& sseqmap);
void terminate_sessions();
void find_idle_sessions();
void kill_session(Session *session);
void journal_close_session(Session *session, int state);
void reconnect_clients();
void handle_client_reconnect(class MClientReconnect *m);
//void process_reconnect_cap(CInode *in, int from, ceph_mds_cap_reconnect& capinfo);
void reconnect_gather_finish();
void reconnect_tick();
void recover_filelocks(CInode *in, bufferlist locks, int64_t client);
void recall_client_state(float ratio);
// -- requests --
void handle_client_request(MClientRequest *m);
void journal_and_reply(MDRequest *mdr, CInode *tracei, CDentry *tracedn,
LogEvent *le, Context *fin);
void dispatch_client_request(MDRequest *mdr);
void early_reply(MDRequest *mdr, CInode *tracei, CDentry *tracedn);
void reply_request(MDRequest *mdr, int r = 0, CInode *tracei = 0, CDentry *tracedn = 0);
void reply_request(MDRequest *mdr, MClientReply *reply, CInode *tracei = 0, CDentry *tracedn = 0);
void set_trace_dist(Session *session, MClientReply *reply, CInode *in, CDentry *dn,
snapid_t snapid,
int num_dentries_wanted);
void encode_empty_dirstat(bufferlist& bl);
void encode_infinite_lease(bufferlist& bl);
void encode_null_lease(bufferlist& bl);
void handle_slave_request(MMDSSlaveRequest *m);
void dispatch_slave_request(MDRequest *mdr);
void handle_slave_auth_pin(MDRequest *mdr);
void handle_slave_auth_pin_ack(MDRequest *mdr, MMDSSlaveRequest *ack);
// some helpers
CDir *validate_dentry_dir(MDRequest *mdr, CInode *diri, const string& dname);
CDir *traverse_to_auth_dir(MDRequest *mdr, vector<CDentry*> &trace, filepath refpath);
CDentry *prepare_null_dentry(MDRequest *mdr, CDir *dir, const string& dname, bool okexist=false);
CInode* prepare_new_inode(MDRequest *mdr, CDir *dir, inodeno_t useino, unsigned mode,
ceph_file_layout *layout=NULL);
void journal_allocated_inos(MDRequest *mdr, EMetaBlob *blob);
void apply_allocated_inos(MDRequest *mdr);
CInode* rdlock_path_pin_ref(MDRequest *mdr, int n, set<SimpleLock*>& rdlocks, bool want_auth,
bool no_want_auth=false,
ceph_file_layout **layout=NULL);
CDentry* rdlock_path_xlock_dentry(MDRequest *mdr, int n, set<SimpleLock*>& rdlocks, set<SimpleLock*>& wrlocks,
set<SimpleLock*>& xlocks, bool okexist, bool mustexist, bool alwaysxlock,
ceph_file_layout **layout=NULL);
CDir* try_open_auth_dirfrag(CInode *diri, frag_t fg, MDRequest *mdr);
// requests on existing inodes.
void handle_client_stat(MDRequest *mdr);
void handle_client_lookup_parent(MDRequest *mdr);
void handle_client_lookup_hash(MDRequest *mdr);
void _lookup_hash_2(MDRequest *mdr, int r);
void _lookup_hash_3(MDRequest *mdr, int r);
void handle_client_lookup_ino(MDRequest *mdr);
void _lookup_ino(MDRequest *mdr);
void _lookup_ino_2(MDRequest *mdr, int r);
void _lookup_ino_3(MDRequest *mdr, int r);
void handle_client_readdir(MDRequest *mdr);
void handle_client_file_setlock(MDRequest *mdr);
void handle_client_file_readlock(MDRequest *mdr);
void handle_client_setattr(MDRequest *mdr);
void handle_client_setlayout(MDRequest *mdr);
void handle_client_setdirlayout(MDRequest *mdr);
void handle_client_setxattr(MDRequest *mdr);
void handle_client_removexattr(MDRequest *mdr);
void handle_client_fsync(MDRequest *mdr);
// open
void handle_client_open(MDRequest *mdr);
void handle_client_openc(MDRequest *mdr); // O_CREAT variant.
void do_open_truncate(MDRequest *mdr, int cmode); // O_TRUNC variant.
// namespace changes
void handle_client_mknod(MDRequest *mdr);
void handle_client_mkdir(MDRequest *mdr);
void handle_client_symlink(MDRequest *mdr);
// link
void handle_client_link(MDRequest *mdr);
void _link_local(MDRequest *mdr, CDentry *dn, CInode *targeti);
void _link_local_finish(MDRequest *mdr,
CDentry *dn, CInode *targeti,
version_t, version_t);
void _link_remote(MDRequest *mdr, bool inc, CDentry *dn, CInode *targeti);
void _link_remote_finish(MDRequest *mdr, bool inc, CDentry *dn, CInode *targeti,
version_t);
void handle_slave_link_prep(MDRequest *mdr);
void _logged_slave_link(MDRequest *mdr, CInode *targeti);
void _commit_slave_link(MDRequest *mdr, int r, CInode *targeti);
void _committed_slave(MDRequest *mdr); // use for rename, too
void handle_slave_link_prep_ack(MDRequest *mdr, MMDSSlaveRequest *m);
void do_link_rollback(bufferlist &rbl, int master, MDRequest *mdr);
void _link_rollback_finish(Mutation *mut, MDRequest *mdr);
// unlink
void handle_client_unlink(MDRequest *mdr);
bool _dir_is_nonempty_unlocked(MDRequest *mdr, CInode *rmdiri);
bool _dir_is_nonempty(MDRequest *mdr, CInode *rmdiri);
void _unlink_local(MDRequest *mdr, CDentry *dn, CDentry *straydn);
void _unlink_local_finish(MDRequest *mdr,
CDentry *dn, CDentry *straydn,
version_t);
// rename
void handle_client_rename(MDRequest *mdr);
void _rename_finish(MDRequest *mdr,
CDentry *srcdn, CDentry *destdn, CDentry *straydn);
void handle_client_lssnap(MDRequest *mdr);
void handle_client_mksnap(MDRequest *mdr);
void _mksnap_finish(MDRequest *mdr, CInode *diri, SnapInfo &info);
void handle_client_rmsnap(MDRequest *mdr);
void _rmsnap_finish(MDRequest *mdr, CInode *diri, snapid_t snapid);
// helpers
void _rename_prepare_witness(MDRequest *mdr, int who,
CDentry *srcdn, CDentry *destdn, CDentry *straydn);
version_t _rename_prepare_import(MDRequest *mdr, CDentry *srcdn, bufferlist *client_map_bl);
void _rename_prepare(MDRequest *mdr,
EMetaBlob *metablob, bufferlist *client_map_bl,
CDentry *srcdn, CDentry *destdn, CDentry *straydn);
void _rename_apply(MDRequest *mdr, CDentry *srcdn, CDentry *destdn, CDentry *straydn);
// slaving
void handle_slave_rename_prep(MDRequest *mdr);
void handle_slave_rename_prep_ack(MDRequest *mdr, MMDSSlaveRequest *m);
void _logged_slave_rename(MDRequest *mdr, CDentry *srcdn, CDentry *destdn, CDentry *straydn);
void _commit_slave_rename(MDRequest *mdr, int r, CDentry *srcdn, CDentry *destdn, CDentry *straydn);
void do_rename_rollback(bufferlist &rbl, int master, MDRequest *mdr);
void _rename_rollback_finish(Mutation *mut, MDRequest *mdr, CInode *in, CDir *olddir);
};
inline ostream& operator<<(ostream& out, ceph_lock_state_t& l) {
out << "ceph_lock_state_t. held_locks.size()=" << l.held_locks.size()
<< ", waiting_locks.size()=" << l.waiting_locks.size()
<< ", client_held_lock_counts -- " << l.client_held_lock_counts
<< "\n client_waiting_lock_counts -- " << l.client_waiting_lock_counts
<< "\n held_locks -- ";
for (multimap<uint64_t, ceph_filelock>::iterator iter = l.held_locks.begin();
iter != l.held_locks.end();
++iter)
out << iter->second;
out << "\n waiting_locks -- ";
for (multimap<uint64_t, ceph_filelock>::iterator iter =l.waiting_locks.begin();
iter != l.waiting_locks.end();
++iter)
out << iter->second << "\n";
out << std::endl;
return out;
}
#endif
|
