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

cls_rgw: call ioctx->aio_operate() under lock

Browse Source 
close a race window

Signed-off-by: Yehuda Sadeh <yehuda@redhat.com>
This commit is contained in:
Yehuda Sadeh 2015-01-12 08:55:35 -08:00
parent 9d17bd0a6e
commit d19a49d332
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/cls/rgw/cls_rgw_client.h
View File

@ -61,7 +61,6 @@ private:
* track the object id per callback.
*/
void add_pending(int id, librados::AioCompletion* completion, string *oid = NULL) {
Mutex::Locker l(lock);
pendings[id] = completion;
if (oid) {
pending_objs[id] = *oid;
@ -96,6 +95,7 @@ public:
* Do aio read operation.
*/
bool aio_operate(librados::IoCtx& io_ctx, const string& oid, librados::ObjectReadOperation *op) {
Mutex::Locker l(lock);
BucketIndexAioArg *arg = new BucketIndexAioArg(get_next(), this);
librados::AioCompletion *c = librados::Rados::aio_create_completion((void*)arg, NULL, bucket_index_op_completion_cb);
int r = io_ctx.aio_operate(oid, c, (librados::ObjectReadOperation*)op, NULL);
@ -109,6 +109,7 @@ public:
* Do aio write operation.
*/
bool aio_operate(librados::IoCtx& io_ctx, const string& oid, librados::ObjectWriteOperation *op) {
Mutex::Locker l(lock);
BucketIndexAioArg *arg = new BucketIndexAioArg(get_next(), this);
librados::AioCompletion *c = librados::Rados::aio_create_completion((void*)arg, NULL, bucket_index_op_completion_cb);
int r = io_ctx.aio_operate(oid, c, (librados::ObjectWriteOperation*)op);