RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-25 03:52:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

cls/rbd: async methods for mirror_peer_list

Browse Source 
Signed-off-by: Mykola Golub <mgolub@suse.com>
This commit is contained in:
Mykola Golub 2019-10-10 16:14:46 +01:00
parent a5f4236a75
commit b78ebb3675
2 changed files with 27 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
src/cls/rbd/cls_rbd_client.cc
View File

@ -1810,22 +1810,37 @@ int mirror_mode_set(librados::IoCtx *ioctx,
return 0;
}
void mirror_peer_list_start(librados::ObjectReadOperation *op) {
bufferlist bl;
op->exec("rbd", "mirror_peer_list", bl);
}
int mirror_peer_list_finish(bufferlist::const_iterator *it,
std::vector<cls::rbd::MirrorPeer> *peers) {
peers->clear();
try {
decode(*peers, *it);
} catch (const buffer::error &err) {
return -EBADMSG;
}
return 0;
}
int mirror_peer_list(librados::IoCtx *ioctx,
std::vector<cls::rbd::MirrorPeer> *peers) {
bufferlist in_bl;
librados::ObjectReadOperation op;
mirror_peer_list_start(&op);
bufferlist out_bl;
int r = ioctx->exec(RBD_MIRRORING, "rbd", "mirror_peer_list", in_bl,
out_bl);
int r = ioctx->operate(RBD_MIRRORING, &op, &out_bl);
if (r < 0) {
return r;
}
peers->clear();
try {
auto bl_it = out_bl.cbegin();
decode(*peers, bl_it);
} catch (const buffer::error &err) {
return -EBADMSG;
auto it = out_bl.cbegin();
r = mirror_peer_list_finish(&it, peers);
if (r < 0) {
return r;
}
return 0;
}

3
src/cls/rbd/cls_rbd_client.h
View File

@ -388,6 +388,9 @@ int mirror_peer_ping(librados::IoCtx *ioctx,
void mirror_peer_ping(librados::ObjectWriteOperation *op,
const std::string& site_name,
const std::string& fsid);
void mirror_peer_list_start(librados::ObjectReadOperation *op);
int mirror_peer_list_finish(bufferlist::const_iterator *it,
std::vector<cls::rbd::MirrorPeer> *peers);
int mirror_peer_list(librados::IoCtx *ioctx,
std::vector<cls::rbd::MirrorPeer> *peers);
int mirror_peer_add(librados::IoCtx *ioctx,