Skip to content

Commit bcde113

Browse files
Merge pull request ceph#65962 from NitzanMordhai/wip-nitzan-MOSDOpReply-pgid64-encode-decode-fix
messages: MOSDOpReply encode and decode errorcode32_t with PGID64 fea…
2 parents 82862b6 + 6eb0dae commit bcde113

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

src/include/types.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -541,8 +541,8 @@ struct errorcode32_t {
541541
return hostos_to_ceph_errno(code);
542542
}
543543

544-
inline void set_wire_to_host(code_t host_code) {
545-
code = ceph_to_hostos_errno(host_code);
544+
inline void set_wire_to_host(code_t wire_code) {
545+
code = ceph_to_hostos_errno(wire_code);
546546
}
547547

548548
void encode(ceph::buffer::list &bl) const {

src/messages/MOSDOpReply.h

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -187,7 +187,7 @@ class MOSDOpReply final : public Message {
187187
head.flags = flags;
188188
head.osdmap_epoch = osdmap_epoch;
189189
head.reassert_version = bad_replay_version;
190-
head.result = result;
190+
head.result = result.get_host_to_wire();
191191
head.num_ops = ops.size();
192192
head.object_len = oid.name.length();
193193
encode(head, payload);
@@ -269,8 +269,9 @@ class MOSDOpReply final : public Message {
269269
}
270270
ceph::decode_nohead(head.object_len, oid.name, p);
271271
pgid = pg_t(head.layout.ol_pgid);
272-
result = (int32_t)head.result;
272+
result.set_wire_to_host((int32_t)head.result);
273273
flags = head.flags;
274+
bad_replay_version = head.reassert_version;
274275
replay_version = head.reassert_version;
275276
user_version = replay_version.version;
276277
osdmap_epoch = head.osdmap_epoch;

0 commit comments

Comments
 (0)