X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fcls%2Flog%2Fcls_log_client.cc;fp=src%2Fceph%2Fsrc%2Fcls%2Flog%2Fcls_log_client.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=0aa6e16d4a03508e621bdb91a9994c105e4d02ad;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/cls/log/cls_log_client.cc b/src/ceph/src/cls/log/cls_log_client.cc
deleted file mode 100644
index 0aa6e16..0000000
--- a/src/ceph/src/cls/log/cls_log_client.cc
+++ /dev/null
@@ -1,154 +0,0 @@
-#include <errno.h>
-
-#include "cls/log/cls_log_ops.h"
-#include "include/rados/librados.hpp"
-#include "include/compat.h"
-
-
-using namespace librados;
-
-
-
-void cls_log_add(librados::ObjectWriteOperation& op, list<cls_log_entry>& entries, bool monotonic_inc)
-{
-  bufferlist in;
-  cls_log_add_op call;
-  call.entries = entries;
-  ::encode(call, in);
-  op.exec("log", "add", in);
-}
-
-void cls_log_add(librados::ObjectWriteOperation& op, cls_log_entry& entry)
-{
-  bufferlist in;
-  cls_log_add_op call;
-  call.entries.push_back(entry);
-  ::encode(call, in);
-  op.exec("log", "add", in);
-}
-
-void cls_log_add_prepare_entry(cls_log_entry& entry, const utime_t& timestamp,
-                 const string& section, const string& name, bufferlist& bl)
-{
-  entry.timestamp = timestamp;
-  entry.section = section;
-  entry.name = name;
-  entry.data = bl;
-}
-
-void cls_log_add(librados::ObjectWriteOperation& op, const utime_t& timestamp,
-                 const string& section, const string& name, bufferlist& bl)
-{
-  cls_log_entry entry;
-
-  cls_log_add_prepare_entry(entry, timestamp, section, name, bl);
-  cls_log_add(op, entry);
-}
-
-void cls_log_trim(librados::ObjectWriteOperation& op, const utime_t& from_time, const utime_t& to_time,
-                  const string& from_marker, const string& to_marker)
-{
-  bufferlist in;
-  cls_log_trim_op call;
-  call.from_time = from_time;
-  call.to_time = to_time;
-  call.from_marker = from_marker;
-  call.to_marker = to_marker;
-  ::encode(call, in);
-  op.exec("log", "trim", in);
-}
-
-int cls_log_trim(librados::IoCtx& io_ctx, const string& oid, const utime_t& from_time, const utime_t& to_time,
-                 const string& from_marker, const string& to_marker)
-{
-  bool done = false;
-
-  do {
-    ObjectWriteOperation op;
-
-    cls_log_trim(op, from_time, to_time, from_marker, to_marker);
-
-    int r = io_ctx.operate(oid, &op);
-    if (r == -ENODATA)
-      done = true;
-    else if (r < 0)
-      return r;
-
-  } while (!done);
-
-
-  return 0;
-}
-
-class LogListCtx : public ObjectOperationCompletion {
-  list<cls_log_entry> *entries;
-  string *marker;
-  bool *truncated;
-public:
-  LogListCtx(list<cls_log_entry> *_entries, string *_marker, bool *_truncated) :
-                                      entries(_entries), marker(_marker), truncated(_truncated) {}
-  void handle_completion(int r, bufferlist& outbl) override {
-    if (r >= 0) {
-      cls_log_list_ret ret;
-      try {
-        bufferlist::iterator iter = outbl.begin();
-        ::decode(ret, iter);
-        if (entries)
-          *entries = std::move(ret.entries);
-        if (truncated)
-          *truncated = ret.truncated;
-        if (marker)
-          *marker = std::move(ret.marker);
-      } catch (buffer::error& err) {
-        // nothing we can do about it atm
-      }
-    }
-  }
-};
-
-void cls_log_list(librados::ObjectReadOperation& op, utime_t& from, utime_t& to,
-                  const string& in_marker, int max_entries,
-		  list<cls_log_entry>& entries,
-                  string *out_marker, bool *truncated)
-{
-  bufferlist inbl;
-  cls_log_list_op call;
-  call.from_time = from;
-  call.to_time = to;
-  call.marker = in_marker;
-  call.max_entries = max_entries;
-
-  ::encode(call, inbl);
-
-  op.exec("log", "list", inbl, new LogListCtx(&entries, out_marker, truncated));
-}
-
-class LogInfoCtx : public ObjectOperationCompletion {
-  cls_log_header *header;
-public:
-  explicit LogInfoCtx(cls_log_header *_header) : header(_header) {}
-  void handle_completion(int r, bufferlist& outbl) override {
-    if (r >= 0) {
-      cls_log_info_ret ret;
-      try {
-        bufferlist::iterator iter = outbl.begin();
-        ::decode(ret, iter);
-        if (header)
-	  *header = ret.header;
-      } catch (buffer::error& err) {
-        // nothing we can do about it atm
-      }
-    }
-  }
-};
-
-void cls_log_info(librados::ObjectReadOperation& op, cls_log_header *header)
-{
-  bufferlist inbl;
-  cls_log_info_op call;
-
-  ::encode(call, inbl);
-
-  op.exec("log", "info", inbl, new LogInfoCtx(header));
-}
-