From: Mykola Golub Date: Wed, 31 Aug 2016 19:27:53 +0000 (+0300) Subject: cls/journal: async client_list method X-Git-Tag: v11.0.1~77^2~12 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=ac25cb19466fb358f0dc685be10a083c8cd3ea6d;p=ceph.git cls/journal: async client_list method Signed-off-by: Mykola Golub --- diff --git a/src/cls/journal/cls_journal_client.cc b/src/cls/journal/cls_journal_client.cc index 4ecaa879ed0a..89baab8c698c 100644 --- 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 *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 *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 9d41d405e7ab..477254f32687 100644 --- 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 *clients); +void client_list(librados::IoCtx &ioctx, const std::string &oid, + std::set *clients, Context *on_finish); // journal tag helpers int get_next_tag_tid(librados::IoCtx &ioctx, const std::string &oid,