cls/journal: async client_list method

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

diff --git a/src/cls/journal/cls_journal_client.cc b/src/cls/journal/cls_journal_client.cc
index 4ecaa879ed0a2a61577332e7ba6326079f77abb5..89baab8c698c8e75650a41dabef45f08d552f3fa 100644 (file)
--- a/src/cls/journal/cls_journal_client.cc
+++ b/src/cls/journal/cls_journal_client.cc
@@ -336,11 +336,16 @@ void client_commit(librados::ObjectWriteOperation *op, const std::string &id,
 int client_list(librados::IoCtx &ioctx, const std::string &oid,
                 std::set<cls::journal::Client> *clients) {
   C_SaferCond cond;
-  C_ClientList *client_list = new C_ClientList(ioctx, oid, clients, &cond);
-  client_list->send("");
+  client_list(ioctx, oid, clients, &cond);
   return cond.wait();
 }
 
+void client_list(librados::IoCtx &ioctx, const std::string &oid,
+                 std::set<cls::journal::Client> *clients, Context *on_finish) {
+  C_ClientList *client_list = new C_ClientList(ioctx, oid, clients, on_finish);
+  client_list->send("");
+}
+
 int get_next_tag_tid(librados::IoCtx &ioctx, const std::string &oid,
                      uint64_t *tag_tid) {
   librados::ObjectReadOperation op;

diff --git a/src/cls/journal/cls_journal_client.h b/src/cls/journal/cls_journal_client.h
index 9d41d405e7ab2e69f035a627e986a9c69b4033c0..477254f32687e2ce20341f142a077160b6ae81e1 100644 (file)
--- a/src/cls/journal/cls_journal_client.h
+++ b/src/cls/journal/cls_journal_client.h
@@ -67,6 +67,8 @@ void client_commit(librados::ObjectWriteOperation *op, const std::string &id,
 
 int client_list(librados::IoCtx &ioctx, const std::string &oid,
                 std::set<cls::journal::Client> *clients);
+void client_list(librados::IoCtx &ioctx, const std::string &oid,
+                 std::set<cls::journal::Client> *clients, Context *on_finish);
 
 // journal tag helpers
 int get_next_tag_tid(librados::IoCtx &ioctx, const std::string &oid,