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
|
#include <errno.h>
#include "cls/version/cls_version_client.h"
#include "include/rados/librados.hpp"
using namespace librados;
void cls_version_set(librados::ObjectWriteOperation& op, obj_version& objv)
{
bufferlist in;
cls_version_set_op call;
call.objv = objv;
encode(call, in);
op.exec("version", "set", in);
}
void cls_version_inc(librados::ObjectWriteOperation& op)
{
bufferlist in;
cls_version_inc_op call;
encode(call, in);
op.exec("version", "inc", in);
}
void cls_version_inc(librados::ObjectWriteOperation& op, obj_version& objv, VersionCond cond)
{
bufferlist in;
cls_version_inc_op call;
call.objv = objv;
obj_version_cond c;
c.cond = cond;
c.ver = objv;
call.conds.push_back(c);
encode(call, in);
op.exec("version", "inc_conds", in);
}
void cls_version_check(librados::ObjectOperation& op, obj_version& objv, VersionCond cond)
{
bufferlist in;
cls_version_check_op call;
call.objv = objv;
obj_version_cond c;
c.cond = cond;
c.ver = objv;
call.conds.push_back(c);
encode(call, in);
op.exec("version", "check_conds", in);
}
class VersionReadCtx : public ObjectOperationCompletion {
obj_version *objv;
public:
explicit VersionReadCtx(obj_version *_objv) : objv(_objv) {}
void handle_completion(int r, bufferlist& outbl) override {
if (r >= 0) {
cls_version_read_ret ret;
try {
auto iter = outbl.cbegin();
decode(ret, iter);
*objv = ret.objv;
} catch (buffer::error& err) {
// nothing we can do about it atm
}
}
}
};
void cls_version_read(librados::ObjectReadOperation& op, obj_version *objv)
{
bufferlist inbl;
op.exec("version", "read", inbl, new VersionReadCtx(objv));
}
int cls_version_read(librados::IoCtx& io_ctx, string& oid, obj_version *ver)
{
bufferlist in, out;
int r = io_ctx.exec(oid, "version", "read", in, out);
if (r < 0)
return r;
cls_version_read_ret ret;
try {
auto iter = out.cbegin();
decode(ret, iter);
} catch (buffer::error& err) {
return -EIO;
}
*ver = ret.objv;
return r;
}
|
