MAuth() : PaxosServiceMessage(CEPH_MSG_AUTH, 0), protocol(0), monmap_epoch(0) { }
private:
- ~MAuth() {}
+ ~MAuth() override {}
public:
- const char *get_type_name() const { return "auth"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "auth"; }
+ void print(ostream& out) const override {
out << "auth(proto " << protocol << " " << auth_payload.length() << " bytes"
<< " epoch " << monmap_epoch << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(protocol, p);
else
monmap_epoch = 0;
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(protocol, payload);
::encode(auth_payload, payload);
result_bl = *bl;
}
private:
- ~MAuthReply() {}
+ ~MAuthReply() override {}
public:
- const char *get_type_name() const { return "auth_reply"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "auth_reply"; }
+ void print(ostream& o) const override {
o << "auth_reply(proto " << protocol << " " << result << " " << cpp_strerror(result);
if (result_msg.length())
o << ": " << result_msg;
o << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(protocol, p);
::decode(result, p);
::decode(result_bl, p);
::decode(result_msg, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(protocol, payload);
::encode(result, payload);
::encode(global_id, payload);
pgid(pgid), query_epoch(query_epoch),
type(type), priority(prio) {}
- const char *get_type_name() const {
+ const char *get_type_name() const override {
return "MBackfillReserve";
}
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "MBackfillReserve ";
switch (type) {
case REQUEST:
return;
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pgid.pgid, p);
::decode(query_epoch, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pgid.pgid, payload);
::encode(query_epoch, payload);
::encode(type, payload);
Message(MSG_MDS_CACHEEXPIRE),
from(f) { }
private:
- ~MCacheExpire() {}
+ ~MCacheExpire() override {}
public:
- virtual const char *get_type_name() const { return "cache_expire";}
+ const char *get_type_name() const override { return "cache_expire";}
void add_inode(dirfrag_t r, vinodeno_t vino, unsigned nonce) {
realms[r].inodes[vino] = nonce;
realms[df].merge(r);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(from, p);
::decode(realms, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(from, payload);
::encode(realms, payload);
}
memset(&head, 0, sizeof(head));
}
private:
- ~MClientCapRelease() {}
+ ~MClientCapRelease() override {}
public:
- const char *get_type_name() const { return "client_cap_release";}
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "client_cap_release";}
+ void print(ostream& out) const override {
out << "client_cap_release(" << caps.size() << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(head, p);
::decode_nohead(head.num, caps, p);
::decode(osd_epoch_barrier, p);
}
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
head.num = caps.size();
::encode(head, payload);
::encode_nohead(caps, payload);
private:
file_layout_t layout;
- ~MClientCaps() {}
+ ~MClientCaps() override {}
public:
- const char *get_type_name() const { return "Cfcap";}
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "Cfcap";}
+ void print(ostream& out) const override {
out << "client_caps(" << ceph_cap_op_name(head.op)
<< " ino " << inodeno_t(head.ino)
<< " " << head.cap_id
out << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(head, p);
ceph_mds_caps_body_legacy body;
::decode(flags, p);
}
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
header.version = HEAD_VERSION;
head.snap_trace_len = snapbl.length();
head.xattr_len = xattrbl.length();
h.duration_ms = 0;
}
private:
- ~MClientLease() {}
+ ~MClientLease() override {}
public:
- const char *get_type_name() const { return "client_lease"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "client_lease"; }
+ void print(ostream& out) const override {
out << "client_lease(a=" << ceph_lease_op_name(get_action())
<< " seq " << get_seq()
<< " mask " << get_mask();
out << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(h, p);
::decode(dname, p);
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(h, payload);
::encode(dname, payload);
}
memset("a, 0, sizeof(quota));
}
private:
- ~MClientQuota() {}
+ ~MClientQuota() override {}
public:
- const char *get_type_name() const { return "client_quota"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "client_quota"; }
+ void print(ostream& out) const override {
out << "client_quota(";
out << " [" << ino << "] ";
out << rstat;
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(ino, payload);
::encode(rstat.rctime, payload);
::encode(rstat.rbytes, payload);
::encode(rstat.rsubdirs, payload);
::encode(quota, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(ino, p);
::decode(rstat.rctime, p);
MClientReconnect() : Message(CEPH_MSG_CLIENT_RECONNECT, HEAD_VERSION) { }
private:
- ~MClientReconnect() {}
+ ~MClientReconnect() override {}
public:
- const char *get_type_name() const { return "client_reconnect"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "client_reconnect"; }
+ void print(ostream& out) const override {
out << "client_reconnect("
<< caps.size() << " caps)";
}
realms.push_back(r);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
data.clear();
if (features & CEPH_FEATURE_MDSENC) {
::encode(caps, data);
}
::encode_nohead(realms, data);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = data.begin();
if (header.version >= 3) {
// new protocol
head.safe = 1;
}
private:
- ~MClientReply() {}
+ ~MClientReply() override {}
public:
- const char *get_type_name() const { return "creply"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "creply"; }
+ void print(ostream& o) const override {
o << "client_reply(???:" << get_tid();
o << " = " << get_result();
if (get_result() <= 0) {
}
// serialization
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(head, p);
::decode(trace_bl, p);
::decode(snapbl, p);
assert(p.end());
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(head, payload);
::encode(trace_bl, payload);
::encode(extra_bl, payload);
head.op = op;
}
private:
- ~MClientRequest() {}
+ ~MClientRequest() override {}
public:
void set_mdsmap_epoch(epoch_t e) { head.mdsmap_epoch = e; }
int get_dentry_wanted() { return get_flags() & CEPH_MDS_FLAG_WANT_DENTRY; }
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
if (header.version >= 4) {
::decode(gid_list, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
head.num_releases = releases.size();
head.version = CEPH_MDS_REQUEST_HEAD_VERSION;
::encode(gid_list, payload);
}
- const char *get_type_name() const { return "creq"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "creq"; }
+ void print(ostream& out) const override {
out << "client_request(" << get_orig_source()
<< ":" << get_tid()
<< " " << ceph_mds_op_name(get_op());
header.tid = t;
}
private:
- ~MClientRequestForward() {}
+ ~MClientRequestForward() override {}
public:
int get_dest_mds() { return dest_mds; }
int get_num_fwd() { return num_fwd; }
bool must_resend() { return client_must_resend; }
- const char *get_type_name() const { return "client_request_forward"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "client_request_forward"; }
+ void print(ostream& o) const override {
o << "client_request_forward(" << get_tid()
<< " to mds." << dest_mds
<< " num_fwd=" << num_fwd
<< ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(dest_mds, payload);
::encode(num_fwd, payload);
::encode(client_must_resend, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(dest_mds, p);
::decode(num_fwd, p);
st.encode_timeval(&head.stamp);
}
private:
- ~MClientSession() {}
+ ~MClientSession() override {}
public:
- const char *get_type_name() const { return "client_session"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "client_session"; }
+ void print(ostream& out) const override {
out << "client_session(" << ceph_session_op_name(get_op());
if (get_seq())
out << " seq " << get_seq();
out << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(head, p);
if (header.version >= 2) {
::decode(client_meta, p);
}
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(head, payload);
if (client_meta.empty()) {
// If we're not trying to send any metadata (always the case if
head.op = o;
}
private:
- ~MClientSnap() {}
+ ~MClientSnap() override {}
public:
- const char *get_type_name() const { return "client_snap"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "client_snap"; }
+ void print(ostream& out) const override {
out << "client_snap(" << ceph_snap_op_name(head.op);
if (head.split)
out << " split=" << inodeno_t(head.split);
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
head.num_split_inos = split_inos.size();
head.num_split_realms = split_realms.size();
head.trace_len = bl.length();
::encode_nohead(split_realms, payload);
::encode_nohead(bl, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(head, p);
::decode_nohead(head.num_split_inos, split_inos, p);
fsid(f) { }
private:
- ~MCommand() {}
+ ~MCommand() override {}
public:
- const char *get_type_name() const { return "command"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "command"; }
+ void print(ostream& o) const override {
o << "command(tid " << get_tid() << ": ";
for (unsigned i=0; i<cmd.size(); i++) {
if (i) o << ' ';
o << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(fsid, payload);
::encode(cmd, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(fsid, p);
::decode(cmd, p);
: Message(MSG_COMMAND_REPLY),
r(_r), rs(s) { }
private:
- ~MCommandReply() {}
+ ~MCommandReply() override {}
public:
- const char *get_type_name() const { return "command_reply"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "command_reply"; }
+ void print(ostream& o) const override {
o << "command_reply(tid " << get_tid() << ": " << r << " " << rs << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(r, payload);
::encode(rs, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(r, p);
::decode(rs, p);
}
private:
- ~MDataPing()
+ ~MDataPing() override
{
if (mdata_hook)
mdata_hook(&mp);
}
public:
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(tag, p);
::decode(counter, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(tag, payload);
::encode(counter, payload);
}
- const char *get_type_name() const { return "data_ping"; }
+ const char *get_type_name() const override { return "data_ping"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << get_type_name() << " " << tag << " " << counter;
}
};
dn(n),
is_primary(p) {}
private:
- ~MDentryLink() {}
+ ~MDentryLink() override {}
public:
- const char *get_type_name() const { return "dentry_link";}
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "dentry_link";}
+ void print(ostream& o) const override {
o << "dentry_link(" << dirfrag << " " << dn << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(subtree, p);
::decode(dirfrag, p);
::decode(is_primary, p);
::decode(bl, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(subtree, payload);
::encode(dirfrag, payload);
::encode(dn, payload);
dirfrag(df),
dn(n) {}
private:
- ~MDentryUnlink() {}
+ ~MDentryUnlink() override {}
public:
- const char *get_type_name() const { return "dentry_unlink";}
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "dentry_unlink";}
+ void print(ostream& o) const override {
o << "dentry_unlink(" << dirfrag << " " << dn << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
::decode(dn, p);
::decode(straybl, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(dirfrag, payload);
::encode(dn, payload);
::encode(straybl, payload);
this->path = path;
}
private:
- ~MDirUpdate() {}
+ ~MDirUpdate() override {}
public:
- const char *get_type_name() const { return "dir_update"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "dir_update"; }
+ void print(ostream& out) const override {
out << "dir_update(" << get_dirfrag() << ")";
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(from_mds, p);
::decode(dirfrag, p);
::decode(path, p);
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(from_mds, payload);
::encode(dirfrag, payload);
::encode(dir_rep, payload);
want_base_dir(want_base_dir_),
want_xlocked(discover_xlocks_) { }
private:
- ~MDiscover() {}
+ ~MDiscover() override {}
public:
- const char *get_type_name() const { return "Dis"; }
- void print(ostream &out) const {
+ const char *get_type_name() const override { return "Dis"; }
+ void print(ostream &out) const override {
out << "discover(" << header.tid << " " << base_ino << "." << base_dir_frag
<< " " << want << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(base_ino, p);
::decode(base_dir_frag, p);
::decode(want_base_dir, p);
::decode(want_xlocked, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(base_ino, payload);
::encode(base_dir_frag, payload);
::encode(snapid, payload);
header.tid = 0;
}
private:
- ~MDiscoverReply() {}
+ ~MDiscoverReply() override {}
public:
- const char *get_type_name() const { return "discover_reply"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "discover_reply"; }
+ void print(ostream& out) const override {
out << "discover_reply(" << header.tid << " " << base_ino << ")";
}
// ...
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(base_ino, p);
::decode(base_dir_frag, p);
::decode(starts_with, p);
::decode(trace, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(base_ino, payload);
::encode(base_dir_frag, payload);
::encode(wanted_base_dir, payload);
MExportCaps() :
Message(MSG_MDS_EXPORTCAPS) {}
private:
- ~MExportCaps() {}
+ ~MExportCaps() override {}
public:
- const char *get_type_name() const { return "export_caps"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "export_caps"; }
+ void print(ostream& o) const override {
o << "export_caps(" << ino << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(ino, payload);
::encode(cap_bl, payload);
::encode(client_map, payload, features);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(ino, p);
::decode(cap_bl, p);
MExportCapsAck(inodeno_t i) :
Message(MSG_MDS_EXPORTCAPSACK), ino(i) {}
private:
- ~MExportCapsAck() {}
+ ~MExportCapsAck() override {}
public:
- const char *get_type_name() const { return "export_caps_ack"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "export_caps_ack"; }
+ void print(ostream& o) const override {
o << "export_caps_ack(" << ino << ")";
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(ino, payload);
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(ino, p);
}
set_tid(tid);
}
private:
- ~MExportDir() {}
+ ~MExportDir() override {}
public:
- const char *get_type_name() const { return "Ex"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "Ex"; }
+ void print(ostream& o) const override {
o << "export(" << dirfrag << ")";
}
bounds.push_back(df);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(dirfrag, payload);
::encode(bounds, payload);
::encode(export_data, payload);
::encode(client_map, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
::decode(bounds, p);
set_tid(tid);
}
private:
- ~MExportDirAck() {}
+ ~MExportDirAck() override {}
public:
- const char *get_type_name() const { return "ExAck"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "ExAck"; }
+ void print(ostream& o) const override {
o << "export_ack(" << dirfrag << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
::decode(imported_caps, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(dirfrag, payload);
::encode(imported_caps, payload);
}
set_tid(tid);
}
private:
- ~MExportDirCancel() {}
+ ~MExportDirCancel() override {}
public:
- const char *get_type_name() const { return "ExCancel"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "ExCancel"; }
+ void print(ostream& o) const override {
o << "export_cancel(" << dirfrag << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(dirfrag, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
}
set_tid(tid);
}
private:
- ~MExportDirDiscover() {}
+ ~MExportDirDiscover() override {}
public:
- const char *get_type_name() const { return "ExDis"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "ExDis"; }
+ void print(ostream& o) const override {
o << "export_discover(" << dirfrag << " " << path << ")";
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(from, p);
::decode(dirfrag, p);
::decode(path, p);
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(from, payload);
::encode(dirfrag, payload);
::encode(path, payload);
set_tid(tid);
}
private:
- ~MExportDirDiscoverAck() {}
+ ~MExportDirDiscoverAck() override {}
public:
- const char *get_type_name() const { return "ExDisA"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "ExDisA"; }
+ void print(ostream& o) const override {
o << "export_discover_ack(" << dirfrag;
if (success)
o << " success)";
o << " failure)";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
::decode(success, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(dirfrag, payload);
::encode(success, payload);
}
set_tid(tid);
}
private:
- ~MExportDirFinish() {}
+ ~MExportDirFinish() override {}
public:
- const char *get_type_name() const { return "ExFin"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "ExFin"; }
+ void print(ostream& o) const override {
o << "export_finish(" << dirfrag << (last ? " last" : "") << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(dirfrag, payload);
::encode(last, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
::decode(last, p);
set_tid(tid);
}
private:
- ~MExportDirNotify() {}
+ ~MExportDirNotify() override {}
public:
- const char *get_type_name() const { return "ExNot"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "ExNot"; }
+ void print(ostream& o) const override {
o << "export_notify(" << base;
o << " " << old_auth << " -> " << new_auth;
if (ack)
bounds.push_back(*i);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(base, payload);
::encode(ack, payload);
::encode(old_auth, payload);
::encode(new_auth, payload);
::encode(bounds, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(base, p);
::decode(ack, p);
set_tid(tid);
}
private:
- ~MExportDirNotifyAck() {}
+ ~MExportDirNotifyAck() override {}
public:
- const char *get_type_name() const { return "ExNotA"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "ExNotA"; }
+ void print(ostream& o) const override {
o << "export_notify_ack(" << dirfrag << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(dirfrag, payload);
::encode(new_auth, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
::decode(new_auth, p);
set_tid(tid);
}
private:
- ~MExportDirPrep() {}
+ ~MExportDirPrep() override {}
public:
- const char *get_type_name() const { return "ExP"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "ExP"; }
+ void print(ostream& o) const override {
o << "export_prep(" << dirfrag << ")";
}
bystanders.insert(who);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
::decode(basedir, p);
::decode(bystanders, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(dirfrag, payload);
::encode(basedir, payload);
::encode(bounds, payload);
set_tid(tid);
}
private:
- ~MExportDirPrepAck() {}
+ ~MExportDirPrepAck() override {}
public:
bool is_success() { return success; }
- const char *get_type_name() const { return "ExPAck"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "ExPAck"; }
+ void print(ostream& o) const override {
o << "export_prep_ack(" << dirfrag << (success ? " success)" : " fail)");
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
::decode(success, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(dirfrag, payload);
::encode(success, payload);
}
private:
FSMap fsmap;
- ~MFSMap() {}
+ ~MFSMap() override {}
public:
- const char *get_type_name() const { return "fsmap"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "fsmap"; }
+ void print(ostream& out) const override {
out << "fsmap(e " << epoch << ")";
}
// marshalling
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
::decode(fsmap, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(epoch, payload);
::encode(fsmap, payload, features);
}
private:
FSMapUser fsmap;
- ~MFSMapUser() {}
+ ~MFSMapUser() override {}
public:
- const char *get_type_name() const { return "fsmap.user"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "fsmap.user"; }
+ void print(ostream& out) const override {
out << "fsmap.user(e " << epoch << ")";
}
// marshalling
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
::decode(fsmap, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(epoch, payload);
::encode(fsmap, payload, features);
}
msg = (PaxosServiceMessage*)m->get();
}
private:
- ~MForward() {
+ ~MForward() override {
if (msg) {
// message was unclaimed
msg->put();
}
public:
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(tid, payload);
::encode(client, payload, features);
::encode(client_caps, payload, features);
::encode(entity_name, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(tid, p);
::decode(client, p);
return m;
}
- const char *get_type_name() const { return "forward"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "forward"; }
+ void print(ostream& o) const override {
o << "forward(";
if (msg) {
o << *msg;
MGatherCaps() :
Message(MSG_MDS_GATHERCAPS) {}
private:
- ~MGatherCaps() {}
+ ~MGatherCaps() override {}
public:
- const char *get_type_name() const { return "gather_caps"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "gather_caps"; }
+ void print(ostream& o) const override {
o << "gather_caps(" << ino << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(ino, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(ino, p);
}
//void set_pcid(long pcid) { this->pcid = pcid; }
//long get_pcid() { return pcid; }
- const char *get_type_name() const { return tname; }
+ const char *get_type_name() const override { return tname; }
- void decode_payload() { }
- void encode_payload(uint64_t features) { }
+ void decode_payload() override { }
+ void encode_payload(uint64_t features) override { }
};
#endif
}
private:
- ~MGetPoolStats() {}
+ ~MGetPoolStats() override {}
public:
- const char *get_type_name() const { return "getpoolstats"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "getpoolstats"; }
+ void print(ostream& out) const override {
out << "getpoolstats(" << get_tid() << " " << pools << " v" << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(pools, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
}
private:
- ~MGetPoolStatsReply() {}
+ ~MGetPoolStatsReply() override {}
public:
- const char *get_type_name() const { return "getpoolstats"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "getpoolstats"; }
+ void print(ostream& out) const override {
out << "getpoolstatsreply(" << get_tid() << " v" << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(pool_stats, payload, features);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
this->beat = beat;
}
private:
- ~MHeartbeat() {}
+ ~MHeartbeat() override {}
public:
- const char *get_type_name() const { return "HB"; }
+ const char *get_type_name() const override { return "HB"; }
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(load, payload);
::encode(beat, payload);
::encode(import_map, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
utime_t now(ceph_clock_now());
::decode(load, now, p);
this->caps = caps;
}
private:
- ~MInodeFileCaps() {}
+ ~MInodeFileCaps() override {}
public:
- const char *get_type_name() const { return "inode_file_caps";}
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "inode_file_caps";}
+ void print(ostream& out) const override {
out << "inode_file_caps(" << ino << " " << ccap_string(caps) << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(ino, payload);
::encode(caps, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(ino, p);
::decode(caps, p);
lockdata.claim(bl);
}
private:
- ~MLock() {}
+ ~MLock() override {}
public:
- const char *get_type_name() const { return "ILock"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "ILock"; }
+ void print(ostream& out) const override {
out << "lock(a=" << get_lock_action_name(action)
<< " " << get_lock_type_name(lock_type)
<< " " << object_info
this->lockdata = lockdata;
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(asker, p);
::decode(action, p);
::decode(object_info, p);
::decode(lockdata, p);
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(asker, payload);
::encode(action, payload);
::encode(reqid, payload);
: PaxosServiceMessage(MSG_LOG, 0), fsid(f), entries(e) { }
MLog(const uuid_d& f) : PaxosServiceMessage(MSG_LOG, 0), fsid(f) { }
private:
- ~MLog() {}
+ ~MLog() override {}
public:
- const char *get_type_name() const { return "log"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "log"; }
+ void print(ostream& out) const override {
out << "log(";
if (entries.size())
out << entries.size() << " entries from seq " << entries.front().seq
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(entries, payload, features);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
MLogAck() : Message(MSG_LOGACK) {}
MLogAck(uuid_d& f, version_t l) : Message(MSG_LOGACK), fsid(f), last(l) {}
private:
- ~MLogAck() {}
+ ~MLogAck() override {}
public:
- const char *get_type_name() const { return "log_ack"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "log_ack"; }
+ void print(ostream& out) const override {
out << "log(last " << last << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(fsid, payload);
::encode(last, payload);
::encode(channel, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(fsid, p);
::decode(last, p);
standby_replay(false), mds_features(feat) {
}
private:
- ~MMDSBeacon() {}
+ ~MMDSBeacon() override {}
public:
uuid_d& get_fsid() { return fsid; }
epoch_t get_last_epoch_seen() { return version; }
MDSMap::DaemonState get_state() { return state; }
version_t get_seq() { return seq; }
- const char *get_type_name() const { return "mdsbeacon"; }
+ const char *get_type_name() const override { return "mdsbeacon"; }
mds_rank_t get_standby_for_rank() { return standby_for_rank; }
const string& get_standby_for_name() { return standby_for_name; }
const fs_cluster_id_t& get_standby_for_fscid() { return standby_for_fscid; }
const map<string, string>& get_sys_info() const { return sys_info; }
void set_sys_info(const map<string, string>& i) { sys_info = i; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "mdsbeacon(" << global_id << "/" << name << " " << ceph_mds_state_name(state)
<< " seq " << seq << " v" << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(global_id, payload);
::encode(standby_for_fscid, payload);
::encode(standby_replay, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
Message(MSG_MDS_CACHEREJOIN, HEAD_VERSION, COMPAT_VERSION),
op(o) {}
private:
- ~MMDSCacheRejoin() {}
+ ~MMDSCacheRejoin() override {}
public:
- const char *get_type_name() const { return "cache_rejoin"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "cache_rejoin"; }
+ void print(ostream& out) const override {
out << "cache_rejoin " << get_opname(op);
}
}
// -- encoding --
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(op, payload);
::encode(strong_inodes, payload);
::encode(inode_base, payload);
::encode(authpinned_dentries, payload);
::encode(xlocked_dentries, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(op, p);
::decode(strong_inodes, p);
MMDSFindIno() : Message(MSG_MDS_FINDINO) {}
MMDSFindIno(ceph_tid_t t, inodeno_t i) : Message(MSG_MDS_FINDINO), tid(t), ino(i) {}
- const char *get_type_name() const { return "findino"; }
- void print(ostream &out) const {
+ const char *get_type_name() const override { return "findino"; }
+ void print(ostream &out) const override {
out << "findino(" << tid << " " << ino << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(tid, payload);
::encode(ino, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(tid, p);
::decode(ino, p);
MMDSFindInoReply() : Message(MSG_MDS_FINDINOREPLY) {}
MMDSFindInoReply(ceph_tid_t t) : Message(MSG_MDS_FINDINOREPLY), tid(t) {}
- const char *get_type_name() const { return "findinoreply"; }
- void print(ostream &out) const {
+ const char *get_type_name() const override { return "findinoreply"; }
+ void print(ostream &out) const override {
out << "findinoreply(" << tid << " " << path << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(tid, payload);
::encode(path, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(tid, p);
::decode(path, p);
Message(MSG_MDS_FRAGMENTNOTIFY),
ino(df.ino), basefrag(df.frag), bits(b) { }
private:
- ~MMDSFragmentNotify() {}
+ ~MMDSFragmentNotify() override {}
public:
- const char *get_type_name() const { return "fragment_notify"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "fragment_notify"; }
+ void print(ostream& o) const override {
o << "fragment_notify(" << ino << "." << basefrag
<< " " << (int)bits << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(ino, payload);
::encode(basefrag, payload);
::encode(bits, payload);
::encode(basebl, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(ino, p);
::decode(basefrag, p);
PaxosServiceMessage(MSG_MDS_OFFLOAD_TARGETS, 0),
global_id(g), targets(mds_targets) {}
private:
- ~MMDSLoadTargets() {}
+ ~MMDSLoadTargets() override {}
public:
- const char* get_type_name() const { return "mds_load_targets"; }
- void print(ostream& o) const {
+ const char* get_type_name() const override { return "mds_load_targets"; }
+ void print(ostream& o) const override {
o << "mds_load_targets(" << global_id << " " << targets << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(global_id, p);
::decode(targets, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(global_id, payload);
::encode(targets, payload);
mm->encode(encoded, -1); // we will reencode with fewer features as necessary
}
private:
- ~MMDSMap() {}
+ ~MMDSMap() override {}
public:
- const char *get_type_name() const { return "mdsmap"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "mdsmap"; }
+ void print(ostream& out) const override {
out << "mdsmap(e " << epoch << ")";
}
// marshalling
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(fsid, p);
::decode(epoch, p);
::decode(encoded, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(fsid, payload);
::encode(epoch, payload);
if ((features & CEPH_FEATURE_PGID64) == 0 ||
header.tid = t;
}
- const char *get_type_name() const { return "openino"; }
- void print(ostream &out) const {
+ const char *get_type_name() const override { return "openino"; }
+ void print(ostream &out) const override {
out << "openino(" << header.tid << " " << ino << " " << ancestors << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(ino, payload);
::encode(ancestors, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(ino, p);
::decode(ancestors, p);
header.tid = t;
}
- const char *get_type_name() const { return "openinoreply"; }
- void print(ostream &out) const {
+ const char *get_type_name() const override { return "openinoreply"; }
+ void print(ostream &out) const override {
out << "openinoreply(" << header.tid << " "
<< ino << " " << hint << " " << ancestors << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(ino, payload);
::encode(ancestors, payload);
::encode(hint, payload);
::encode(error, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(ino, p);
::decode(ancestors, p);
MMDSResolve() : Message(MSG_MDS_RESOLVE) {}
private:
- ~MMDSResolve() {}
+ ~MMDSResolve() override {}
public:
- const char *get_type_name() const { return "mds_resolve"; }
+ const char *get_type_name() const override { return "mds_resolve"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "mds_resolve(" << subtrees.size()
<< "+" << ambiguous_imports.size()
<< " subtrees +" << slave_requests.size() << " slave requests)";
slave_requests[reqid].inode_caps.claim(bl);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(subtrees, payload);
::encode(ambiguous_imports, payload);
::encode(slave_requests, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(subtrees, p);
::decode(ambiguous_imports, p);
MMDSResolveAck() : Message(MSG_MDS_RESOLVEACK) {}
private:
- ~MMDSResolveAck() {}
+ ~MMDSResolveAck() override {}
public:
- const char *get_type_name() const { return "resolve_ack"; }
+ const char *get_type_name() const override { return "resolve_ack"; }
/*void print(ostream& out) const {
out << "resolve_ack.size()
<< "+" << ambiguous_imap.size()
abort.push_back(r);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(commit, payload);
::encode(abort, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(commit, p);
::decode(abort, p);
reqid(ri), attempt(att), op(o), flags(0), lock_type(0),
inode_export_v(0) { }
private:
- ~MMDSSlaveRequest() {}
+ ~MMDSSlaveRequest() override {}
public:
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(reqid, payload);
::encode(attempt, payload);
::encode(op, payload);
::encode(srci_replica, payload);
::encode(stray, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(reqid, p);
::decode(attempt, p);
::decode(stray, p);
}
- const char *get_type_name() const { return "slave_request"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "slave_request"; }
+ void print(ostream& out) const override {
out << "slave_request(" << reqid
<< "." << attempt
<< " " << get_opname(op)
set_tid(v);
}
private:
- ~MMDSTableRequest() {}
+ ~MMDSTableRequest() override {}
public:
- virtual const char *get_type_name() const { return "mds_table_request"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "mds_table_request"; }
+ void print(ostream& o) const override {
o << "mds_table_request(" << get_mdstable_name(table)
<< " " << get_mdstableserver_opname(op);
if (reqid) o << " " << reqid;
o << ")";
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(table, p);
::decode(op, p);
::decode(bl, p);
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(table, payload);
::encode(op, payload);
::encode(reqid, payload);
const std::string& get_name() const { return name; }
private:
- ~MMgrBeacon() {}
+ ~MMgrBeacon() override {}
public:
- const char *get_type_name() const { return "mgrbeacon"; }
+ const char *get_type_name() const override { return "mgrbeacon"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << get_type_name() << " mgr." << name << "(" << gid << ", "
<< server_addr << ", " << available << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(server_addr, payload, features);
::encode(gid, payload);
::encode(available, payload);
::encode(name, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(server_addr, p);
public:
uint32_t stats_period;
- void decode_payload()
+ void decode_payload() override
{
bufferlist::iterator p = payload.begin();
::decode(stats_period, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(stats_period, payload);
}
- const char *get_type_name() const { return "mgrconfigure"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "mgrconfigure"; }
+ void print(ostream& out) const override {
out << get_type_name() << "()";
}
MMgrDigest() :
Message(MSG_MGR_DIGEST) {}
- const char *get_type_name() const { return "mgrdigest"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "mgrdigest"; }
+ void print(ostream& out) const override {
out << get_type_name();
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(mon_status_json, p);
::decode(health_json, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(mon_status_json, payload);
::encode(health_json, payload);
}
private:
- ~MMgrDigest() {}
+ ~MMgrDigest() override {}
};
}
private:
- ~MMgrMap() {}
+ ~MMgrMap() override {}
public:
- const char *get_type_name() const { return "mgrmap"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "mgrmap"; }
+ void print(ostream& out) const override {
out << get_type_name() << "(e " << map.epoch << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(map, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(map, payload, features);
}
};
std::string daemon_name;
- void decode_payload()
+ void decode_payload() override
{
bufferlist::iterator p = payload.begin();
::decode(daemon_name, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(daemon_name, payload);
}
- const char *get_type_name() const { return "mgropen"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "mgropen"; }
+ void print(ostream& out) const override {
out << get_type_name() << "(" << daemon_name << ")";
}
std::string daemon_name;
- void decode_payload()
+ void decode_payload() override
{
bufferlist::iterator p = payload.begin();
::decode(daemon_name, p);
::decode(packed, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(daemon_name, payload);
::encode(declare_types, payload);
::encode(packed, payload);
}
- const char *get_type_name() const { return "mgrreport"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "mgrreport"; }
+ void print(ostream& out) const override {
out << get_type_name() << "(" << declare_types.size() << " "
<< packed.length() << ")";
}
{ }
private:
- ~MMonCommand() {}
+ ~MMonCommand() override {}
public:
- const char *get_type_name() const { return "mon_command"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "mon_command"; }
+ void print(ostream& o) const override {
o << "mon_command(";
for (unsigned i=0; i<cmd.size(); i++) {
if (i) o << ' ';
o << " v " << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(cmd, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
PaxosServiceMessage(MSG_MON_COMMAND_ACK, v),
cmd(c), r(_r), rs(s) { }
private:
- ~MMonCommandAck() {}
+ ~MMonCommandAck() override {}
public:
- const char *get_type_name() const { return "mon_command"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "mon_command"; }
+ void print(ostream& o) const override {
o << "mon_command_ack(" << cmd << "=" << r << " " << rs << " v" << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(r, payload);
::encode(rs, payload);
::encode(cmd, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(r, p);
m->encode(monmap_bl, CEPH_FEATURES_ALL);
}
private:
- ~MMonElection() {}
+ ~MMonElection() override {}
public:
- const char *get_type_name() const { return "election"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "election"; }
+ void print(ostream& out) const override {
out << "election(" << fsid << " " << get_opname(op) << " " << epoch << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
if (monmap_bl.length() && (features != CEPH_FEATURES_ALL)) {
// reencode old-format monmap
MonMap t;
::encode(sharing_bl, payload);
::encode(mon_features, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
if (header.version >= 2)
::decode(fsid, p);
public:
MMonGetMap() : Message(CEPH_MSG_MON_GET_MAP) { }
private:
- ~MMonGetMap() {}
+ ~MMonGetMap() override {}
public:
- const char *get_type_name() const { return "mon_getmap"; }
+ const char *get_type_name() const override { return "mon_getmap"; }
- void encode_payload(uint64_t features) { }
- void decode_payload() { }
+ void encode_payload(uint64_t features) override { }
+ void decode_payload() override { }
};
#endif
inc_first(0),
inc_last(0) { }
private:
- ~MMonGetOSDMap() {}
+ ~MMonGetOSDMap() override {}
public:
void request_full(epoch_t first, epoch_t last) {
return inc_last;
}
- const char *get_type_name() const { return "mon_get_osdmap"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "mon_get_osdmap"; }
+ void print(ostream& out) const override {
out << "mon_get_osdmap(";
if (full_first && full_last)
out << "full " << full_first << "-" << full_last;
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(full_first, payload);
::encode(full_last, payload);
::encode(inc_first, payload);
::encode(inc_last, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(full_first, p);
public:
MMonGetVersion() : Message(CEPH_MSG_MON_GET_VERSION) {}
- const char *get_type_name() const {
+ const char *get_type_name() const override {
return "mon_get_version";
}
- void print(ostream& o) const {
+ void print(ostream& o) const override {
o << "mon_get_version(what=" << what << " handle=" << handle << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(handle, payload);
::encode(what, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(handle, p);
::decode(what, p);
string what;
private:
- ~MMonGetVersion() {}
+ ~MMonGetVersion() override {}
};
#endif
public:
MMonGetVersionReply() : Message(CEPH_MSG_MON_GET_VERSION_REPLY, HEAD_VERSION) { }
- const char *get_type_name() const {
+ const char *get_type_name() const override {
return "mon_get_version_reply";
}
- void print(ostream& o) const {
+ void print(ostream& o) const override {
o << "mon_get_version_reply(handle=" << handle << " version=" << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(handle, payload);
::encode(version, payload);
::encode(oldest_version, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(handle, p);
::decode(version, p);
version_t oldest_version;
private:
- ~MMonGetVersionReply() {}
+ ~MMonGetVersionReply() override {}
};
#endif
uint64_t old_max_id;
MMonGlobalID() : PaxosServiceMessage(MSG_MON_GLOBAL_ID, 0), old_max_id(0) { }
private:
- ~MMonGlobalID() {}
+ ~MMonGlobalID() override {}
public:
- const char *get_type_name() const { return "global_id"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "global_id"; }
+ void print(ostream& out) const override {
out << "global_id (" << old_max_id << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(old_max_id, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(old_max_id, payload);
}
{ }
private:
- ~MMonHealth() { }
+ ~MMonHealth() override { }
public:
- const char *get_type_name() const { return "mon_health"; }
+ const char *get_type_name() const override { return "mon_health"; }
const char *get_service_op_name() const {
switch (service_op) {
case OP_TELL: return "tell";
}
return "???";
}
- void print(ostream &o) const {
+ void print(ostream &o) const override {
o << "mon_health( service " << get_service_type()
<< " op " << get_service_op_name()
<< " e " << get_epoch() << " r " << get_round()
return service_op;
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
service_decode(p);
::decode(service_type, p);
::decode(data_stats, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
service_encode();
::encode(service_type, payload);
::encode(service_op, payload);
{ }
private:
- ~MMonJoin() {}
+ ~MMonJoin() override {}
public:
- const char *get_type_name() const { return "mon_join"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "mon_join"; }
+ void print(ostream& o) const override {
o << "mon_join(" << name << " " << addr << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(name, payload);
::encode(addr, payload, features);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
monmapbl.claim(bl);
}
private:
- ~MMonMap() {}
+ ~MMonMap() override {}
public:
- const char *get_type_name() const { return "mon_map"; }
+ const char *get_type_name() const override { return "mon_map"; }
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
if (monmapbl.length() &&
((features & CEPH_FEATURE_MONENC) == 0 ||
(features & CEPH_FEATURE_MSG_ADDR2) == 0)) {
::encode(monmapbl, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(monmapbl, p);
}
private:
static const int HEAD_VERSION = 1;
- ~MMonMetadata() {}
+ ~MMonMetadata() override {}
public:
MMonMetadata() :
data(metadata)
{}
- virtual const char *get_type_name() const {
+ const char *get_type_name() const override {
return "mon_metadata";
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(data, payload);
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(data, p);
}
}
private:
- ~MMonPaxos() {}
+ ~MMonPaxos() override {}
public:
- const char *get_type_name() const { return "paxos"; }
+ const char *get_type_name() const override { return "paxos"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "paxos(" << get_opname(op)
<< " lc " << last_committed
<< " fc " << first_committed
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
header.version = HEAD_VERSION;
::encode(epoch, payload);
::encode(op, payload);
::encode(latest_value, payload);
::encode(values, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
::decode(op, p);
has_ever_joined(hej),
required_features(0) {}
private:
- ~MMonProbe() {}
+ ~MMonProbe() override {}
public:
- const char *get_type_name() const { return "mon_probe"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "mon_probe"; }
+ void print(ostream& out) const override {
out << "mon_probe(" << get_opname(op) << " " << fsid << " name " << name;
if (quorum.size())
out << " quorum " << quorum;
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
if (monmap_bl.length() &&
((features & CEPH_FEATURE_MONENC) == 0 ||
(features & CEPH_FEATURE_MSG_ADDR2) == 0)) {
::encode(paxos_last_version, payload);
::encode(required_features, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(fsid, p);
::decode(op, p);
{ }
protected:
- ~MMonQuorumService() { }
+ ~MMonQuorumService() override { }
public:
::decode(round, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
assert(0 == "MMonQuorumService message must always be a base class");
}
- void decode_payload() {
+ void decode_payload() override {
assert(0 == "MMonQuorumService message must always be a base class");
}
- const char *get_type_name() const { return "quorum_service"; }
+ const char *get_type_name() const override { return "quorum_service"; }
};
#endif /* CEPH_MMON_QUORUM_SERVICE_H */
op(op), version(v), num_keys(num_keys)
{ }
- const char *get_type_name() const { return "mon_scrub"; }
+ const char *get_type_name() const override { return "mon_scrub"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "mon_scrub(" << get_opname((op_type_t)op);
out << " v " << version;
if (op == OP_RESULT)
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
uint8_t o = op;
::encode(o, payload);
::encode(version, payload);
::encode(key, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
uint8_t o;
::decode(o, p);
MMonSubscribe() : Message(CEPH_MSG_MON_SUBSCRIBE, HEAD_VERSION) { }
private:
- ~MMonSubscribe() {}
+ ~MMonSubscribe() override {}
public:
void sub_want(const char *w, version_t start, unsigned flags) {
what[w].flags = flags;
}
- const char *get_type_name() const { return "mon_subscribe"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "mon_subscribe"; }
+ void print(ostream& o) const override {
o << "mon_subscribe(" << what << ")";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
if (header.version < 2) {
map<string, ceph_mon_subscribe_item_old> oldwhat;
::decode(what, p);
}
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
if (features & CEPH_FEATURE_SUBSCRIBE2) {
::encode(what, payload);
header.version = HEAD_VERSION;
MMonSubscribeAck(uuid_d& f, int i) : Message(CEPH_MSG_MON_SUBSCRIBE_ACK),
interval(i), fsid(f) { }
private:
- ~MMonSubscribeAck() {}
+ ~MMonSubscribeAck() override {}
public:
- const char *get_type_name() const { return "mon_subscribe_ack"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "mon_subscribe_ack"; }
+ void print(ostream& o) const override {
o << "mon_subscribe_ack(" << interval << "s)";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(interval, p);
::decode(fsid, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(interval, payload);
::encode(fsid, payload);
}
last_committed(0)
{ }
- const char *get_type_name() const { return "mon_sync"; }
+ const char *get_type_name() const override { return "mon_sync"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "mon_sync(" << get_opname(op);
if (cookie)
out << " cookie " << cookie;
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(op, payload);
::encode(cookie, payload);
::encode(last_committed, payload);
::encode(reply_to, payload, features);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(op, p);
::decode(cookie, p);
MOSDAlive(epoch_t h, epoch_t w) : PaxosServiceMessage(MSG_OSD_ALIVE, h), want(w) { }
MOSDAlive() : PaxosServiceMessage(MSG_OSD_ALIVE, 0) {}
private:
- ~MOSDAlive() {}
+ ~MOSDAlive() override {}
public:
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(want, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(want, p);
}
- const char *get_type_name() const { return "osd_alive"; }
- void print(ostream &out) const {
+ const char *get_type_name() const override { return "osd_alive"; }
+ void print(ostream &out) const override {
out << "osd_alive(want up_thru " << want << " have " << version << ")";
}
{ }
private:
- ~MOSDBoot() { }
+ ~MOSDBoot() override { }
public:
- const char *get_type_name() const { return "osd_boot"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "osd_boot"; }
+ void print(ostream& out) const override {
out << "osd_boot(osd." << sb.whoami << " booted " << boot_epoch
<< " features " << osd_features
<< " v" << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(sb, payload);
::encode(hb_back_addr, payload, features);
::encode(metadata, payload);
::encode(osd_features, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(sb, p);
epoch_t map_epoch;
ECSubRead op;
- int get_cost() const {
+ int get_cost() const override {
return 0;
}
epoch_t get_map_epoch() const override {
: MOSDFastDispatchOp(MSG_OSD_EC_READ, HEAD_VERSION, COMPAT_VERSION)
{}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pgid, p);
::decode(map_epoch, p);
::decode(op, p);
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pgid, payload);
::encode(map_epoch, payload);
::encode(op, payload, features);
}
- const char *get_type_name() const { return "MOSDECSubOpRead"; }
+ const char *get_type_name() const override { return "MOSDECSubOpRead"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "MOSDECSubOpRead(" << pgid
<< " " << map_epoch
<< " " << op;
epoch_t map_epoch;
ECSubReadReply op;
- int get_cost() const {
+ int get_cost() const override {
return 0;
}
epoch_t get_map_epoch() const override {
: MOSDFastDispatchOp(MSG_OSD_EC_READ_REPLY, HEAD_VERSION, COMPAT_VERSION)
{}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pgid, p);
::decode(map_epoch, p);
::decode(op, p);
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pgid, payload);
::encode(map_epoch, payload);
::encode(op, payload);
}
- const char *get_type_name() const { return "MOSDECSubOpReadReply"; }
+ const char *get_type_name() const override { return "MOSDECSubOpReadReply"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "MOSDECSubOpReadReply(" << pgid
<< " " << map_epoch
<< " " << op;
epoch_t map_epoch;
ECSubWrite op;
- int get_cost() const {
+ int get_cost() const override {
return 0;
}
epoch_t get_map_epoch() const override {
op.claim(in_op);
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pgid, p);
::decode(map_epoch, p);
::decode(op, p);
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pgid, payload);
::encode(map_epoch, payload);
::encode(op, payload);
}
- const char *get_type_name() const { return "MOSDECSubOpWrite"; }
+ const char *get_type_name() const override { return "MOSDECSubOpWrite"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "MOSDECSubOpWrite(" << pgid
<< " " << map_epoch
<< " " << op;
out << ")";
}
- void clear_buffers() {
+ void clear_buffers() override {
op.t = ObjectStore::Transaction();
op.log_entries.clear();
}
epoch_t map_epoch;
ECSubWriteReply op;
- int get_cost() const {
+ int get_cost() const override {
return 0;
}
epoch_t get_map_epoch() const override {
: MOSDFastDispatchOp(MSG_OSD_EC_WRITE_REPLY, HEAD_VERSION, COMPAT_VERSION)
{}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pgid, p);
::decode(map_epoch, p);
::decode(op, p);
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pgid, payload);
::encode(map_epoch, payload);
::encode(op, payload);
}
- const char *get_type_name() const { return "MOSDECSubOpWriteReply"; }
+ const char *get_type_name() const override { return "MOSDECSubOpWriteReply"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "MOSDECSubOpWriteReply(" << pgid
<< " " << map_epoch
<< " " << op;
flags(extra_flags),
epoch(e), failed_for(duration) { }
private:
- ~MOSDFailure() {}
+ ~MOSDFailure() override {}
public:
entity_inst_t get_target() { return target_osd; }
}
epoch_t get_epoch() const { return epoch; }
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
failed_for = 0;
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(target_osd, payload, features);
::encode(failed_for, payload);
}
- const char *get_type_name() const { return "osd_failure"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "osd_failure"; }
+ void print(ostream& out) const override {
out << "osd_failure("
<< (if_osd_failed() ? "failed " : "recovered ")
<< (is_immediate() ? "immediate " : "timeout ")
fsid(f),
oldest_map(0), newest_map(0) { }
private:
- ~MOSDMap() {}
+ ~MOSDMap() override {}
public:
// marshalling
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(fsid, p);
::decode(incremental_maps, p);
newest_map = 0;
}
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
header.version = HEAD_VERSION;
::encode(fsid, payload);
if ((features & CEPH_FEATURE_PGID64) == 0 ||
}
}
- const char *get_type_name() const { return "omap"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "omap"; }
+ void print(ostream& out) const override {
out << "osd_map(" << get_first() << ".." << get_last();
if (oldest_map || newest_map)
out << " src has " << oldest_map << ".." << newest_map;
HEAD_VERSION, COMPAT_VERSION),
fsid(fs), target_osd(f), epoch(e), request_ack(request_ack) {}
private:
- ~MOSDMarkMeDown() {}
+ ~MOSDMarkMeDown() override {}
public:
entity_inst_t get_target() const { return target_osd; }
epoch_t get_epoch() const { return epoch; }
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
request_ack = true; // assume true for older clients
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(target_osd, payload, features);
::encode(request_ack, payload);
}
- const char *get_type_name() const { return "MOSDMarkMeDown"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "MOSDMarkMeDown"; }
+ void print(ostream& out) const override {
out << "MOSDMarkMeDown("
<< "request_ack=" << request_ack
<< ", target_osd=" << target_osd
reqid.inc = inc;
}
private:
- ~MOSDOp() {}
+ ~MOSDOp() override {}
public:
void set_mtime(utime_t mt) { mtime = mt; }
}
// marshalling
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
OSDOp::merge_osd_op_vector_in_data(ops, data);
}
}
- virtual void decode_payload() {
+ void decode_payload() override {
assert(partial_decode_needed && final_decode_needed);
p = payload.begin();
return true;
}
- void clear_buffers() {
+ void clear_buffers() override {
ops.clear();
}
- const char *get_type_name() const { return "osd_op"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "osd_op"; }
+ void print(ostream& out) const override {
out << "osd_op(";
if (!partial_decode_needed) {
out << get_reqid() << ' ';
}
}
private:
- ~MOSDOpReply() {}
+ ~MOSDOpReply() override {}
public:
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
OSDOp::merge_osd_op_vector_out_data(ops, data);
}
}
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
// Always keep here the newest version of decoding order/rule
}
}
- const char *get_type_name() const { return "osd_op_reply"; }
+ const char *get_type_name() const override { return "osd_op_reply"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "osd_op_reply(" << get_tid()
<< " " << oid << " " << ops
<< " v" << get_replay_version()
return pgid;
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(op, p);
::decode(map_epoch, p);
pgid.shard = shard_id_t::NO_SHARD;
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(op, payload);
::encode(map_epoch, payload);
::encode(query_epoch, payload);
pgid(p),
compat_stat_sum(false) {}
private:
- ~MOSDPGBackfill() {}
+ ~MOSDPGBackfill() override {}
public:
- const char *get_type_name() const { return "pg_backfill"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "pg_backfill"; }
+ void print(ostream& out) const override {
out << "pg_backfill(" << get_op_name(op)
<< " " << pgid
<< " e " << map_epoch << "/" << query_epoch
: Message(MSG_OSD_PG_CREATE, HEAD_VERSION, COMPAT_VERSION),
epoch(e) { }
private:
- ~MOSDPGCreate() {}
+ ~MOSDPGCreate() override {}
public:
- const char *get_type_name() const { return "pg_create"; }
+ const char *get_type_name() const override { return "pg_create"; }
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(epoch, payload);
::encode(mkpg, payload);
::encode(ctimes, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
if (header.version >= 2) {
}
}
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "osd_pg_create(e" << epoch;
for (map<pg_t,pg_create_t>::const_iterator i = mkpg.begin();
i != mkpg.end();
set_priority(CEPH_MSG_PRIO_HIGH);
}
private:
- ~MOSDPGInfo() {}
+ ~MOSDPGInfo() override {}
public:
- const char *get_type_name() const { return "pg_info"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "pg_info"; }
+ void print(ostream& out) const override {
out << "pg_info(" << pg_list.size() << " pgs e" << epoch << ":";
for (vector<pair<pg_notify_t,pg_interval_map_t> >::const_iterator i = pg_list.begin();
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(epoch, payload);
// v1 was vector<pg_info_t>
::encode(p->first.to, payload);
}
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
}
private:
- ~MOSDPGLog() {}
+ ~MOSDPGLog() override {}
public:
- const char *get_type_name() const { return "PGlog"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "PGlog"; }
+ void print(ostream& out) const override {
// NOTE: log is not const, but operator<< doesn't touch fields
// swapped out by OSD code.
out << "pg_log(" << info.pgid << " epoch " << epoch
<< " query_epoch " << query_epoch << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(epoch, payload);
::encode(info, payload);
::encode(log, payload);
::encode(to, payload);
::encode(from, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
::decode(info, p);
set_priority(CEPH_MSG_PRIO_HIGH);
}
private:
- ~MOSDPGNotify() {}
+ ~MOSDPGNotify() override {}
public:
- const char *get_type_name() const { return "PGnot"; }
+ const char *get_type_name() const override { return "PGnot"; }
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
// Use query_epoch for first entry for backwards compatibility
epoch_t query_epoch = epoch;
if (pg_list.size())
::encode(p->first.to, payload);
}
}
- void decode_payload() {
+ void decode_payload() override {
epoch_t query_epoch;
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
}
}
}
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "pg_notify(";
for (vector<pair<pg_notify_t,pg_interval_map_t> >::const_iterator i = pg_list.begin();
i != pg_list.end();
}
}
- int get_cost() const {
+ int get_cost() const override {
return cost;
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pgid.pgid, p);
::decode(map_epoch, p);
}
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pgid.pgid, payload);
::encode(map_epoch, payload);
::encode(pulls, payload, features);
::encode(from, payload);
}
- const char *get_type_name() const { return "MOSDPGPull"; }
+ const char *get_type_name() const override { return "MOSDPGPull"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "MOSDPGPull(" << pgid
<< " e" << map_epoch
<< " cost " << cost
}
}
- int get_cost() const {
+ int get_cost() const override {
return cost;
}
cost(0)
{}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pgid.pgid, p);
::decode(map_epoch, p);
}
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pgid.pgid, payload);
::encode(map_epoch, payload);
::encode(pushes, payload, features);
::encode(from, payload);
}
- const char *get_type_name() const { return "MOSDPGPush"; }
+ const char *get_type_name() const override { return "MOSDPGPush"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "MOSDPGPush(" << pgid
<< " " << map_epoch
<< " " << pushes;
}
}
- int get_cost() const {
+ int get_cost() const override {
return cost;
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pgid.pgid, p);
::decode(map_epoch, p);
}
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pgid.pgid, payload);
::encode(map_epoch, payload);
::encode(replies, payload);
::encode(from, payload);
}
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "MOSDPGPushReply(" << pgid
<< " " << map_epoch
<< " " << replies;
out << ")";
}
- const char *get_type_name() const { return "MOSDPGPushReply"; }
+ const char *get_type_name() const override { return "MOSDPGPushReply"; }
};
#endif
set_priority(CEPH_MSG_PRIO_HIGH);
}
private:
- ~MOSDPGQuery() {}
+ ~MOSDPGQuery() override {}
public:
- const char *get_type_name() const { return "pg_query"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "pg_query"; }
+ void print(ostream& out) const override {
out << "pg_query(";
for (map<spg_t,pg_query_t>::const_iterator p = pg_list.begin();
p != pg_list.end(); ++p) {
out << " epoch " << epoch << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(epoch, payload);
vector<pair<pg_t, pg_query_t> > _pg_list;
_pg_list.reserve(pg_list.size());
::encode(_pg_list, payload, features);
::encode(_shard_list, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
vector<pair<pg_t, pg_query_t> > _pg_list;
pg_list.swap(l);
}
private:
- ~MOSDPGRemove() {}
+ ~MOSDPGRemove() override {}
public:
- const char *get_type_name() const { return "PGrm"; }
+ const char *get_type_name() const override { return "PGrm"; }
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(epoch, payload);
vector<pg_t> _pg_list;
::encode(_pg_list, payload);
::encode(_shard_list, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
vector<pg_t> _pg_list;
pg_list.push_back(spg_t(_pg_list[i], _shard_list[i]));
}
}
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "osd pg remove(" << "epoch " << epoch << "; ";
for (vector<spg_t>::const_iterator i = pg_list.begin();
i != pg_list.end();
return pgid;
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(op, p);
::decode(map_epoch, p);
}
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(op, payload);
::encode(map_epoch, payload);
::encode(query_epoch, payload);
begin(be), end(en) {
}
private:
- ~MOSDPGScan() {}
+ ~MOSDPGScan() override {}
public:
- const char *get_type_name() const { return "pg_scan"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "pg_scan"; }
+ void print(ostream& out) const override {
out << "pg_scan(" << get_op_name(op)
<< " " << pgid
<< " " << begin << "-" << end
MOSDPGTemp(epoch_t e) : PaxosServiceMessage(MSG_OSD_PGTEMP, e), map_epoch(e) { }
MOSDPGTemp() : PaxosServiceMessage(MSG_OSD_PGTEMP, 0) {}
private:
- ~MOSDPGTemp() {}
+ ~MOSDPGTemp() override {}
public:
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(map_epoch, payload);
::encode(pg_temp, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(map_epoch, p);
::decode(pg_temp, p);
}
- const char *get_type_name() const { return "osd_pgtemp"; }
- void print(ostream &out) const {
+ const char *get_type_name() const override { return "osd_pgtemp"; }
+ void print(ostream &out) const override {
out << "osd_pgtemp(e" << map_epoch << " " << pg_temp << " v" << version << ")";
}
Message(MSG_OSD_PG_TRIM, HEAD_VERSION, COMPAT_VERSION),
epoch(mv), pgid(p), trim_to(tt) { }
private:
- ~MOSDPGTrim() {}
+ ~MOSDPGTrim() override {}
public:
- const char *get_type_name() const { return "pg_trim"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "pg_trim"; }
+ void print(ostream& out) const override {
out << "pg_trim(" << pgid << " to " << trim_to << " e" << epoch << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(epoch, payload);
::encode(pgid.pgid, payload);
::encode(trim_to, payload);
::encode(pgid.shard, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(epoch, p);
::decode(pgid.pgid, p);
entries(entries) {}
private:
- ~MOSDPGUpdateLogMissing() {}
+ ~MOSDPGUpdateLogMissing() override {}
public:
- const char *get_type_name() const { return "PGUpdateLogMissing"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "PGUpdateLogMissing"; }
+ void print(ostream& out) const override {
out << "pg_update_log_missing(" << pgid << " epoch " << map_epoch
<< " rep_tid " << rep_tid
<< " entries " << entries << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(map_epoch, payload);
::encode(pgid, payload);
::encode(from, payload);
::encode(rep_tid, payload);
::encode(entries, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(map_epoch, p);
::decode(pgid, p);
{}
private:
- ~MOSDPGUpdateLogMissingReply() {}
+ ~MOSDPGUpdateLogMissingReply() override {}
public:
- const char *get_type_name() const { return "PGUpdateLogMissingReply"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "PGUpdateLogMissingReply"; }
+ void print(ostream& out) const override {
out << "pg_update_log_missing_reply(" << pgid << " epoch " << map_epoch
<< " rep_tid " << rep_tid << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(map_epoch, payload);
::encode(pgid, payload);
::encode(from, payload);
::encode(rep_tid, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(map_epoch, p);
::decode(pgid, p);
: Message(MSG_OSD_PING, HEAD_VERSION, COMPAT_VERSION)
{}
private:
- ~MOSDPing() {}
+ ~MOSDPing() override {}
public:
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(fsid, p);
::decode(map_epoch, p);
if (header.version >= 2)
::decode(stamp, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(fsid, payload);
::encode(map_epoch, payload);
::encode(peer_as_of_epoch, payload);
::encode(stamp, payload);
}
- const char *get_type_name() const { return "osd_ping"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "osd_ping"; }
+ void print(ostream& out) const override {
out << "osd_ping(" << get_op_name(op)
<< " e" << map_epoch
//<< " as_of " << peer_as_of_epoch
return pgid;
}
- int get_cost() const {
+ int get_cost() const override {
return data.length();
}
- virtual void decode_payload() {
+ void decode_payload() override {
p = payload.begin();
// splitted to partial and final
::decode(map_epoch, p);
final_decode_needed = false;
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(map_epoch, payload);
::encode(reqid, payload);
::encode(pgid, payload);
set_tid(rtid);
}
private:
- ~MOSDRepOp() {}
+ ~MOSDRepOp() override {}
public:
- const char *get_type_name() const { return "osd_repop"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "osd_repop"; }
+ void print(ostream& out) const override {
out << "osd_repop(" << reqid
<< " " << pgid;
if (!final_decode_needed) {
return pgid;
}
- virtual void decode_payload() {
+ void decode_payload() override {
p = payload.begin();
::decode(map_epoch, p);
::decode(reqid, p);
::decode(from, p);
final_decode_needed = false;
}
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(map_epoch, payload);
::encode(reqid, payload);
::encode(pgid, payload);
ack_type(0), result(0),
final_decode_needed(true) {}
private:
- ~MOSDRepOpReply() {}
+ ~MOSDRepOpReply() override {}
public:
- const char *get_type_name() const { return "osd_repop_reply"; }
+ const char *get_type_name() const override { return "osd_repop_reply"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "osd_repop_reply(" << reqid
<< " " << pgid;
if (!final_decode_needed) {
private:
- ~MOSDRepScrub() {}
+ ~MOSDRepScrub() override {}
public:
- const char *get_type_name() const { return "replica scrub"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "replica scrub"; }
+ void print(ostream& out) const override {
out << "replica scrub(pg: ";
out << pgid << ",from:" << scrub_from << ",to:" << scrub_to
<< ",epoch:" << map_epoch << ",start:" << start << ",end:" << end
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pgid.pgid, payload);
::encode(scrub_from, payload);
::encode(scrub_to, payload);
::encode(pgid.shard, payload);
::encode(seed, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pgid.pgid, p);
::decode(scrub_from, p);
Message(MSG_OSD_SCRUB, HEAD_VERSION, COMPAT_VERSION),
fsid(f), scrub_pgs(pgs), repair(r), deep(d) {}
private:
- ~MOSDScrub() {}
+ ~MOSDScrub() override {}
public:
- const char *get_type_name() const { return "scrub"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "scrub"; }
+ void print(ostream& out) const override {
out << "scrub(";
if (scrub_pgs.empty())
out << "osd";
out << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(fsid, payload);
::encode(scrub_pgs, payload);
::encode(repair, payload);
::encode(deep, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(fsid, p);
::decode(scrub_pgs, p);
return pgid;
}
- int get_cost() const {
+ int get_cost() const override {
if (ops.size() == 1 && ops[0].op.op == CEPH_OSD_OP_PULL)
return ops[0].op.extent.length;
return data.length();
}
- virtual void decode_payload() {
+ void decode_payload() override {
//since we drop incorrect_pools flag, now we only support
//version >=7
assert (header.version >= 7);
void finish_decode() { }
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
header.version = HEAD_VERSION;
::encode(map_epoch, payload);
::encode(reqid, payload);
set_tid(rtid);
}
private:
- ~MOSDSubOp() {}
+ ~MOSDSubOp() override {}
public:
- const char *get_type_name() const { return "osd_sub_op"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "osd_sub_op"; }
+ void print(ostream& out) const override {
out << "osd_sub_op(" << reqid
<< " " << pgid
<< " " << poid
return pgid;
}
- virtual void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(map_epoch, p);
::decode(reqid, p);
void finish_decode() { }
- virtual void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(map_epoch, payload);
::encode(reqid, payload);
::encode(pgid.pgid, payload);
MOSDSubOpReply()
: MOSDFastDispatchOp(MSG_OSD_SUBOPREPLY, HEAD_VERSION, COMPAT_VERSION) {}
private:
- ~MOSDSubOpReply() {}
+ ~MOSDSubOpReply() override {}
public:
- const char *get_type_name() const { return "osd_subop_reply"; }
+ const char *get_type_name() const override { return "osd_subop_reply"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "osd_sub_op_reply(" << reqid
<< " " << pgid
<< " " << poid << " " << ops;
{}
private:
- ~MPGStats() {}
+ ~MPGStats() override {}
public:
- const char *get_type_name() const { return "pg_stats"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "pg_stats"; }
+ void print(ostream& out) const override {
out << "pg_stats(" << pg_stat.size() << " pgs tid " << get_tid() << " v " << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(osd_stat, payload);
::encode(epoch, payload);
::encode(had_map_for, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
MPGStatsAck() : Message(MSG_PGSTATSACK) {}
private:
- ~MPGStatsAck() {}
+ ~MPGStatsAck() override {}
public:
- const char *get_type_name() const { return "pg_stats_ack"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "pg_stats_ack"; }
+ void print(ostream& out) const override {
out << "pg_stats_ack(" << pg_stat.size() << " pgs tid " << get_tid() << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pg_stat, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pg_stat, p);
}
public:
MPing() : Message(CEPH_MSG_PING) {}
private:
- ~MPing() {}
+ ~MPing() override {}
public:
- void decode_payload() { }
- void encode_payload(uint64_t features) { }
- const char *get_type_name() const { return "ping"; }
+ void decode_payload() override { }
+ void encode_payload(uint64_t features) override { }
+ const char *get_type_name() const override { return "ping"; }
};
#endif
}
private:
- ~MPoolOp() {}
+ ~MPoolOp() override {}
public:
- const char *get_type_name() const { return "poolop"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "poolop"; }
+ void print(ostream& out) const override {
out << "pool_op(" << ceph_pool_op_name(op) << " pool " << pool
<< " auid " << auid
<< " tid " << get_tid()
<< " v" << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(pool, payload);
::encode(pad, payload); /* for v3->v4 encoding change */
::encode(crush_rule, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
response_data.claim(*blp);
}
- const char *get_type_name() const { return "poolopreply"; }
+ const char *get_type_name() const override { return "poolopreply"; }
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "pool_op_reply(tid " << get_tid()
<< " " << cpp_strerror(-replyCode)
<< " v" << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
::encode(replyCode, payload);
} else
::encode(false, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
pgid(pgid), query_epoch(query_epoch),
type(type) {}
- const char *get_type_name() const {
+ const char *get_type_name() const override {
return "MRecoveryReserve";
}
- void print(ostream& out) const {
+ void print(ostream& out) const override {
out << "MRecoveryReserve ";
switch (type) {
case REQUEST:
return;
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(pgid.pgid, p);
::decode(query_epoch, p);
pgid.shard = shard_id_t::NO_SHARD;
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(pgid.pgid, payload);
::encode(query_epoch, payload);
::encode(type, payload);
snaps.swap(s);
}
private:
- ~MRemoveSnaps() {}
+ ~MRemoveSnaps() override {}
public:
- const char *get_type_name() const { return "remove_snaps"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "remove_snaps"; }
+ void print(ostream& out) const override {
out << "remove_snaps(" << snaps << " v" << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(snaps, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(snaps, p);
msg = decode_message(NULL, 0, p);
}
private:
- ~MRoute() {
+ ~MRoute() override {
if (msg)
msg->put();
}
public:
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(session_mon_tid, p);
::decode(dest, p);
::decode(send_osdmap_first, p);
}
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(session_mon_tid, payload);
::encode(dest, payload, features);
bool m = msg ? true : false;
::encode(send_osdmap_first, payload);
}
- const char *get_type_name() const { return "route"; }
- void print(ostream& o) const {
+ const char *get_type_name() const override { return "route"; }
+ void print(ostream& o) const override {
if (msg)
o << "route(" << *msg;
else
}
private:
- ~MStatfs() {}
+ ~MStatfs() override {}
public:
- const char *get_type_name() const { return "statfs"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "statfs"; }
+ void print(ostream& out) const override {
out << "statfs(" << get_tid() << " v" << version << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
paxos_encode();
::encode(fsid, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
paxos_decode(p);
::decode(fsid, p);
h.version = epoch;
}
- const char *get_type_name() const { return "statfs_reply"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "statfs_reply"; }
+ void print(ostream& out) const override {
out << "statfs_reply(" << header.tid << ")";
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(h, payload);
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(h, p);
}
{ }
private:
- ~MTimeCheck() { }
+ ~MTimeCheck() override { }
public:
- const char *get_type_name() const { return "time_check"; }
+ const char *get_type_name() const override { return "time_check"; }
const char *get_op_name() const {
switch (op) {
case OP_PING: return "ping";
}
return "???";
}
- void print(ostream &o) const {
+ void print(ostream &o) const override {
o << "time_check( " << get_op_name()
<< " e " << epoch << " r " << round;
if (op == OP_PONG) {
o << " )";
}
- void decode_payload() {
+ void decode_payload() override {
bufferlist::iterator p = payload.begin();
::decode(op, p);
::decode(epoch, p);
::decode(latencies, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
::encode(op, payload);
::encode(epoch, payload);
::encode(round, payload);
return_code(0),
notifier_gid(0) { }
private:
- ~MWatchNotify() {}
+ ~MWatchNotify() override {}
public:
- void decode_payload() {
+ void decode_payload() override {
uint8_t msg_ver;
bufferlist::iterator p = payload.begin();
::decode(msg_ver, p);
else
notifier_gid = 0;
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
uint8_t msg_ver = 1;
::encode(msg_ver, payload);
::encode(opcode, payload);
::encode(notifier_gid, payload);
}
- const char *get_type_name() const { return "watch-notify"; }
- void print(ostream& out) const {
+ const char *get_type_name() const override { return "watch-notify"; }
+ void print(ostream& out) const override {
out << "watch-notify("
<< ceph_watch_event_name(opcode) << " (" << (int)opcode << ")"
<< " cookie " << cookie
version(v), deprecated_session_mon(-1), deprecated_session_mon_tid(0),
rx_election_epoch(0) { }
protected:
- ~PaxosServiceMessage() {}
+ ~PaxosServiceMessage() override {}
public:
void paxos_encode() {
::decode(deprecated_session_mon_tid, p);
}
- void encode_payload(uint64_t features) {
+ void encode_payload(uint64_t features) override {
ceph_abort();
paxos_encode();
}
- void decode_payload() {
+ void decode_payload() override {
ceph_abort();
bufferlist::iterator p = payload.begin();
paxos_decode(p);
return session;
}
- const char *get_type_name() const { return "PaxosServiceMessage"; }
+ const char *get_type_name() const override { return "PaxosServiceMessage"; }
};
#endif
rx_buffers_version(0) {
}
- virtual ~Connection() {
+ ~Connection() override {
//generic_dout(0) << "~Connection " << this << dendl;
if (priv) {
//generic_dout(0) << "~Connection " << this << " dropping priv " << priv << dendl;
DispatchQueue *dq;
public:
explicit DispatchThread(DispatchQueue *dq) : dq(dq) {}
- void *entry() {
+ void *entry() override {
dq->entry();
return 0;
}
DispatchQueue *dq;
public:
explicit LocalDeliveryThread(DispatchQueue *dq) : dq(dq) {}
- void *entry() {
+ void *entry() override {
dq->run_local_delivery();
return 0;
}
}
protected:
- virtual ~Message() {
+ ~Message() override {
if (byte_throttler)
byte_throttler->put(payload.length() + middle.length() + data.length());
release_message_throttle();
*
* @return A const Policy reference.
*/
- virtual Policy get_policy(int t) {
+ Policy get_policy(int t) override {
Mutex::Locker l(policy_lock);
map<int, Policy>::iterator iter =
policy_map.find(t);
return default_policy;
}
- virtual Policy get_default_policy() {
+ Policy get_default_policy() override {
Mutex::Locker l(policy_lock);
return default_policy;
}
*
* @param p The Policy to apply.
*/
- virtual void set_default_policy(Policy p) {
+ void set_default_policy(Policy p) override {
Mutex::Locker l(policy_lock);
default_policy = p;
}
* @param type The peer type this policy applies to.
* @param p The policy to apply.
*/
- virtual void set_policy(int type, Policy p) {
+ void set_policy(int type, Policy p) override {
Mutex::Locker l(policy_lock);
policy_map[type] = p;
}
*/
void set_policy_throttlers(int type,
Throttle *byte_throttle,
- Throttle *msg_throttle) {
+ Throttle *msg_throttle) override {
Mutex::Locker l(policy_lock);
map<int, Policy>::iterator iter =
policy_map.find(type);
DispatchQueue *q, uint64_t cid)
: msgr(omsgr), center(c), dispatch_queue(q), conn_id(cid),
stop_dispatch(false) { }
- ~DelayedDelivery() {
+ ~DelayedDelivery() override {
assert(register_time_events.empty());
assert(delay_queue.empty());
}
public:
AsyncConnection(CephContext *cct, AsyncMessenger *m, DispatchQueue *q, Worker *w);
- ~AsyncConnection();
+ ~AsyncConnection() override;
void maybe_start_delay_thread();
ostream& _conn_prefix(std::ostream *_dout);
* Destroy the AsyncMessenger. Pretty simple since all the work is done
* elsewhere.
*/
- virtual ~AsyncMessenger();
+ ~AsyncMessenger() override;
/** @defgroup Accessors
* @{
*/
void set_addr_unknowns(const entity_addr_t &addr) override;
- int get_dispatch_queue_len() {
+ int get_dispatch_queue_len() override {
return dispatch_queue.get_queue_len();
}
- double get_dispatch_queue_max_age(utime_t now) {
+ double get_dispatch_queue_max_age(utime_t now) override {
return dispatch_queue.get_max_age(now);
}
/** @} Accessors */
* @defgroup Configuration functions
* @{
*/
- void set_cluster_protocol(int p) {
+ void set_cluster_protocol(int p) override {
assert(!started && !did_bind);
cluster_protocol = p;
}
- int bind(const entity_addr_t& bind_addr);
- int rebind(const set<int>& avoid_ports);
- int client_bind(const entity_addr_t& bind_addr);
+ int bind(const entity_addr_t& bind_addr) override;
+ int rebind(const set<int>& avoid_ports) override;
+ int client_bind(const entity_addr_t& bind_addr) override;
/** @} Configuration functions */
*/
ConnectionRef get_connection(const entity_inst_t& dest) override;
ConnectionRef get_loopback_connection() override;
- virtual void mark_down(const entity_addr_t& addr) override;
- virtual void mark_down_all() override {
+ void mark_down(const entity_addr_t& addr) override;
+ void mark_down_all() override {
shutdown_connections(true);
}
/** @} // Connection Management */
public:
C_submit_event(func &&_f, bool nw)
: f(std::move(_f)), nonwait(nw) {}
- void do_request(int id) {
+ void do_request(int id) override {
f();
lock.lock();
cond.notify_all();
public:
explicit EpollDriver(CephContext *c): epfd(-1), events(NULL), cct(c), size(0) {}
- virtual ~EpollDriver() {
+ ~EpollDriver() override {
if (epfd != -1)
close(epfd);
public:
explicit SelectDriver(CephContext *c): max_fd(0), cct(c) {}
- virtual ~SelectDriver() {}
+ ~SelectDriver() override {}
int init(EventCenter *c, int nevent) override;
int add_event(int fd, int cur_mask, int add_mask) override;
class PosixWorker : public Worker {
NetHandler net;
- virtual void initialize();
+ void initialize() override;
public:
PosixWorker(CephContext *c, unsigned i)
: Worker(c, i), net(c) {}
- virtual int listen(entity_addr_t &sa, const SocketOptions &opt,
+ int listen(entity_addr_t &sa, const SocketOptions &opt,
ServerSocket *socks) override;
- virtual int connect(const entity_addr_t &addr, const SocketOptions &opts, ConnectedSocket *socket) override;
+ int connect(const entity_addr_t &addr, const SocketOptions &opts, ConnectedSocket *socket) override;
};
class PosixNetworkStack : public NetworkStack {
return -1;
return coreids[id % coreids.size()];
}
- virtual void spawn_worker(unsigned i, std::function<void ()> &&func) override {
+ void spawn_worker(unsigned i, std::function<void ()> &&func) override {
threads.resize(i+1);
threads[i] = std::thread(func);
}
- virtual void join_worker(unsigned i) override {
+ void join_worker(unsigned i) override {
assert(threads.size() > i && threads[i].joinable());
threads[i].join();
}
public:
NetworkStack(const NetworkStack &) = delete;
NetworkStack& operator=(const NetworkStack &) = delete;
- virtual ~NetworkStack() {
+ ~NetworkStack() override {
for (auto &&w : workers)
delete w;
}
virtual void spawn_worker(unsigned i, std::function<void ()> &&) = 0;
virtual void join_worker(unsigned i) = 0;
- virtual void handle_pre_fork() override {
+ void handle_pre_fork() override {
stop();
}
- virtual void handle_post_fork() override {
+ void handle_post_fork() override {
start();
}
stop_delayed_delivery(false),
delay_dispatching(false),
stop_fast_dispatching_flag(false) { }
- ~DelayedDelivery() {
+ ~DelayedDelivery() override {
discard();
}
void *entry() override;
Pipe *pipe;
public:
explicit Reader(Pipe *p) : pipe(p) {}
- void *entry() { pipe->reader(); return 0; }
+ void *entry() override { pipe->reader(); return 0; }
} reader_thread;
/**
Pipe *pipe;
public:
explicit Writer(Pipe *p) : pipe(p) {}
- void *entry() { pipe->writer(); return 0; }
+ void *entry() override { pipe->writer(); return 0; }
} writer_thread;
class DelayedDelivery;
DelayedDelivery *delay_thread;
public:
Pipe(SimpleMessenger *r, int st, PipeConnection *con);
- ~Pipe();
+ ~Pipe() override;
SimpleMessenger *msgr;
uint64_t conn_id;
: Connection(cct, m),
pipe(NULL) { }
- ~PipeConnection();
+ ~PipeConnection() override;
Pipe* get_pipe();
* Destroy the SimpleMessenger. Pretty simple since all the work is done
* elsewhere.
*/
- virtual ~SimpleMessenger();
+ ~SimpleMessenger() override;
/** @defgroup Accessors
* @{
*/
void set_addr_unknowns(const entity_addr_t& addr) override;
- int get_dispatch_queue_len() {
+ int get_dispatch_queue_len() override {
return dispatch_queue.get_queue_len();
}
- double get_dispatch_queue_max_age(utime_t now) {
+ double get_dispatch_queue_max_age(utime_t now) override {
return dispatch_queue.get_max_age(now);
}
/** @} Accessors */
* @defgroup Configuration functions
* @{
*/
- void set_cluster_protocol(int p) {
+ void set_cluster_protocol(int p) override {
assert(!started && !did_bind);
cluster_protocol = p;
}
- int bind(const entity_addr_t& bind_addr);
- int rebind(const set<int>& avoid_ports);
- int client_bind(const entity_addr_t& bind_addr);
+ int bind(const entity_addr_t& bind_addr) override;
+ int rebind(const set<int>& avoid_ports) override;
+ int client_bind(const entity_addr_t& bind_addr) override;
/** @} Configuration functions */
* @defgroup Startup/Shutdown
* @{
*/
- virtual int start();
- virtual void wait();
- virtual int shutdown();
+ int start() override;
+ void wait() override;
+ int shutdown() override;
/** @} // Startup/Shutdown */
* @defgroup Messaging
* @{
*/
- virtual int send_message(Message *m, const entity_inst_t& dest) {
+ int send_message(Message *m, const entity_inst_t& dest) override {
return _send_message(m, dest);
}
* @defgroup Connection Management
* @{
*/
- virtual ConnectionRef get_connection(const entity_inst_t& dest);
- virtual ConnectionRef get_loopback_connection();
+ ConnectionRef get_connection(const entity_inst_t& dest) override;
+ ConnectionRef get_loopback_connection() override;
int send_keepalive(Connection *con);
- virtual void mark_down(const entity_addr_t& addr);
+ void mark_down(const entity_addr_t& addr) override;
void mark_down(Connection *con);
void mark_disposable(Connection *con);
- virtual void mark_down_all();
+ void mark_down_all() override;
/** @} // Connection Management */
protected:
/**
/**
* Start up the DispatchQueue thread once we have somebody to dispatch to.
*/
- virtual void ready();
+ void ready() override;
/** @} // Messenger Interfaces */
private:
/**
SimpleMessenger *msgr;
public:
explicit ReaperThread(SimpleMessenger *m) : msgr(m) {}
- void *entry() {
+ void *entry() override {
msgr->reaper_entry();
return 0;
}