1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
*
*/
#ifndef CEPH_MOSDSUBOPREPLY_H
#define CEPH_MOSDSUBOPREPLY_H
#include "msg/Message.h"
#include "MOSDSubOp.h"
#include "os/ObjectStore.h"
/*
* OSD op reply
*
* oid - object id
* op - OSD_OP_DELETE, etc.
*
*/
class MOSDSubOpReply : public Message {
public:
epoch_t map_epoch;
// subop metadata
osd_reqid_t reqid;
pg_t pgid;
sobject_t poid;
vector<OSDOp> ops;
// result
__u8 ack_type;
int32_t result;
// piggybacked osd state
eversion_t last_complete_ondisk;
osd_peer_stat_t peer_stat;
map<string,bufferptr> attrset;
virtual void decode_payload(CephContext *cct) {
bufferlist::iterator p = payload.begin();
::decode(map_epoch, p);
::decode(reqid, p);
::decode(pgid, p);
::decode(poid, p);
unsigned num_ops;
::decode(num_ops, p);
ops.resize(num_ops);
for (unsigned i = 0; i < num_ops; i++) {
::decode(ops[i].op, p);
}
::decode(ack_type, p);
::decode(result, p);
::decode(last_complete_ondisk, p);
::decode(peer_stat, p);
::decode(attrset, p);
}
virtual void encode_payload(CephContext *cct) {
::encode(map_epoch, payload);
::encode(reqid, payload);
::encode(pgid, payload);
::encode(poid, payload);
__u32 num_ops = ops.size();
::encode(num_ops, payload);
for (unsigned i = 0; i < ops.size(); i++) {
::encode(ops[i].op, payload);
}
::encode(ack_type, payload);
::encode(result, payload);
::encode(last_complete_ondisk, payload);
::encode(peer_stat, payload);
::encode(attrset, payload);
}
epoch_t get_map_epoch() { return map_epoch; }
pg_t get_pg() { return pgid; }
sobject_t get_poid() { return poid; }
int get_ack_type() { return ack_type; }
bool is_ondisk() { return ack_type & CEPH_OSD_FLAG_ONDISK; }
bool is_onnvram() { return ack_type & CEPH_OSD_FLAG_ONNVRAM; }
int get_result() { return result; }
void set_last_complete_ondisk(eversion_t v) { last_complete_ondisk = v; }
eversion_t get_last_complete_ondisk() { return last_complete_ondisk; }
void set_peer_stat(const osd_peer_stat_t& stat) { peer_stat = stat; }
const osd_peer_stat_t& get_peer_stat() { return peer_stat; }
void set_attrset(map<string,bufferptr> &as) { attrset = as; }
map<string,bufferptr>& get_attrset() { return attrset; }
public:
MOSDSubOpReply(MOSDSubOp *req, int result_, epoch_t e, int at) :
Message(MSG_OSD_SUBOPREPLY),
map_epoch(e),
reqid(req->reqid),
pgid(req->pgid),
poid(req->poid),
ops(req->ops),
ack_type(at),
result(result_) {
memset(&peer_stat, 0, sizeof(peer_stat));
set_tid(req->get_tid());
}
MOSDSubOpReply() {}
private:
~MOSDSubOpReply() {}
public:
const char *get_type_name() { return "osd_op_reply"; }
void print(ostream& out) {
out << "osd_sub_op_reply(" << reqid
<< " " << pgid
<< " " << poid << " " << ops;
if (ack_type & CEPH_OSD_FLAG_ONDISK)
out << " ondisk";
if (ack_type & CEPH_OSD_FLAG_ONNVRAM)
out << " onnvram";
if (ack_type & CEPH_OSD_FLAG_ACK)
out << " ack";
out << " = " << result;
out << ")";
}
};
#endif
|
