cls/rbd: provide async version of copyup method

Signed-off-by: Mykola Golub <mgolub@suse.com>

diff --git a/src/cls/rbd/cls_rbd_client.cc b/src/cls/rbd/cls_rbd_client.cc
index 1e03fbce01bc9736d198cba3e8502dd860afde2a..4f2b3f510aac6d0271f26bcaec97fe44484cb0ab 100644 (file)
--- a/src/cls/rbd/cls_rbd_client.cc
+++ b/src/cls/rbd/cls_rbd_client.cc
@@ -833,10 +833,16 @@ int get_all_features(librados::IoCtx *ioctx, const std::string &oid,
   return get_all_features_finish(&it, all_features);
 }
 
+void copyup(librados::ObjectWriteOperation *op, bufferlist data) {
+  op->exec("rbd", "copyup", data);
+}
+
 int copyup(librados::IoCtx *ioctx, const std::string &oid,
            bufferlist data) {
-  bufferlist out;
-  return ioctx->exec(oid, "rbd", "copyup", data, out);
+  librados::ObjectWriteOperation op;
+  copyup(&op, data);
+
+  return ioctx->operate(oid, &op);
 }
 
 void sparse_copyup(librados::ObjectWriteOperation *op,

diff --git a/src/cls/rbd/cls_rbd_client.h b/src/cls/rbd/cls_rbd_client.h
index d9a01acd110559c93b8f5cfbec76184bf9cb5157..3ff6f32caa30b25b79c549e08e46cce2579d6445 100644 (file)
--- a/src/cls/rbd/cls_rbd_client.h
+++ b/src/cls/rbd/cls_rbd_client.h
@@ -597,6 +597,7 @@ void assert_snapc_seq(librados::ObjectWriteOperation *op,
                       uint64_t snapc_seq,
                       cls::rbd::AssertSnapcSeqState state);
 
+void copyup(librados::ObjectWriteOperation *op, bufferlist data);
 int copyup(librados::IoCtx *ioctx, const std::string &oid,
            bufferlist data);