+++ /dev/null
-// -*- 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) 2013 eNovance SAS <licensing@enovance.com>
- *
- * 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.
- *
- */
-#include "common/ceph_json.h"
-#include "common/strtol.h"
-#include "rgw_rest.h"
-#include "rgw_op.h"
-#include "rgw_rest_s3.h"
-#include "rgw_rest_opstate.h"
-#include "rgw_client_io.h"
-#include "common/errno.h"
-#include "include/assert.h"
-
-#define dout_context g_ceph_context
-#define OPSTATE_LIST_MAX_ENTRIES 1000
-#define dout_subsys ceph_subsys_rgw
-
-void RGWOp_Opstate_List::execute() {
- string client_id = s->info.args.get("client-id"),
- op_id = s->info.args.get("op-id"),
- object = s->info.args.get("object"),
- max_entries_str = s->info.args.get("max-entries");
- unsigned max_entries = OPSTATE_LIST_MAX_ENTRIES;
-
- if (!max_entries_str.empty()) {
- string err;
- max_entries = (unsigned)strict_strtol(max_entries_str.c_str(), 10, &err);
- if (!err.empty()) {
- dout(5) << "Error parsing max-entries " << max_entries_str << dendl;
- http_ret = -EINVAL;
- return;
- }
- }
-
- RGWOpState oc = RGWOpState(store);
- void *handle;
- bool done;
- list<cls_statelog_entry> entries;
-
- oc.init_list_entries(client_id, op_id, object, &handle);
-
- http_ret = 0;
- send_response();
- do {
- int ret = oc.list_entries(handle, max_entries, entries, &done);
-
- if (ret < 0) {
- dout(5) << "oc.list_entries failed with error " << ret << dendl;
- http_ret = ret;
- oc.finish_list_entries(handle);
- return;
- }
-
- if (!max_entries_str.empty())
- max_entries -= entries.size();
-
- send_response(entries);
- } while (!done && max_entries > 0);
-
- oc.finish_list_entries(handle);
- send_response_end();
-}
-
-void RGWOp_Opstate_List::send_response() {
- if (sent_header)
- return;
-
- set_req_state_err(s, http_ret);
- dump_errno(s);
- end_header(s);
-
- sent_header = true;
-
- if (http_ret < 0)
- return;
-
- s->formatter->open_array_section("entries");
-}
-
-void RGWOp_Opstate_List::send_response(list<cls_statelog_entry> entries) {
- RGWOpState oc(store);
- for (list<cls_statelog_entry>::iterator it = entries.begin();
- it != entries.end(); ++it) {
- oc.dump_entry(*it, s->formatter);
- flusher.flush();
- }
-}
-
-void RGWOp_Opstate_List::send_response_end() {
- s->formatter->close_section();
- flusher.flush();
-}
-
-void RGWOp_Opstate_Set::execute() {
- string client_id = s->info.args.get("client-id"),
- op_id = s->info.args.get("op-id"),
- object = s->info.args.get("object"),
- state_str = s->info.args.get("state");
-
- if (client_id.empty() ||
- op_id.empty() ||
- object.empty() ||
- state_str.empty()) {
- dout(5) << "Error - invalid parameter list" << dendl;
- http_ret = -EINVAL;
- return;
- }
-
- RGWOpState oc(store);
- RGWOpState::OpState state;
-
- http_ret = oc.state_from_str(state_str, &state);
- if (http_ret < 0) {
- dout(5) << "Error - invalid state" << dendl;
- return;
- }
-
- http_ret = oc.set_state(client_id, op_id, object, state);
- if (http_ret < 0) {
- dout(5) << "Error - Unable to set state" << dendl;
- return;
- }
-}
-
-void RGWOp_Opstate_Renew::execute() {
- string client_id = s->info.args.get("client-id"),
- op_id = s->info.args.get("op-id"),
- object = s->info.args.get("object"),
- state_str = s->info.args.get("state");
-
- if (client_id.empty() ||
- op_id.empty() ||
- object.empty() ||
- state_str.empty()) {
- dout(5) << "Error - invalid parameter list" << dendl;
- http_ret = -EINVAL;
- return;
- }
- RGWOpState oc(store);
- RGWOpState::OpState state;
-
- http_ret = oc.state_from_str(state_str, &state);
- if (http_ret < 0) {
- dout(5) << "Error - invalid state" << dendl;
- return;
- }
-
- http_ret = oc.renew_state(client_id, op_id, object, state);
- if (http_ret < 0) {
- dout(5) << "Error - Unable to renew state" << dendl;
- return;
- }
-}
-
-void RGWOp_Opstate_Delete::execute() {
- string client_id = s->info.args.get("client-id"),
- op_id = s->info.args.get("op-id"),
- object = s->info.args.get("object");
-
- if (client_id.empty() ||
- op_id.empty() ||
- object.empty()) {
- dout(5) << "Error - invalid parameter list" << dendl;
- http_ret = -EINVAL;
- return;
- }
-
- RGWOpState oc(store);
-
- http_ret = oc.remove_entry(client_id, op_id, object);
- if (http_ret < 0) {
- dout(5) << "Error - Unable to remove entry" << dendl;
- }
-}
-
-RGWOp *RGWHandler_Opstate::op_post() {
- if (s->info.args.exists("renew")) {
- return new RGWOp_Opstate_Renew;
- }
- return new RGWOp_Opstate_Set;
-}