remove ceph code

[stor4nfv.git] / src / ceph / src / cls / user / cls_user_client.cc

diff --git a/src/ceph/src/cls/user/cls_user_client.cc b/src/ceph/src/cls/user/cls_user_client.cc
deleted file mode 100644 (file)
index c77075d..0000000
--- a/src/ceph/src/cls/user/cls_user_client.cc
+++ /dev/null
@@ -1,149 +0,0 @@
-// -*- mode:C; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#include <errno.h>
-
-#include "cls/user/cls_user_client.h"
-#include "include/rados/librados.hpp"
-
-
-using namespace librados;
-
-
-void cls_user_set_buckets(librados::ObjectWriteOperation& op, list<cls_user_bucket_entry>& entries, bool add)
-{
-  bufferlist in;
-  cls_user_set_buckets_op call;
-  call.entries = entries;
-  call.add = add;
-  call.time = real_clock::now();
-  ::encode(call, in);
-  op.exec("user", "set_buckets_info", in);
-}
-
-void cls_user_complete_stats_sync(librados::ObjectWriteOperation& op)
-{
-  bufferlist in;
-  cls_user_complete_stats_sync_op call;
-  call.time = real_clock::now();
-  ::encode(call, in);
-  op.exec("user", "complete_stats_sync", in);
-}
-
-void cls_user_remove_bucket(librados::ObjectWriteOperation& op, const cls_user_bucket& bucket)
-{
-  bufferlist in;
-  cls_user_remove_bucket_op call;
-  call.bucket = bucket;
-  ::encode(call, in);
-  op.exec("user", "remove_bucket", in);
-}
-
-class ClsUserListCtx : public ObjectOperationCompletion {
-  list<cls_user_bucket_entry> *entries;
-  string *marker;
-  bool *truncated;
-  int *pret;
-public:
-  ClsUserListCtx(list<cls_user_bucket_entry> *_entries, string *_marker, bool *_truncated, int *_pret) :
-                                      entries(_entries), marker(_marker), truncated(_truncated), pret(_pret) {}
-  void handle_completion(int r, bufferlist& outbl) override {
-    if (r >= 0) {
-      cls_user_list_buckets_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) {
-        r = -EIO;
-      }
-    }
-    if (pret) {
-      *pret = r;
-    }
-  }
-};
-
-void cls_user_bucket_list(librados::ObjectReadOperation& op,
-                          const string& in_marker,
-                          const string& end_marker,
-                          int max_entries,
-                          list<cls_user_bucket_entry>& entries,
-                          string *out_marker,
-                          bool *truncated,
-                          int *pret)
-{
-  bufferlist inbl;
-  cls_user_list_buckets_op call;
-  call.marker = in_marker;
-  call.end_marker = end_marker;
-  call.max_entries = max_entries;
-
-  ::encode(call, inbl);
-
-  op.exec("user", "list_buckets", inbl, new ClsUserListCtx(&entries, out_marker, truncated, pret));
-}
-
-class ClsUserGetHeaderCtx : public ObjectOperationCompletion {
-  cls_user_header *header;
-  RGWGetUserHeader_CB *ret_ctx;
-  int *pret;
-public:
-  ClsUserGetHeaderCtx(cls_user_header *_h, RGWGetUserHeader_CB *_ctx, int *_pret) : header(_h), ret_ctx(_ctx), pret(_pret) {}
-  ~ClsUserGetHeaderCtx() override {
-    if (ret_ctx) {
-      ret_ctx->put();
-    }
-  }
-  void handle_completion(int r, bufferlist& outbl) override {
-    if (r >= 0) {
-      cls_user_get_header_ret ret;
-      try {
-        bufferlist::iterator iter = outbl.begin();
-        ::decode(ret, iter);
-        if (header)
-         *header = ret.header;
-      } catch (buffer::error& err) {
-        r = -EIO;
-      }
-      if (ret_ctx) {
-        ret_ctx->handle_response(r, ret.header);
-      }
-    }
-    if (pret) {
-      *pret = r;
-    }
-  }
-};
-
-void cls_user_get_header(librados::ObjectReadOperation& op,
-                       cls_user_header *header, int *pret)
-{
-  bufferlist inbl;
-  cls_user_get_header_op call;
-
-  ::encode(call, inbl);
-
-  op.exec("user", "get_header", inbl, new ClsUserGetHeaderCtx(header, NULL, pret));
-}
-
-int cls_user_get_header_async(IoCtx& io_ctx, string& oid, RGWGetUserHeader_CB *ctx)
-{
-  bufferlist in, out;
-  cls_user_get_header_op call;
-  ::encode(call, in);
-  ObjectReadOperation op;
-  op.exec("user", "get_header", in, new ClsUserGetHeaderCtx(NULL, ctx, NULL)); /* no need to pass pret, as we'll call ctx->handle_response() with correct error */
-  AioCompletion *c = librados::Rados::aio_create_completion(NULL, NULL, NULL);
-  int r = io_ctx.aio_operate(oid, c, &op, NULL);
-  c->release();
-  if (r < 0)
-    return r;
-
-  return 0;
-}