]>
Commit | Line | Data |
---|---|---|
7c673cae FG |
1 | // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- |
2 | // vim: ts=8 sw=2 smarttab | |
3 | /* | |
4 | * Ceph - scalable distributed file system | |
5 | * | |
6 | * Copyright (C) 2013 eNovance SAS <licensing@enovance.com> | |
7 | * | |
8 | * This is free software; you can redistribute it and/or | |
9 | * modify it under the terms of the GNU Lesser General Public | |
10 | * License version 2.1, as published by the Free Software | |
11 | * Foundation. See file COPYING. | |
12 | * | |
13 | */ | |
14 | #include "common/ceph_json.h" | |
15 | #include "common/strtol.h" | |
16 | #include "rgw_rest.h" | |
17 | #include "rgw_op.h" | |
18 | #include "rgw_rest_s3.h" | |
19 | #include "rgw_rest_opstate.h" | |
20 | #include "rgw_client_io.h" | |
21 | #include "common/errno.h" | |
22 | #include "include/assert.h" | |
23 | ||
24 | #define dout_context g_ceph_context | |
25 | #define OPSTATE_LIST_MAX_ENTRIES 1000 | |
26 | #define dout_subsys ceph_subsys_rgw | |
27 | ||
28 | void RGWOp_Opstate_List::execute() { | |
29 | string client_id = s->info.args.get("client-id"), | |
30 | op_id = s->info.args.get("op-id"), | |
31 | object = s->info.args.get("object"), | |
32 | max_entries_str = s->info.args.get("max-entries"); | |
33 | unsigned max_entries = OPSTATE_LIST_MAX_ENTRIES; | |
34 | ||
35 | if (!max_entries_str.empty()) { | |
36 | string err; | |
37 | max_entries = (unsigned)strict_strtol(max_entries_str.c_str(), 10, &err); | |
38 | if (!err.empty()) { | |
39 | dout(5) << "Error parsing max-entries " << max_entries_str << dendl; | |
40 | http_ret = -EINVAL; | |
41 | return; | |
42 | } | |
43 | } | |
44 | ||
45 | RGWOpState oc = RGWOpState(store); | |
46 | void *handle; | |
47 | bool done; | |
48 | list<cls_statelog_entry> entries; | |
49 | ||
50 | oc.init_list_entries(client_id, op_id, object, &handle); | |
51 | ||
52 | http_ret = 0; | |
53 | send_response(); | |
54 | do { | |
55 | int ret = oc.list_entries(handle, max_entries, entries, &done); | |
56 | ||
57 | if (ret < 0) { | |
58 | dout(5) << "oc.list_entries failed with error " << ret << dendl; | |
59 | http_ret = ret; | |
60 | oc.finish_list_entries(handle); | |
61 | return; | |
62 | } | |
63 | ||
64 | if (!max_entries_str.empty()) | |
65 | max_entries -= entries.size(); | |
66 | ||
67 | send_response(entries); | |
68 | } while (!done && max_entries > 0); | |
69 | ||
70 | oc.finish_list_entries(handle); | |
71 | send_response_end(); | |
72 | } | |
73 | ||
74 | void RGWOp_Opstate_List::send_response() { | |
75 | if (sent_header) | |
76 | return; | |
77 | ||
78 | set_req_state_err(s, http_ret); | |
79 | dump_errno(s); | |
80 | end_header(s); | |
81 | ||
82 | sent_header = true; | |
83 | ||
84 | if (http_ret < 0) | |
85 | return; | |
86 | ||
87 | s->formatter->open_array_section("entries"); | |
88 | } | |
89 | ||
90 | void RGWOp_Opstate_List::send_response(list<cls_statelog_entry> entries) { | |
91 | RGWOpState oc(store); | |
92 | for (list<cls_statelog_entry>::iterator it = entries.begin(); | |
93 | it != entries.end(); ++it) { | |
94 | oc.dump_entry(*it, s->formatter); | |
95 | flusher.flush(); | |
96 | } | |
97 | } | |
98 | ||
99 | void RGWOp_Opstate_List::send_response_end() { | |
100 | s->formatter->close_section(); | |
101 | flusher.flush(); | |
102 | } | |
103 | ||
104 | void RGWOp_Opstate_Set::execute() { | |
105 | string client_id = s->info.args.get("client-id"), | |
106 | op_id = s->info.args.get("op-id"), | |
107 | object = s->info.args.get("object"), | |
108 | state_str = s->info.args.get("state"); | |
109 | ||
110 | if (client_id.empty() || | |
111 | op_id.empty() || | |
112 | object.empty() || | |
113 | state_str.empty()) { | |
114 | dout(5) << "Error - invalid parameter list" << dendl; | |
115 | http_ret = -EINVAL; | |
116 | return; | |
117 | } | |
118 | ||
119 | RGWOpState oc(store); | |
120 | RGWOpState::OpState state; | |
121 | ||
122 | http_ret = oc.state_from_str(state_str, &state); | |
123 | if (http_ret < 0) { | |
124 | dout(5) << "Error - invalid state" << dendl; | |
125 | return; | |
126 | } | |
127 | ||
128 | http_ret = oc.set_state(client_id, op_id, object, state); | |
129 | if (http_ret < 0) { | |
130 | dout(5) << "Error - Unable to set state" << dendl; | |
131 | return; | |
132 | } | |
133 | } | |
134 | ||
135 | void RGWOp_Opstate_Renew::execute() { | |
136 | string client_id = s->info.args.get("client-id"), | |
137 | op_id = s->info.args.get("op-id"), | |
138 | object = s->info.args.get("object"), | |
139 | state_str = s->info.args.get("state"); | |
140 | ||
141 | if (client_id.empty() || | |
142 | op_id.empty() || | |
143 | object.empty() || | |
144 | state_str.empty()) { | |
145 | dout(5) << "Error - invalid parameter list" << dendl; | |
146 | http_ret = -EINVAL; | |
147 | return; | |
148 | } | |
149 | RGWOpState oc(store); | |
150 | RGWOpState::OpState state; | |
151 | ||
152 | http_ret = oc.state_from_str(state_str, &state); | |
153 | if (http_ret < 0) { | |
154 | dout(5) << "Error - invalid state" << dendl; | |
155 | return; | |
156 | } | |
157 | ||
158 | http_ret = oc.renew_state(client_id, op_id, object, state); | |
159 | if (http_ret < 0) { | |
160 | dout(5) << "Error - Unable to renew state" << dendl; | |
161 | return; | |
162 | } | |
163 | } | |
164 | ||
165 | void RGWOp_Opstate_Delete::execute() { | |
166 | string client_id = s->info.args.get("client-id"), | |
167 | op_id = s->info.args.get("op-id"), | |
168 | object = s->info.args.get("object"); | |
169 | ||
170 | if (client_id.empty() || | |
171 | op_id.empty() || | |
172 | object.empty()) { | |
173 | dout(5) << "Error - invalid parameter list" << dendl; | |
174 | http_ret = -EINVAL; | |
175 | return; | |
176 | } | |
177 | ||
178 | RGWOpState oc(store); | |
179 | ||
180 | http_ret = oc.remove_entry(client_id, op_id, object); | |
181 | if (http_ret < 0) { | |
182 | dout(5) << "Error - Unable to remove entry" << dendl; | |
183 | } | |
184 | } | |
185 | ||
186 | RGWOp *RGWHandler_Opstate::op_post() { | |
187 | if (s->info.args.exists("renew")) { | |
188 | return new RGWOp_Opstate_Renew; | |
189 | } | |
190 | return new RGWOp_Opstate_Set; | |
191 | } |