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
147
148
149
150
151
152
153
154
155
156
157
158
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#include <errno.h>
#include <string>
#include <map>
#include <boost/algorithm/string.hpp>
#include "common/errno.h"
#include "common/Formatter.h"
#include "common/ceph_json.h"
#include "rgw_rados.h"
#include "rgw_zone.h"
#include "include/types.h"
#include "rgw_common.h"
#include "rgw_tools.h"
#include "services/svc_zone.h"
#define dout_subsys ceph_subsys_rgw
using namespace std;
static RGWMetadataHandler *otp_meta_handler = NULL;
class RGWOTPMetadataObject : public RGWMetadataObject {
list<rados::cls::otp::otp_info_t> result;
public:
RGWOTPMetadataObject(list<rados::cls::otp::otp_info_t>& _result, obj_version& v, real_time m) {
result.swap(_result);
objv = v;
mtime = m;
}
void dump(Formatter *f) const override {
encode_json("devices", result, f);
}
};
class RGWOTPMetadataHandler : public RGWMetadataHandler {
public:
string get_type() override { return "otp"; }
int get(RGWRados *store, string& entry, RGWMetadataObject **obj) override {
RGWObjVersionTracker objv_tracker;
real_time mtime;
list<rados::cls::otp::otp_info_t> result;
int r = store->list_mfa(entry, &result, &objv_tracker, &mtime);
if (r < 0) {
return r;
}
RGWOTPMetadataObject *mdo = new RGWOTPMetadataObject(result, objv_tracker.read_version, mtime);
*obj = mdo;
return 0;
}
int put(RGWRados *store, string& entry, RGWObjVersionTracker& objv_tracker,
real_time mtime, JSONObj *obj, sync_type_t sync_mode) override {
list<rados::cls::otp::otp_info_t> devices;
try {
JSONDecoder::decode_json("devices", devices, obj);
} catch (JSONDecoder::err& e) {
return -EINVAL;
}
int ret = store->meta_mgr->mutate(this, entry, mtime, &objv_tracker,
MDLOG_STATUS_WRITE, sync_mode,
[&] {
return store->set_mfa(entry, devices, true, &objv_tracker, mtime);
});
if (ret < 0) {
return ret;
}
return STATUS_APPLIED;
}
int remove(RGWRados *store, string& entry, RGWObjVersionTracker& objv_tracker) override {
return store->meta_mgr->remove_entry(this, entry, &objv_tracker);
}
void get_pool_and_oid(RGWRados *store, const string& key, rgw_pool& pool, string& oid) override {
oid = key;
pool = store->svc.zone->get_zone_params().otp_pool;
}
struct list_keys_info {
RGWRados *store;
RGWListRawObjsCtx ctx;
};
int list_keys_init(RGWRados *store, const string& marker, void **phandle) override
{
auto info = std::make_unique<list_keys_info>();
info->store = store;
int ret = store->list_raw_objects_init(store->svc.zone->get_zone_params().otp_pool, marker,
&info->ctx);
if (ret < 0) {
return ret;
}
*phandle = (void *)info.release();
return 0;
}
int list_keys_next(void *handle, int max, list<string>& keys, bool *truncated) override {
list_keys_info *info = static_cast<list_keys_info *>(handle);
string no_filter;
keys.clear();
RGWRados *store = info->store;
int ret = store->list_raw_objects_next(no_filter, max, info->ctx,
keys, truncated);
if (ret < 0 && ret != -ENOENT)
return ret;
if (ret == -ENOENT) {
if (truncated)
*truncated = false;
return 0;
}
return 0;
}
void list_keys_complete(void *handle) override {
list_keys_info *info = static_cast<list_keys_info *>(handle);
delete info;
}
string get_marker(void *handle) override {
list_keys_info *info = static_cast<list_keys_info *>(handle);
return info->store->list_raw_objs_get_cursor(info->ctx);
}
};
RGWMetadataHandler *rgw_otp_get_handler()
{
return otp_meta_handler;
}
void rgw_otp_init(RGWRados *store)
{
otp_meta_handler = new RGWOTPMetadataHandler;
store->meta_mgr->register_handler(otp_meta_handler);
}
|
