From: Yehuda Sadeh Date: Thu, 18 May 2017 18:51:21 +0000 (-0700) Subject: rgw: replace reshard blocking sleep with interruptible condition wait X-Git-Tag: ses5-milestone6~8^2~7^2~13 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=f2b0eb08636f0ea055dd6cd94faf2065a9e14f9c;p=ceph.git rgw: replace reshard blocking sleep with interruptible condition wait Signed-off-by: Yehuda Sadeh --- diff --git a/src/rgw/rgw_reshard.cc b/src/rgw/rgw_reshard.cc index faa15080f2d7..a80291d09d10 100644 --- a/src/rgw/rgw_reshard.cc +++ b/src/rgw/rgw_reshard.cc @@ -243,7 +243,7 @@ int RGWBucketReshard::set_resharding_status(const string& new_instance_id, int32 int RGWBucketReshard::clear_resharding() { cls_rgw_bucket_instance_entry instance_entry; - + int ret = store->bucket_set_reshard(bucket_info, instance_entry); if (ret < 0) { ldout(store->ctx(), 0) << "RGWReshard::" << __func__ << " ERROR: error setting bucket resharding flag on bucket index: " @@ -710,7 +710,6 @@ int RGWReshardWait::block_while_resharding(RGWRados::BucketShard *bs, string *ne return -ERR_BUSY_RESHARDING; } - int RGWReshard::process_single_logshard(int logshard_num) { string marker; @@ -719,7 +718,7 @@ int RGWReshard::process_single_logshard(int logshard_num) CephContext *cct = store->ctx(); int max_entries = 1000; int max_secs = 60; - + rados::cls::lock::Lock l(reshard_lock_name); utime_t time(max_secs, 0);