summaryrefslogtreecommitdiffstats
path: root/src/messages
diff options
context:
space:
mode:
authorSage Weil <sage.weil@dreamhost.com>2012-01-30 21:03:12 +0100
committerSage Weil <sage.weil@dreamhost.com>2012-01-30 21:03:12 +0100
commit11f6a840be56253beef6fbee326a95bcbf62f5c2 (patch)
tree51d531bac35eccbfa75e3953f01c90ca084ee96b /src/messages
parentmdsmap: move member initialization to monitor create_initial() (diff)
downloadceph-11f6a840be56253beef6fbee326a95bcbf62f5c2.tar.xz
ceph-11f6a840be56253beef6fbee326a95bcbf62f5c2.zip
msg: no cct needed for message encoding
Signed-off-by: Sage Weil <sage.weil@dreamhost.com>
Diffstat (limited to 'src/messages')
-rw-r--r--src/messages/MAuth.h2
-rw-r--r--src/messages/MAuthReply.h2
-rw-r--r--src/messages/MCacheExpire.h2
-rw-r--r--src/messages/MClientCapRelease.h2
-rw-r--r--src/messages/MClientCaps.h2
-rw-r--r--src/messages/MClientLease.h2
-rw-r--r--src/messages/MClientReconnect.h2
-rw-r--r--src/messages/MClientReply.h2
-rw-r--r--src/messages/MClientRequest.h2
-rw-r--r--src/messages/MClientRequestForward.h2
-rw-r--r--src/messages/MClientSession.h2
-rw-r--r--src/messages/MClientSnap.h2
-rw-r--r--src/messages/MCommand.h2
-rw-r--r--src/messages/MCommandReply.h2
-rw-r--r--src/messages/MDentryLink.h2
-rw-r--r--src/messages/MDentryUnlink.h2
-rw-r--r--src/messages/MDirUpdate.h2
-rw-r--r--src/messages/MDiscover.h2
-rw-r--r--src/messages/MDiscoverReply.h2
-rw-r--r--src/messages/MExportCaps.h2
-rw-r--r--src/messages/MExportCapsAck.h2
-rw-r--r--src/messages/MExportDir.h2
-rw-r--r--src/messages/MExportDirAck.h2
-rw-r--r--src/messages/MExportDirCancel.h2
-rw-r--r--src/messages/MExportDirDiscover.h2
-rw-r--r--src/messages/MExportDirDiscoverAck.h2
-rw-r--r--src/messages/MExportDirFinish.h2
-rw-r--r--src/messages/MExportDirNotify.h2
-rw-r--r--src/messages/MExportDirNotifyAck.h2
-rw-r--r--src/messages/MExportDirPrep.h2
-rw-r--r--src/messages/MExportDirPrepAck.h2
-rw-r--r--src/messages/MForward.h4
-rw-r--r--src/messages/MGenericMessage.h2
-rw-r--r--src/messages/MGetPoolStats.h2
-rw-r--r--src/messages/MGetPoolStatsReply.h2
-rw-r--r--src/messages/MHeartbeat.h2
-rw-r--r--src/messages/MInodeFileCaps.h2
-rw-r--r--src/messages/MLock.h2
-rw-r--r--src/messages/MLog.h2
-rw-r--r--src/messages/MLogAck.h2
-rw-r--r--src/messages/MMDSBeacon.h2
-rw-r--r--src/messages/MMDSCacheRejoin.h2
-rw-r--r--src/messages/MMDSFindIno.h2
-rw-r--r--src/messages/MMDSFindInoReply.h2
-rw-r--r--src/messages/MMDSFragmentNotify.h2
-rw-r--r--src/messages/MMDSLoadTargets.h2
-rw-r--r--src/messages/MMDSMap.h2
-rw-r--r--src/messages/MMDSResolve.h2
-rw-r--r--src/messages/MMDSResolveAck.h2
-rw-r--r--src/messages/MMDSSlaveRequest.h2
-rw-r--r--src/messages/MMDSTableRequest.h2
-rw-r--r--src/messages/MMonCommand.h2
-rw-r--r--src/messages/MMonCommandAck.h2
-rw-r--r--src/messages/MMonElection.h2
-rw-r--r--src/messages/MMonGetMap.h2
-rw-r--r--src/messages/MMonGetVersion.h2
-rw-r--r--src/messages/MMonGetVersionReply.h2
-rw-r--r--src/messages/MMonGlobalID.h2
-rw-r--r--src/messages/MMonJoin.h2
-rw-r--r--src/messages/MMonMap.h2
-rw-r--r--src/messages/MMonObserve.h2
-rw-r--r--src/messages/MMonObserveNotify.h2
-rw-r--r--src/messages/MMonPaxos.h2
-rw-r--r--src/messages/MMonProbe.h2
-rw-r--r--src/messages/MMonSubscribe.h2
-rw-r--r--src/messages/MMonSubscribeAck.h2
-rw-r--r--src/messages/MOSDAlive.h2
-rw-r--r--src/messages/MOSDBoot.h2
-rw-r--r--src/messages/MOSDFailure.h2
-rw-r--r--src/messages/MOSDMap.h2
-rw-r--r--src/messages/MOSDOp.h2
-rw-r--r--src/messages/MOSDOpReply.h2
-rw-r--r--src/messages/MOSDPGBackfill.h2
-rw-r--r--src/messages/MOSDPGCreate.h2
-rw-r--r--src/messages/MOSDPGInfo.h2
-rw-r--r--src/messages/MOSDPGLog.h2
-rw-r--r--src/messages/MOSDPGMissing.h2
-rw-r--r--src/messages/MOSDPGNotify.h2
-rw-r--r--src/messages/MOSDPGQuery.h2
-rw-r--r--src/messages/MOSDPGRemove.h2
-rw-r--r--src/messages/MOSDPGScan.h2
-rw-r--r--src/messages/MOSDPGTemp.h2
-rw-r--r--src/messages/MOSDPGTrim.h2
-rw-r--r--src/messages/MOSDPing.h2
-rw-r--r--src/messages/MOSDRepScrub.h2
-rw-r--r--src/messages/MOSDScrub.h2
-rw-r--r--src/messages/MOSDSubOp.h2
-rw-r--r--src/messages/MOSDSubOpReply.h2
-rw-r--r--src/messages/MPGStats.h2
-rw-r--r--src/messages/MPGStatsAck.h2
-rw-r--r--src/messages/MPing.h2
-rw-r--r--src/messages/MPoolOp.h2
-rw-r--r--src/messages/MPoolOpReply.h2
-rw-r--r--src/messages/MRemoveSnaps.h2
-rw-r--r--src/messages/MRoute.h4
-rw-r--r--src/messages/MStatfs.h2
-rw-r--r--src/messages/MStatfsReply.h2
-rw-r--r--src/messages/MWatchNotify.h2
-rw-r--r--src/messages/PaxosServiceMessage.h2
99 files changed, 101 insertions, 101 deletions
diff --git a/src/messages/MAuth.h b/src/messages/MAuth.h
index 7fc0e59036c..f76ee49fdea 100644
--- a/src/messages/MAuth.h
+++ b/src/messages/MAuth.h
@@ -45,7 +45,7 @@ public:
else
monmap_epoch = 0;
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(protocol, payload);
::encode(auth_payload, payload);
diff --git a/src/messages/MAuthReply.h b/src/messages/MAuthReply.h
index 7a219a3cb23..eaa1524abc8 100644
--- a/src/messages/MAuthReply.h
+++ b/src/messages/MAuthReply.h
@@ -53,7 +53,7 @@ public:
::decode(result_bl, p);
::decode(result_msg, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(protocol, payload);
::encode(result, payload);
::encode(global_id, payload);
diff --git a/src/messages/MCacheExpire.h b/src/messages/MCacheExpire.h
index e562a83069a..42fade885f3 100644
--- a/src/messages/MCacheExpire.h
+++ b/src/messages/MCacheExpire.h
@@ -75,7 +75,7 @@ public:
::decode(realms, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(from, payload);
::encode(realms, payload);
}
diff --git a/src/messages/MClientCapRelease.h b/src/messages/MClientCapRelease.h
index a25b4afb5bc..2015c66b351 100644
--- a/src/messages/MClientCapRelease.h
+++ b/src/messages/MClientCapRelease.h
@@ -41,7 +41,7 @@ public:
::decode(head, p);
::decode_nohead(head.num, caps, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
head.num = caps.size();
::encode(head, payload);
::encode_nohead(caps, payload);
diff --git a/src/messages/MClientCaps.h b/src/messages/MClientCaps.h
index ac3df11e047..d261692ae63 100644
--- a/src/messages/MClientCaps.h
+++ b/src/messages/MClientCaps.h
@@ -147,7 +147,7 @@ public:
if (header.version >= 2)
::decode(flockbl, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
head.snap_trace_len = snapbl.length();
head.xattr_len = xattrbl.length();
::encode(head, payload);
diff --git a/src/messages/MClientLease.h b/src/messages/MClientLease.h
index e87d7c58205..bab99a1ea24 100644
--- a/src/messages/MClientLease.h
+++ b/src/messages/MClientLease.h
@@ -73,7 +73,7 @@ public:
::decode(h, p);
::decode(dname, p);
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
::encode(h, payload);
::encode(dname, payload);
}
diff --git a/src/messages/MClientReconnect.h b/src/messages/MClientReconnect.h
index 9327227d5fc..43bb11bf924 100644
--- a/src/messages/MClientReconnect.h
+++ b/src/messages/MClientReconnect.h
@@ -49,7 +49,7 @@ public:
realms.push_back(r);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
if (features & CEPH_FEATURE_FLOCK) {
// new protocol
header.version = 2;
diff --git a/src/messages/MClientReply.h b/src/messages/MClientReply.h
index 88c7b5ababd..65768566734 100644
--- a/src/messages/MClientReply.h
+++ b/src/messages/MClientReply.h
@@ -238,7 +238,7 @@ public:
::decode(snapbl, p);
assert(p.end());
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
::encode(head, payload);
::encode(trace_bl, payload);
::encode(extra_bl, payload);
diff --git a/src/messages/MClientRequest.h b/src/messages/MClientRequest.h
index 360c05051a1..a26a7a9b437 100644
--- a/src/messages/MClientRequest.h
+++ b/src/messages/MClientRequest.h
@@ -149,7 +149,7 @@ public:
::decode_nohead(head.num_releases, releases, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
head.num_releases = releases.size();
::encode(head, payload);
::encode(path, payload);
diff --git a/src/messages/MClientRequestForward.h b/src/messages/MClientRequestForward.h
index 62fca8df75b..43b0e4094e0 100644
--- a/src/messages/MClientRequestForward.h
+++ b/src/messages/MClientRequestForward.h
@@ -46,7 +46,7 @@ public:
<< ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dest_mds, payload);
::encode(num_fwd, payload);
::encode(client_must_resend, payload);
diff --git a/src/messages/MClientSession.h b/src/messages/MClientSession.h
index 54411fe6ce6..d045bda5d41 100644
--- a/src/messages/MClientSession.h
+++ b/src/messages/MClientSession.h
@@ -59,7 +59,7 @@ public:
bufferlist::iterator p = payload.begin();
::decode(head, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(head, payload);
}
};
diff --git a/src/messages/MClientSnap.h b/src/messages/MClientSnap.h
index 7f662005308..56476c6aabf 100644
--- a/src/messages/MClientSnap.h
+++ b/src/messages/MClientSnap.h
@@ -43,7 +43,7 @@ public:
out << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
head.num_split_inos = split_inos.size();
head.num_split_realms = split_realms.size();
head.trace_len = bl.length();
diff --git a/src/messages/MCommand.h b/src/messages/MCommand.h
index bcdb938eb4a..9376aceb580 100644
--- a/src/messages/MCommand.h
+++ b/src/messages/MCommand.h
@@ -45,7 +45,7 @@ public:
o << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(fsid, payload);
::encode(cmd, payload);
}
diff --git a/src/messages/MCommandReply.h b/src/messages/MCommandReply.h
index 5196487f870..797c64ea610 100644
--- a/src/messages/MCommandReply.h
+++ b/src/messages/MCommandReply.h
@@ -41,7 +41,7 @@ public:
o << "command_reply(tid " << get_tid() << ": " << r << " " << rs << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(r, payload);
::encode(rs, payload);
}
diff --git a/src/messages/MDentryLink.h b/src/messages/MDentryLink.h
index d6286bb0793..8a91d28ec5c 100644
--- a/src/messages/MDentryLink.h
+++ b/src/messages/MDentryLink.h
@@ -51,7 +51,7 @@ public:
::decode(is_primary, p);
::decode(bl, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dirfrag, payload);
::encode(dn, payload);
::encode(is_primary, payload);
diff --git a/src/messages/MDentryUnlink.h b/src/messages/MDentryUnlink.h
index 4d047706719..30cf4327a80 100644
--- a/src/messages/MDentryUnlink.h
+++ b/src/messages/MDentryUnlink.h
@@ -47,7 +47,7 @@ public:
::decode(dn, p);
::decode(straybl, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dirfrag, payload);
::encode(dn, payload);
::encode(straybl, payload);
diff --git a/src/messages/MDirUpdate.h b/src/messages/MDirUpdate.h
index f26acd7a9d1..de00652b577 100644
--- a/src/messages/MDirUpdate.h
+++ b/src/messages/MDirUpdate.h
@@ -72,7 +72,7 @@ public:
::decode(path, p);
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
::encode(from_mds, payload);
::encode(dirfrag, payload);
::encode(dir_rep, payload);
diff --git a/src/messages/MDiscover.h b/src/messages/MDiscover.h
index 0ee60a21616..45132b311e0 100644
--- a/src/messages/MDiscover.h
+++ b/src/messages/MDiscover.h
@@ -88,7 +88,7 @@ public:
::decode(want_base_dir, p);
::decode(want_xlocked, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(base_ino, payload);
::encode(base_dir_frag, payload);
::encode(snapid, payload);
diff --git a/src/messages/MDiscoverReply.h b/src/messages/MDiscoverReply.h
index 96ac6752ed2..ee3a81419bd 100644
--- a/src/messages/MDiscoverReply.h
+++ b/src/messages/MDiscoverReply.h
@@ -199,7 +199,7 @@ public:
if (header.version >= 2)
::decode(wanted_ino, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
header.version = 2;
::encode(base_ino, payload);
::encode(base_dir_frag, payload);
diff --git a/src/messages/MExportCaps.h b/src/messages/MExportCaps.h
index ac8cc93f8b9..873751d7da8 100644
--- a/src/messages/MExportCaps.h
+++ b/src/messages/MExportCaps.h
@@ -36,7 +36,7 @@ public:
o << "export_caps(" << ino << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(ino, payload);
::encode(cap_bl, payload);
::encode(client_map, payload);
diff --git a/src/messages/MExportCapsAck.h b/src/messages/MExportCapsAck.h
index 8ffdea660e2..8f5ff81ab09 100644
--- a/src/messages/MExportCapsAck.h
+++ b/src/messages/MExportCapsAck.h
@@ -36,7 +36,7 @@ public:
o << "export_caps_ack(" << ino << ")";
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
::encode(ino, payload);
}
virtual void decode_payload(CephContext *cct) {
diff --git a/src/messages/MExportDir.h b/src/messages/MExportDir.h
index a44ae6c507b..e6113aedd42 100644
--- a/src/messages/MExportDir.h
+++ b/src/messages/MExportDir.h
@@ -44,7 +44,7 @@ public:
bounds.push_back(df);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dirfrag, payload);
::encode(bounds, payload);
::encode(export_data, payload);
diff --git a/src/messages/MExportDirAck.h b/src/messages/MExportDirAck.h
index e95def9d6d1..908e0fda6d5 100644
--- a/src/messages/MExportDirAck.h
+++ b/src/messages/MExportDirAck.h
@@ -39,7 +39,7 @@ public:
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dirfrag, payload);
}
diff --git a/src/messages/MExportDirCancel.h b/src/messages/MExportDirCancel.h
index 045b78a988d..eba4dd1a20b 100644
--- a/src/messages/MExportDirCancel.h
+++ b/src/messages/MExportDirCancel.h
@@ -37,7 +37,7 @@ public:
o << "export_cancel(" << dirfrag << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dirfrag, payload);
}
void decode_payload(CephContext *cct) {
diff --git a/src/messages/MExportDirDiscover.h b/src/messages/MExportDirDiscover.h
index 4c1e59b7e10..a06ac01cc15 100644
--- a/src/messages/MExportDirDiscover.h
+++ b/src/messages/MExportDirDiscover.h
@@ -57,7 +57,7 @@ public:
::decode(path, p);
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
::encode(from, payload);
::encode(dirfrag, payload);
::encode(path, payload);
diff --git a/src/messages/MExportDirDiscoverAck.h b/src/messages/MExportDirDiscoverAck.h
index 6fca62ab5aa..58178a860ca 100644
--- a/src/messages/MExportDirDiscoverAck.h
+++ b/src/messages/MExportDirDiscoverAck.h
@@ -50,7 +50,7 @@ public:
::decode(dirfrag, p);
::decode(success, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dirfrag, payload);
::encode(success, payload);
}
diff --git a/src/messages/MExportDirFinish.h b/src/messages/MExportDirFinish.h
index b6651f41643..52e738f6e2d 100644
--- a/src/messages/MExportDirFinish.h
+++ b/src/messages/MExportDirFinish.h
@@ -37,7 +37,7 @@ public:
o << "export_finish(" << dirfrag << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dirfrag, payload);
}
void decode_payload(CephContext *cct) {
diff --git a/src/messages/MExportDirNotify.h b/src/messages/MExportDirNotify.h
index ea92a234496..e5f1263776d 100644
--- a/src/messages/MExportDirNotify.h
+++ b/src/messages/MExportDirNotify.h
@@ -59,7 +59,7 @@ public:
bounds.push_back(*i);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(base, payload);
::encode(ack, payload);
::encode(old_auth, payload);
diff --git a/src/messages/MExportDirNotifyAck.h b/src/messages/MExportDirNotifyAck.h
index ed7989aaa70..d2e4facb0bb 100644
--- a/src/messages/MExportDirNotifyAck.h
+++ b/src/messages/MExportDirNotifyAck.h
@@ -39,7 +39,7 @@ public:
o << "export_notify_ack(" << dirfrag << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dirfrag, payload);
}
void decode_payload(CephContext *cct) {
diff --git a/src/messages/MExportDirPrep.h b/src/messages/MExportDirPrep.h
index df46b802630..8b8690ee563 100644
--- a/src/messages/MExportDirPrep.h
+++ b/src/messages/MExportDirPrep.h
@@ -72,7 +72,7 @@ public:
::decode(bystanders, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dirfrag, payload);
::encode(basedir, payload);
::encode(bounds, payload);
diff --git a/src/messages/MExportDirPrepAck.h b/src/messages/MExportDirPrepAck.h
index 1b3de01d80e..7b9d97d3aa7 100644
--- a/src/messages/MExportDirPrepAck.h
+++ b/src/messages/MExportDirPrepAck.h
@@ -41,7 +41,7 @@ public:
bufferlist::iterator p = payload.begin();
::decode(dirfrag, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(dirfrag, payload);
}
};
diff --git a/src/messages/MForward.h b/src/messages/MForward.h
index b916f5bd893..2969b8c2f20 100644
--- a/src/messages/MForward.h
+++ b/src/messages/MForward.h
@@ -46,11 +46,11 @@ private:
}
public:
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(tid, payload);
::encode(client, payload);
::encode(client_caps, payload);
- encode_message(cct, msg, features, payload);
+ encode_message(msg, features, payload);
}
void decode_payload(CephContext *cct) {
diff --git a/src/messages/MGenericMessage.h b/src/messages/MGenericMessage.h
index edeb8ae755e..9051b33f269 100644
--- a/src/messages/MGenericMessage.h
+++ b/src/messages/MGenericMessage.h
@@ -33,7 +33,7 @@ class MGenericMessage : public Message {
const char *get_type_name() { return tname; }
void decode_payload(CephContext *cct) { }
- void encode_payload(CephContext *cct, uint64_t features) { }
+ void encode_payload(uint64_t features) { }
};
#endif
diff --git a/src/messages/MGetPoolStats.h b/src/messages/MGetPoolStats.h
index 4905e6feb1e..86f2ebf2c0d 100644
--- a/src/messages/MGetPoolStats.h
+++ b/src/messages/MGetPoolStats.h
@@ -41,7 +41,7 @@ public:
out << "getpoolstats(" << get_tid() << " " << pools << " v" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(fsid, payload);
::encode(pools, payload);
diff --git a/src/messages/MGetPoolStatsReply.h b/src/messages/MGetPoolStatsReply.h
index e5832bd7334..6b075def2ab 100644
--- a/src/messages/MGetPoolStatsReply.h
+++ b/src/messages/MGetPoolStatsReply.h
@@ -39,7 +39,7 @@ public:
out << "getpoolstatsreply(" << get_tid() << " v" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(fsid, payload);
::encode(pool_stats, payload);
diff --git a/src/messages/MHeartbeat.h b/src/messages/MHeartbeat.h
index e3bdf122044..7197c78525d 100644
--- a/src/messages/MHeartbeat.h
+++ b/src/messages/MHeartbeat.h
@@ -48,7 +48,7 @@ private:
public:
const char *get_type_name() { return "HB"; }
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(load, payload);
::encode(beat, payload);
::encode(import_map, payload);
diff --git a/src/messages/MInodeFileCaps.h b/src/messages/MInodeFileCaps.h
index 58cf3837264..afc55cde57b 100644
--- a/src/messages/MInodeFileCaps.h
+++ b/src/messages/MInodeFileCaps.h
@@ -39,7 +39,7 @@ public:
out << "inode_file_caps(" << ino << " " << ccap_string(caps) << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(ino, payload);
::encode(caps, payload);
}
diff --git a/src/messages/MLock.h b/src/messages/MLock.h
index 053efe8b281..b6018a52df1 100644
--- a/src/messages/MLock.h
+++ b/src/messages/MLock.h
@@ -81,7 +81,7 @@ public:
::decode(object_info, p);
::decode(lockdata, p);
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
::encode(asker, payload);
::encode(action, payload);
::encode(reqid, payload);
diff --git a/src/messages/MLog.h b/src/messages/MLog.h
index 0b3206f8829..c32393380d3 100644
--- a/src/messages/MLog.h
+++ b/src/messages/MLog.h
@@ -42,7 +42,7 @@ public:
out << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(fsid, payload);
::encode(entries, payload);
diff --git a/src/messages/MLogAck.h b/src/messages/MLogAck.h
index f3137499948..d9caf8c70f2 100644
--- a/src/messages/MLogAck.h
+++ b/src/messages/MLogAck.h
@@ -33,7 +33,7 @@ public:
out << "log(last " << last << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(fsid, payload);
::encode(last, payload);
}
diff --git a/src/messages/MMDSBeacon.h b/src/messages/MMDSBeacon.h
index ca19828b7a9..2da0aa220ed 100644
--- a/src/messages/MMDSBeacon.h
+++ b/src/messages/MMDSBeacon.h
@@ -67,7 +67,7 @@ public:
<< " seq " << seq << " v" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
header.version = 2;
paxos_encode();
::encode(fsid, payload);
diff --git a/src/messages/MMDSCacheRejoin.h b/src/messages/MMDSCacheRejoin.h
index e8e09cb9cd7..200a3a12db4 100644
--- a/src/messages/MMDSCacheRejoin.h
+++ b/src/messages/MMDSCacheRejoin.h
@@ -271,7 +271,7 @@ public:
}
// -- encoding --
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(op, payload);
::encode(strong_inodes, payload);
::encode(inode_base, payload);
diff --git a/src/messages/MMDSFindIno.h b/src/messages/MMDSFindIno.h
index 2379efe8630..83564ce7d13 100644
--- a/src/messages/MMDSFindIno.h
+++ b/src/messages/MMDSFindIno.h
@@ -30,7 +30,7 @@ struct MMDSFindIno : public Message {
out << "findino(" << tid << " " << ino << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(tid, payload);
::encode(ino, payload);
}
diff --git a/src/messages/MMDSFindInoReply.h b/src/messages/MMDSFindInoReply.h
index 91babc23d15..44f4d585457 100644
--- a/src/messages/MMDSFindInoReply.h
+++ b/src/messages/MMDSFindInoReply.h
@@ -30,7 +30,7 @@ struct MMDSFindInoReply : public Message {
out << "findinoreply(" << tid << " " << path << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(tid, payload);
::encode(path, payload);
}
diff --git a/src/messages/MMDSFragmentNotify.h b/src/messages/MMDSFragmentNotify.h
index fa90c84adb0..042ae365ca0 100644
--- a/src/messages/MMDSFragmentNotify.h
+++ b/src/messages/MMDSFragmentNotify.h
@@ -45,7 +45,7 @@ public:
<< " " << (int)bits << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(ino, payload);
::encode(basefrag, payload);
::encode(bits, payload);
diff --git a/src/messages/MMDSLoadTargets.h b/src/messages/MMDSLoadTargets.h
index 225f7330a56..ed46ceb3d49 100644
--- a/src/messages/MMDSLoadTargets.h
+++ b/src/messages/MMDSLoadTargets.h
@@ -48,7 +48,7 @@ public:
::decode(targets, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(global_id, payload);
::encode(targets, payload);
diff --git a/src/messages/MMDSMap.h b/src/messages/MMDSMap.h
index 3e19cb41312..f04b07fa3fa 100644
--- a/src/messages/MMDSMap.h
+++ b/src/messages/MMDSMap.h
@@ -79,7 +79,7 @@ public:
::decode(epoch, p);
::decode(encoded, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(fsid, payload);
::encode(epoch, payload);
if ((features & CEPH_FEATURE_PGID64) == 0) {
diff --git a/src/messages/MMDSResolve.h b/src/messages/MMDSResolve.h
index 2436b696d18..be034e7970c 100644
--- a/src/messages/MMDSResolve.h
+++ b/src/messages/MMDSResolve.h
@@ -53,7 +53,7 @@ public:
slave_requests.push_back(reqid);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(subtrees, payload);
::encode(ambiguous_imports, payload);
::encode(slave_requests, payload);
diff --git a/src/messages/MMDSResolveAck.h b/src/messages/MMDSResolveAck.h
index 4666c59e33f..78a0b13c5da 100644
--- a/src/messages/MMDSResolveAck.h
+++ b/src/messages/MMDSResolveAck.h
@@ -45,7 +45,7 @@ public:
abort.push_back(r);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(commit, payload);
::encode(abort, payload);
}
diff --git a/src/messages/MMDSSlaveRequest.h b/src/messages/MMDSSlaveRequest.h
index 17a157abd7f..39ae9a09665 100644
--- a/src/messages/MMDSSlaveRequest.h
+++ b/src/messages/MMDSSlaveRequest.h
@@ -127,7 +127,7 @@ private:
~MMDSSlaveRequest() {}
public:
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(reqid, payload);
::encode(attempt, payload);
::encode(op, payload);
diff --git a/src/messages/MMDSTableRequest.h b/src/messages/MMDSTableRequest.h
index a056114f1bd..64d5d11a445 100644
--- a/src/messages/MMDSTableRequest.h
+++ b/src/messages/MMDSTableRequest.h
@@ -54,7 +54,7 @@ public:
::decode(bl, p);
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
::encode(table, payload);
::encode(op, payload);
::encode(reqid, payload);
diff --git a/src/messages/MMonCommand.h b/src/messages/MMonCommand.h
index 69771250a85..8c3ecc905d8 100644
--- a/src/messages/MMonCommand.h
+++ b/src/messages/MMonCommand.h
@@ -44,7 +44,7 @@ public:
o << " v " << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(fsid, payload);
::encode(cmd, payload);
diff --git a/src/messages/MMonCommandAck.h b/src/messages/MMonCommandAck.h
index 4b0f90bb017..c55b89b3004 100644
--- a/src/messages/MMonCommandAck.h
+++ b/src/messages/MMonCommandAck.h
@@ -36,7 +36,7 @@ public:
o << "mon_command_ack(" << cmd << "=" << r << " " << rs << " v" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(r, payload);
::encode(rs, payload);
diff --git a/src/messages/MMonElection.h b/src/messages/MMonElection.h
index ce1b567763b..6c7063dd0b9 100644
--- a/src/messages/MMonElection.h
+++ b/src/messages/MMonElection.h
@@ -56,7 +56,7 @@ public:
out << "election(" << fsid << " " << get_opname(op) << " " << epoch << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
header.version = 2;
::encode(fsid, payload);
::encode(op, payload);
diff --git a/src/messages/MMonGetMap.h b/src/messages/MMonGetMap.h
index 312291b64dc..a349538f314 100644
--- a/src/messages/MMonGetMap.h
+++ b/src/messages/MMonGetMap.h
@@ -28,7 +28,7 @@ private:
public:
const char *get_type_name() { return "mon_getmap"; }
- void encode_payload(CephContext *cct, uint64_t features) { }
+ void encode_payload(uint64_t features) { }
void decode_payload(CephContext *cct) { }
};
diff --git a/src/messages/MMonGetVersion.h b/src/messages/MMonGetVersion.h
index da3665d21a5..809bbd3a564 100644
--- a/src/messages/MMonGetVersion.h
+++ b/src/messages/MMonGetVersion.h
@@ -37,7 +37,7 @@ public:
o << "mon_get_version(what=" << what << " handle=" << handle << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(handle, payload);
::encode(what, payload);
}
diff --git a/src/messages/MMonGetVersionReply.h b/src/messages/MMonGetVersionReply.h
index 7346602ec0e..248e3172014 100644
--- a/src/messages/MMonGetVersionReply.h
+++ b/src/messages/MMonGetVersionReply.h
@@ -36,7 +36,7 @@ public:
o << "mon_check_map_ack(handle=" << handle << " version=" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
header.version = 2;
::encode(handle, payload);
::encode(version, payload);
diff --git a/src/messages/MMonGlobalID.h b/src/messages/MMonGlobalID.h
index 8abe9c04c8d..a8fb69b1dd0 100644
--- a/src/messages/MMonGlobalID.h
+++ b/src/messages/MMonGlobalID.h
@@ -34,7 +34,7 @@ public:
paxos_decode(p);
::decode(old_max_id, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(old_max_id, payload);
}
diff --git a/src/messages/MMonJoin.h b/src/messages/MMonJoin.h
index 23b468bb710..51f3ce658c7 100644
--- a/src/messages/MMonJoin.h
+++ b/src/messages/MMonJoin.h
@@ -41,7 +41,7 @@ public:
o << "mon_join(" << name << " " << addr << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(fsid, payload);
::encode(name, payload);
diff --git a/src/messages/MMonMap.h b/src/messages/MMonMap.h
index c7dc06dcd81..56b5582af61 100644
--- a/src/messages/MMonMap.h
+++ b/src/messages/MMonMap.h
@@ -31,7 +31,7 @@ private:
public:
const char *get_type_name() { return "mon_map"; }
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(monmapbl, payload);
}
void decode_payload(CephContext *cct) {
diff --git a/src/messages/MMonObserve.h b/src/messages/MMonObserve.h
index dde35d2e754..b631492f671 100644
--- a/src/messages/MMonObserve.h
+++ b/src/messages/MMonObserve.h
@@ -39,7 +39,7 @@ public:
o << "observe(" << machine_id << " v" << ver << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(fsid, payload);
::encode(machine_id, payload);
diff --git a/src/messages/MMonObserveNotify.h b/src/messages/MMonObserveNotify.h
index b6842d1491d..33eb667afa5 100644
--- a/src/messages/MMonObserveNotify.h
+++ b/src/messages/MMonObserveNotify.h
@@ -40,7 +40,7 @@ public:
o << " v" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(fsid, payload);
::encode(machine_id, payload);
diff --git a/src/messages/MMonPaxos.h b/src/messages/MMonPaxos.h
index 1e165d57358..5bc87f335f4 100644
--- a/src/messages/MMonPaxos.h
+++ b/src/messages/MMonPaxos.h
@@ -87,7 +87,7 @@ public:
out << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
if (features & CEPH_FEATURE_MONCLOCKCHECK)
header.version = 1;
::encode(epoch, payload);
diff --git a/src/messages/MMonProbe.h b/src/messages/MMonProbe.h
index 592cd0d3db5..da8df6ad025 100644
--- a/src/messages/MMonProbe.h
+++ b/src/messages/MMonProbe.h
@@ -72,7 +72,7 @@ public:
out << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(fsid, payload);
::encode(op, payload);
::encode(name, payload);
diff --git a/src/messages/MMonSubscribe.h b/src/messages/MMonSubscribe.h
index 1a4bb9f5631..b773f1de457 100644
--- a/src/messages/MMonSubscribe.h
+++ b/src/messages/MMonSubscribe.h
@@ -68,7 +68,7 @@ public:
::decode(what, p);
}
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
if (features & CEPH_FEATURE_SUBSCRIBE2) {
header.version = 2;
::encode(what, payload);
diff --git a/src/messages/MMonSubscribeAck.h b/src/messages/MMonSubscribeAck.h
index 24361150a86..4a4b8056a99 100644
--- a/src/messages/MMonSubscribeAck.h
+++ b/src/messages/MMonSubscribeAck.h
@@ -41,7 +41,7 @@ public:
::decode(interval, p);
::decode(fsid, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(interval, payload);
::encode(fsid, payload);
}
diff --git a/src/messages/MOSDAlive.h b/src/messages/MOSDAlive.h
index b44286f3aa1..cd205668711 100644
--- a/src/messages/MOSDAlive.h
+++ b/src/messages/MOSDAlive.h
@@ -29,7 +29,7 @@ private:
~MOSDAlive() {}
public:
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(want, payload);
}
diff --git a/src/messages/MOSDBoot.h b/src/messages/MOSDBoot.h
index f3bc0444004..88d30f6b27b 100644
--- a/src/messages/MOSDBoot.h
+++ b/src/messages/MOSDBoot.h
@@ -41,7 +41,7 @@ public:
out << "osd_boot(osd." << sb.whoami << " v" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
header.version = 2;
paxos_encode();
::encode(sb, payload);
diff --git a/src/messages/MOSDFailure.h b/src/messages/MOSDFailure.h
index 8f8685e3358..f270a47e5a3 100644
--- a/src/messages/MOSDFailure.h
+++ b/src/messages/MOSDFailure.h
@@ -48,7 +48,7 @@ public:
::decode(is_failed, p);
else is_failed = true;
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
header.version = 2;
paxos_encode();
::encode(fsid, payload);
diff --git a/src/messages/MOSDMap.h b/src/messages/MOSDMap.h
index 3b450e4c4f5..d3bb8e80c12 100644
--- a/src/messages/MOSDMap.h
+++ b/src/messages/MOSDMap.h
@@ -79,7 +79,7 @@ public:
newest_map = 0;
}
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(fsid, payload);
header.version = 2;
if ((features & CEPH_FEATURE_PGID64) == 0 ||
diff --git a/src/messages/MOSDOp.h b/src/messages/MOSDOp.h
index d6864405cc9..3d3cb67f0ab 100644
--- a/src/messages/MOSDOp.h
+++ b/src/messages/MOSDOp.h
@@ -184,7 +184,7 @@ public:
}
// marshalling
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
OSDOp::merge_osd_op_vector_in_data(ops, data);
diff --git a/src/messages/MOSDOpReply.h b/src/messages/MOSDOpReply.h
index 88cec1149f9..0a1dc9aa2bc 100644
--- a/src/messages/MOSDOpReply.h
+++ b/src/messages/MOSDOpReply.h
@@ -108,7 +108,7 @@ private:
~MOSDOpReply() {}
public:
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
OSDOp::merge_osd_op_vector_out_data(ops, data);
diff --git a/src/messages/MOSDPGBackfill.h b/src/messages/MOSDPGBackfill.h
index e5783cf9a61..b38147834e2 100644
--- a/src/messages/MOSDPGBackfill.h
+++ b/src/messages/MOSDPGBackfill.h
@@ -50,7 +50,7 @@ public:
::decode(stats, p);
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
::encode(op, payload);
::encode(map_epoch, payload);
::encode(query_epoch, payload);
diff --git a/src/messages/MOSDPGCreate.h b/src/messages/MOSDPGCreate.h
index d93a1421cf7..6052f4c1447 100644
--- a/src/messages/MOSDPGCreate.h
+++ b/src/messages/MOSDPGCreate.h
@@ -54,7 +54,7 @@ private:
public:
const char *get_type_name() { return "pg_create"; }
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(epoch, payload);
::encode(mkpg, payload);
}
diff --git a/src/messages/MOSDPGInfo.h b/src/messages/MOSDPGInfo.h
index da176728a32..dd5a75ed87f 100644
--- a/src/messages/MOSDPGInfo.h
+++ b/src/messages/MOSDPGInfo.h
@@ -39,7 +39,7 @@ public:
out << "pg_info(" << pg_info.size() << " pgs e" << epoch << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(epoch, payload);
::encode(pg_info, payload);
}
diff --git a/src/messages/MOSDPGLog.h b/src/messages/MOSDPGLog.h
index 5ceee001ade..3bb3d6811fd 100644
--- a/src/messages/MOSDPGLog.h
+++ b/src/messages/MOSDPGLog.h
@@ -52,7 +52,7 @@ public:
<< " query_epoch " << query_epoch << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
header.version = 2;
::encode(epoch, payload);
::encode(info, payload);
diff --git a/src/messages/MOSDPGMissing.h b/src/messages/MOSDPGMissing.h
index 00abe5f6aa1..764e737422d 100644
--- a/src/messages/MOSDPGMissing.h
+++ b/src/messages/MOSDPGMissing.h
@@ -41,7 +41,7 @@ public:
out << "pg_missing(" << info.pgid << " e" << epoch << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(epoch, payload);
::encode(info, payload);
::encode(missing, payload);
diff --git a/src/messages/MOSDPGNotify.h b/src/messages/MOSDPGNotify.h
index cf53e3b7a76..0524f65d59c 100644
--- a/src/messages/MOSDPGNotify.h
+++ b/src/messages/MOSDPGNotify.h
@@ -49,7 +49,7 @@ private:
public:
const char *get_type_name() { return "PGnot"; }
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
header.version = 2;
::encode(epoch, payload);
::encode(pg_list, payload);
diff --git a/src/messages/MOSDPGQuery.h b/src/messages/MOSDPGQuery.h
index 8c58888a3f9..a5a2b528c13 100644
--- a/src/messages/MOSDPGQuery.h
+++ b/src/messages/MOSDPGQuery.h
@@ -50,7 +50,7 @@ public:
out << " epoch " << epoch << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(epoch, payload);
::encode(pg_list, payload);
}
diff --git a/src/messages/MOSDPGRemove.h b/src/messages/MOSDPGRemove.h
index 4dc1ebf0a17..b78070c3ca0 100644
--- a/src/messages/MOSDPGRemove.h
+++ b/src/messages/MOSDPGRemove.h
@@ -39,7 +39,7 @@ private:
public:
const char *get_type_name() { return "PGrm"; }
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(epoch, payload);
::encode(pg_list, payload);
}
diff --git a/src/messages/MOSDPGScan.h b/src/messages/MOSDPGScan.h
index d053486efc9..6aeeb52e637 100644
--- a/src/messages/MOSDPGScan.h
+++ b/src/messages/MOSDPGScan.h
@@ -47,7 +47,7 @@ public:
::decode(end, p);
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
::encode(op, payload);
::encode(map_epoch, payload);
::encode(query_epoch, payload);
diff --git a/src/messages/MOSDPGTemp.h b/src/messages/MOSDPGTemp.h
index 78c88ebd892..6432fa64f40 100644
--- a/src/messages/MOSDPGTemp.h
+++ b/src/messages/MOSDPGTemp.h
@@ -30,7 +30,7 @@ private:
~MOSDPGTemp() {}
public:
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(map_epoch, payload);
::encode(pg_temp, payload);
diff --git a/src/messages/MOSDPGTrim.h b/src/messages/MOSDPGTrim.h
index f404c76261e..0ba0c66e334 100644
--- a/src/messages/MOSDPGTrim.h
+++ b/src/messages/MOSDPGTrim.h
@@ -38,7 +38,7 @@ public:
out << "pg_trim(" << pgid << " to " << trim_to << " e" << epoch << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(epoch, payload);
::encode(pgid, payload);
::encode(trim_to, payload);
diff --git a/src/messages/MOSDPing.h b/src/messages/MOSDPing.h
index 75541ebe18c..4635d3df8b3 100644
--- a/src/messages/MOSDPing.h
+++ b/src/messages/MOSDPing.h
@@ -61,7 +61,7 @@ public:
::decode(op, p);
::decode(peer_stat, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(fsid, payload);
::encode(map_epoch, payload);
::encode(peer_as_of_epoch, payload);
diff --git a/src/messages/MOSDRepScrub.h b/src/messages/MOSDRepScrub.h
index 7599771f480..52e11fea740 100644
--- a/src/messages/MOSDRepScrub.h
+++ b/src/messages/MOSDRepScrub.h
@@ -49,7 +49,7 @@ public:
out << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
header.version = 2;
::encode(pgid, payload);
::encode(scrub_from, payload);
diff --git a/src/messages/MOSDScrub.h b/src/messages/MOSDScrub.h
index 8785a833608..724ea126247 100644
--- a/src/messages/MOSDScrub.h
+++ b/src/messages/MOSDScrub.h
@@ -50,7 +50,7 @@ public:
out << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(fsid, payload);
::encode(scrub_pgs, payload);
::encode(repair, payload);
diff --git a/src/messages/MOSDSubOp.h b/src/messages/MOSDSubOp.h
index da811bedec5..30ff3fb0fee 100644
--- a/src/messages/MOSDSubOp.h
+++ b/src/messages/MOSDSubOp.h
@@ -108,7 +108,7 @@ public:
::decode(oloc, p);
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
header.version = 3;
::encode(map_epoch, payload);
diff --git a/src/messages/MOSDSubOpReply.h b/src/messages/MOSDSubOpReply.h
index d01bc6a78bf..b49a20c181d 100644
--- a/src/messages/MOSDSubOpReply.h
+++ b/src/messages/MOSDSubOpReply.h
@@ -69,7 +69,7 @@ public:
::decode(peer_stat, p);
::decode(attrset, p);
}
- virtual void encode_payload(CephContext *cct, uint64_t features) {
+ virtual void encode_payload(uint64_t features) {
::encode(map_epoch, payload);
::encode(reqid, payload);
::encode(pgid, payload);
diff --git a/src/messages/MPGStats.h b/src/messages/MPGStats.h
index 5f94a8423c3..06f590bdea2 100644
--- a/src/messages/MPGStats.h
+++ b/src/messages/MPGStats.h
@@ -39,7 +39,7 @@ public:
out << "pg_stats(" << pg_stat.size() << " pgs tid " << get_tid() << " v " << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(fsid, payload);
::encode(osd_stat, payload);
diff --git a/src/messages/MPGStatsAck.h b/src/messages/MPGStatsAck.h
index 8d933803c75..44e04959bb5 100644
--- a/src/messages/MPGStatsAck.h
+++ b/src/messages/MPGStatsAck.h
@@ -32,7 +32,7 @@ public:
out << "pg_stats_ack(" << pg_stat.size() << " pgs tid " << get_tid() << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(pg_stat, payload);
}
void decode_payload(CephContext *cct) {
diff --git a/src/messages/MPing.h b/src/messages/MPing.h
index a3778c0f5b5..a0cd5446da3 100644
--- a/src/messages/MPing.h
+++ b/src/messages/MPing.h
@@ -28,7 +28,7 @@ private:
public:
void decode_payload(CephContext *cct) { }
- void encode_payload(CephContext *cct, uint64_t features) { }
+ void encode_payload(uint64_t features) { }
const char *get_type_name() { return "ping"; }
};
diff --git a/src/messages/MPoolOp.h b/src/messages/MPoolOp.h
index ddd6c242ec1..d81f37dee9b 100644
--- a/src/messages/MPoolOp.h
+++ b/src/messages/MPoolOp.h
@@ -54,7 +54,7 @@ public:
<< " v" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
header.version = 4;
paxos_encode();
::encode(fsid, payload);
diff --git a/src/messages/MPoolOpReply.h b/src/messages/MPoolOpReply.h
index 6f0a3a49b47..d3dc2d49bea 100644
--- a/src/messages/MPoolOpReply.h
+++ b/src/messages/MPoolOpReply.h
@@ -52,7 +52,7 @@ public:
<< " v" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(fsid, payload);
::encode(replyCode, payload);
diff --git a/src/messages/MRemoveSnaps.h b/src/messages/MRemoveSnaps.h
index adba7e835e1..79b3fbc8931 100644
--- a/src/messages/MRemoveSnaps.h
+++ b/src/messages/MRemoveSnaps.h
@@ -35,7 +35,7 @@ public:
out << "remove_snaps(" << snaps << " v" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(snaps, payload);
}
diff --git a/src/messages/MRoute.h b/src/messages/MRoute.h
index 350bb4cad28..d9bc7f83397 100644
--- a/src/messages/MRoute.h
+++ b/src/messages/MRoute.h
@@ -45,10 +45,10 @@ public:
::decode(dest, p);
msg = decode_message(cct, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(session_mon_tid, payload);
::encode(dest, payload);
- encode_message(cct, msg, features, payload);
+ encode_message(msg, features, payload);
}
const char *get_type_name() { return "route"; }
diff --git a/src/messages/MStatfs.h b/src/messages/MStatfs.h
index 1a57bbb4bd8..35067b9e9e3 100644
--- a/src/messages/MStatfs.h
+++ b/src/messages/MStatfs.h
@@ -38,7 +38,7 @@ public:
out << "statfs(" << get_tid() << " v" << version << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
paxos_encode();
::encode(fsid, payload);
}
diff --git a/src/messages/MStatfsReply.h b/src/messages/MStatfsReply.h
index f8ea2637d41..8932f154010 100644
--- a/src/messages/MStatfsReply.h
+++ b/src/messages/MStatfsReply.h
@@ -32,7 +32,7 @@ public:
out << "statfs_reply(" << header.tid << ")";
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
::encode(h, payload);
}
void decode_payload(CephContext *cct) {
diff --git a/src/messages/MWatchNotify.h b/src/messages/MWatchNotify.h
index 54ccb21c600..2ffffff0164 100644
--- a/src/messages/MWatchNotify.h
+++ b/src/messages/MWatchNotify.h
@@ -45,7 +45,7 @@ public:
if (msg_ver >= 1)
::decode(bl, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
uint8_t msg_ver = 1;
::encode(msg_ver, payload);
::encode(opcode, payload);
diff --git a/src/messages/PaxosServiceMessage.h b/src/messages/PaxosServiceMessage.h
index 5551df472cd..dcd5b5a183b 100644
--- a/src/messages/PaxosServiceMessage.h
+++ b/src/messages/PaxosServiceMessage.h
@@ -30,7 +30,7 @@ class PaxosServiceMessage : public Message {
::decode(session_mon_tid, p);
}
- void encode_payload(CephContext *cct, uint64_t features) {
+ void encode_payload(uint64_t features) {
assert(0);
paxos_encode();
}