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

rgw: return errors from RGWInitBucketShardSyncStatusCoroutine

Browse Source 
return ENOENT so caller can detect whether sync is stopped

Signed-off-by: Casey Bodley <cbodley@redhat.com>
This commit is contained in:
Casey Bodley 2018-08-14 13:06:50 -04:00
parent 038b95da83
commit 72ac0aa1bb
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/rgw/rgw_data_sync.cc
View File

@ -1,3 +1,6 @@
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#include <boost/utility/string_ref.hpp>
#include "common/ceph_json.h"
@ -1996,6 +1999,12 @@ public:
call(new RGWSimpleRadosWriteAttrsCR(sync_env->async_rados, store, obj, attrs));
}
}
if (info.syncstopped) {
retcode = -ENOENT;
}
if (retcode < 0) {
return set_cr_error(retcode);
}
return set_cr_done();
}
return 0;
@ -3220,6 +3229,12 @@ int RGWRunBucketSyncCoroutine::operate()
if (sync_status.state == rgw_bucket_shard_sync_info::StateInit) {
yield call(new RGWInitBucketShardSyncStatusCoroutine(sync_env, bs, sync_status));
if (retcode == -ENOENT) {
tn->log(0, "bucket sync disabled");
lease_cr->go_down();
drain_all();
return set_cr_done();
}
if (retcode < 0) {
tn->log(0, SSTR("ERROR: init sync on bucket failed, retcode=" << retcode));
lease_cr->go_down();