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
|
// -*- 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_MMDSRESOLVE_H
#define CEPH_MMDSRESOLVE_H
#include "include/types.h"
#include "mds/Capability.h"
#include "messages/MMDSOp.h"
class MMDSResolve final : public MMDSOp {
static constexpr int HEAD_VERSION = 1;
static constexpr int COMPAT_VERSION = 1;
public:
std::map<dirfrag_t, std::vector<dirfrag_t>> subtrees;
std::map<dirfrag_t, std::vector<dirfrag_t>> ambiguous_imports;
class peer_inode_cap {
public:
inodeno_t ino;
std::map<client_t,Capability::Export> cap_exports;
peer_inode_cap() {}
peer_inode_cap(inodeno_t a, map<client_t, Capability::Export> b) : ino(a), cap_exports(b) {}
void encode(ceph::buffer::list &bl) const
{
ENCODE_START(1, 1, bl);
encode(ino, bl);
encode(cap_exports, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator &blp)
{
DECODE_START(1, blp);
decode(ino, blp);
decode(cap_exports, blp);
DECODE_FINISH(blp);
}
};
WRITE_CLASS_ENCODER(peer_inode_cap)
struct peer_request {
ceph::buffer::list inode_caps;
bool committing;
peer_request() : committing(false) {}
void encode(ceph::buffer::list &bl) const {
ENCODE_START(1, 1, bl);
encode(inode_caps, bl);
encode(committing, bl);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator &blp) {
DECODE_START(1, blp);
decode(inode_caps, blp);
decode(committing, blp);
DECODE_FINISH(blp);
}
};
std::map<metareqid_t, peer_request> peer_requests;
// table client information
struct table_client {
__u8 type;
std::set<version_t> pending_commits;
table_client() : type(0) {}
table_client(int _type, const std::set<version_t>& commits)
: type(_type), pending_commits(commits) {}
void encode(ceph::buffer::list& bl) const {
using ceph::encode;
encode(type, bl);
encode(pending_commits, bl);
}
void decode(ceph::buffer::list::const_iterator& bl) {
using ceph::decode;
decode(type, bl);
decode(pending_commits, bl);
}
};
std::list<table_client> table_clients;
protected:
MMDSResolve() : MMDSOp{MSG_MDS_RESOLVE, HEAD_VERSION, COMPAT_VERSION}
{}
~MMDSResolve() final {}
public:
std::string_view get_type_name() const override { return "mds_resolve"; }
void print(std::ostream& out) const override {
out << "mds_resolve(" << subtrees.size()
<< "+" << ambiguous_imports.size()
<< " subtrees +" << peer_requests.size() << " peer requests)";
}
void add_subtree(dirfrag_t im) {
subtrees[im].clear();
}
void add_subtree_bound(dirfrag_t im, dirfrag_t ex) {
subtrees[im].push_back(ex);
}
void add_ambiguous_import(dirfrag_t im, const std::vector<dirfrag_t>& m) {
ambiguous_imports[im] = m;
}
void add_peer_request(metareqid_t reqid, bool committing) {
peer_requests[reqid].committing = committing;
}
void add_peer_request(metareqid_t reqid, ceph::buffer::list& bl) {
peer_requests[reqid].inode_caps = std::move(bl);
}
void add_table_commits(int table, const std::set<version_t>& pending_commits) {
table_clients.push_back(table_client(table, pending_commits));
}
void encode_payload(uint64_t features) override {
using ceph::encode;
encode(subtrees, payload);
encode(ambiguous_imports, payload);
encode(peer_requests, payload);
encode(table_clients, payload);
}
void decode_payload() override {
using ceph::decode;
auto p = payload.cbegin();
decode(subtrees, p);
decode(ambiguous_imports, p);
decode(peer_requests, p);
decode(table_clients, p);
}
private:
template<class T, typename... Args>
friend boost::intrusive_ptr<T> ceph::make_message(Args&&... args);
};
inline std::ostream& operator<<(std::ostream& out, const MMDSResolve::peer_request&) {
return out;
}
WRITE_CLASS_ENCODER(MMDSResolve::peer_request)
WRITE_CLASS_ENCODER(MMDSResolve::table_client)
WRITE_CLASS_ENCODER(MMDSResolve::peer_inode_cap)
#endif
|
