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
|
#include <errno.h>
#include "include/types.h"
#include "cls/statelog/cls_statelog_ops.h"
#include "include/rados/librados.hpp"
using namespace librados;
void cls_statelog_add(librados::ObjectWriteOperation& op, list<cls_statelog_entry>& entries)
{
bufferlist in;
cls_statelog_add_op call;
call.entries = entries;
::encode(call, in);
op.exec("statelog", "add", in);
}
void cls_statelog_add(librados::ObjectWriteOperation& op, cls_statelog_entry& entry)
{
bufferlist in;
cls_statelog_add_op call;
call.entries.push_back(entry);
::encode(call, in);
op.exec("statelog", "add", in);
}
void cls_statelog_add_prepare_entry(cls_statelog_entry& entry, const string& client_id, const string& op_id,
const string& object, const utime_t& timestamp, uint32_t state, bufferlist& bl)
{
entry.client_id = client_id;
entry.op_id = op_id;
entry.object = object;
entry.timestamp = timestamp;
entry.state = state;
entry.data = bl;
}
void cls_statelog_add(librados::ObjectWriteOperation& op, const string& client_id, const string& op_id,
const string& object, const utime_t& timestamp, uint32_t state, bufferlist& bl)
{
cls_statelog_entry entry;
cls_statelog_add_prepare_entry(entry, client_id, op_id, object, timestamp, state, bl);
cls_statelog_add(op, entry);
}
void cls_statelog_remove_by_client(librados::ObjectWriteOperation& op, const string& client_id, const string& op_id)
{
bufferlist in;
cls_statelog_remove_op call;
call.client_id = client_id;
call.op_id = op_id;
::encode(call, in);
op.exec("statelog", "remove", in);
}
void cls_statelog_remove_by_object(librados::ObjectWriteOperation& op, const string& object, const string& op_id)
{
bufferlist in;
cls_statelog_remove_op call;
call.object = object;
call.op_id = op_id;
::encode(call, in);
op.exec("statelog", "remove", in);
}
class StateLogListCtx : public ObjectOperationCompletion {
list<cls_statelog_entry> *entries;
string *marker;
bool *truncated;
public:
StateLogListCtx(list<cls_statelog_entry> *_entries, string *_marker, bool *_truncated) :
entries(_entries), marker(_marker), truncated(_truncated) {}
void handle_completion(int r, bufferlist& outbl) {
if (r >= 0) {
cls_statelog_list_ret ret;
try {
bufferlist::iterator iter = outbl.begin();
::decode(ret, iter);
if (entries)
*entries = ret.entries;
if (truncated)
*truncated = ret.truncated;
if (marker)
*marker = ret.marker;
} catch (buffer::error& err) {
// nothing we can do about it atm
}
}
}
};
void cls_statelog_list(librados::ObjectReadOperation& op,
const string& client_id, const string& op_id, const string& object, /* op_id may be empty, also one of client_id, object*/
const string& in_marker, int max_entries, list<cls_statelog_entry>& entries,
string *out_marker, bool *truncated)
{
bufferlist inbl;
cls_statelog_list_op call;
call.client_id = client_id;
call.op_id = op_id;
call.object = object;
call.marker = in_marker;
call.max_entries = max_entries;
::encode(call, inbl);
op.exec("statelog", "list", inbl, new StateLogListCtx(&entries, out_marker, truncated));
}
void cls_statelog_check_state(librados::ObjectOperation& op, const string& client_id, const string& op_id, const string& object, uint32_t state)
{
bufferlist inbl;
bufferlist outbl;
cls_statelog_check_state_op call;
call.client_id = client_id;
call.op_id = op_id;
call.object = object;
call.state = state;
::encode(call, inbl);
op.exec("statelog", "list", inbl, NULL);
}
|
