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

diff --git a/src/ceph/src/cls/replica_log/cls_replica_log.cc b/src/ceph/src/cls/replica_log/cls_replica_log.cc
deleted file mode 100644
index e8ae3bc..0000000
--- a/src/ceph/src/cls/replica_log/cls_replica_log.cc
+++ /dev/null
@@ -1,150 +0,0 @@
-/*
- * Ceph - scalable distributed file system
- *
- * 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.
- * 
- * Copyright Inktank 2013
- */
-
-#include "objclass/objclass.h"
-
-#include "cls_replica_log_types.h"
-#include "cls_replica_log_ops.h"
-
-CLS_VER(1, 0)
-CLS_NAME(replica_log)
-
-static const string replica_log_prefix = "rl_";
-static const string replica_log_bounds = replica_log_prefix + "bounds";
-
-static int get_bounds(cls_method_context_t hctx, cls_replica_log_bound& bound)
-{
-  bufferlist bounds_bl;
-  int rc = cls_cxx_map_get_val(hctx, replica_log_bounds, &bounds_bl);
-  if (rc < 0) {
-    return rc;
-  }
-
-  try {
-    bufferlist::iterator bounds_bl_i = bounds_bl.begin();
-    ::decode(bound, bounds_bl_i);
-  } catch (buffer::error& err) {
-    bound = cls_replica_log_bound();
-    CLS_LOG(0, "ERROR: get_bounds(): failed to decode on-disk bounds object");
-    return -EIO;
-  }
-
-  return 0;
-}
-
-static int write_bounds(cls_method_context_t hctx,
-                        const cls_replica_log_bound& bound)
-{
-  bufferlist bounds_bl;
-  ::encode(bound, bounds_bl);
-  return cls_cxx_map_set_val(hctx, replica_log_bounds, &bounds_bl);
-}
-
-static int cls_replica_log_set(cls_method_context_t hctx,
-                               bufferlist *in, bufferlist *out)
-{
-  bufferlist::iterator in_iter = in->begin();
-
-  cls_replica_log_set_marker_op op;
-  try {
-    ::decode(op, in_iter);
-  } catch (buffer::error& err) {
-    CLS_LOG(0, "ERROR: cls_replica_log_set(): failed to decode op");
-    return -EINVAL;
-  }
-
-  cls_replica_log_bound bound;
-  int rc = get_bounds(hctx, bound);
-  if (rc < 0 && rc != -ENOENT) {
-    return rc;
-  }
-
-  rc = bound.update_marker(op.marker);
-  if (rc < 0) {
-    return rc;
-  }
-
-  return write_bounds(hctx, bound);
-}
-
-static int cls_replica_log_delete(cls_method_context_t hctx,
-                                  bufferlist *in, bufferlist *out)
-{
-  bufferlist::iterator in_iter = in->begin();
-
-  cls_replica_log_delete_marker_op op;
-  try {
-    ::decode(op, in_iter);
-  } catch (buffer::error& err) {
-    CLS_LOG(0, "ERROR: cls_replica_log_delete(): failed to decode op");
-    return -EINVAL;
-  }
-
-  cls_replica_log_bound bound;
-  int rc = get_bounds(hctx, bound);
-  if (rc < 0 && rc != -ENOENT) {
-    return rc;
-  }
-
-  rc = bound.delete_marker(op.entity_id);
-  if (rc < 0) {
-    return rc;
-  }
-
-  return write_bounds(hctx, bound);
-}
-
-static int cls_replica_log_get(cls_method_context_t hctx,
-                               bufferlist *in, bufferlist *out)
-{
-  bufferlist::iterator in_iter = in->begin();
-
-  cls_replica_log_get_bounds_op op;
-  try {
-    ::decode(op, in_iter);
-  } catch (buffer::error& err) {
-    CLS_LOG(0, "ERROR: cls_replica_log_get(): failed to decode op");
-    return -EINVAL;
-  }
-
-  cls_replica_log_bound bound;
-  int rc = get_bounds(hctx, bound);
-  if (rc < 0) {
-    return rc;
-  }
-
-  cls_replica_log_get_bounds_ret ret;
-  ret.oldest_time = bound.get_oldest_time();
-  ret.position_marker = bound.get_lowest_marker_bound();
-  bound.get_markers(ret.markers);
-
-  ::encode(ret, *out);
-  return 0;
-}
-
-CLS_INIT(replica_log)
-{
-  CLS_LOG(1, "Loaded replica log class!");
-
-  cls_handle_t h_class;
-  cls_method_handle_t h_replica_log_set;
-  cls_method_handle_t h_replica_log_delete;
-  cls_method_handle_t h_replica_log_get;
-
-  cls_register("replica_log", &h_class);
-
-  cls_register_cxx_method(h_class, "set", CLS_METHOD_RD | CLS_METHOD_WR,
-                          cls_replica_log_set, &h_replica_log_set);
-  cls_register_cxx_method(h_class, "get", CLS_METHOD_RD,
-                          cls_replica_log_get, &h_replica_log_get);
-  cls_register_cxx_method(h_class, "delete", CLS_METHOD_RD | CLS_METHOD_WR,
-                          cls_replica_log_delete, &h_replica_log_delete);
-}