From: Yehuda Sadeh <yehuda@redhat.com>
Date: Thu, 27 Aug 2015 20:35:07 +0000 (-0700)
Subject: rgw: lock obj expirer shards when processing
X-Git-Tag: v9.1.0~229^2~3
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=9db8122680e7a641c06c09c6a42da8cc870194a6;p=ceph.git

rgw: lock obj expirer shards when processing

to prevent multiple rgws processing the same shard concurrently

Signed-off-by: Yehuda Sadeh <yehuda@redhat.com>
---

diff --git a/src/rgw/rgw_object_expirer_core.cc b/src/rgw/rgw_object_expirer_core.cc
index 3c12ca6c1505..2dee9bb011a1 100644
--- a/src/rgw/rgw_object_expirer_core.cc
+++ b/src/rgw/rgw_object_expirer_core.cc
@@ -33,8 +33,12 @@ using namespace std;
 #include "rgw_replica_log.h"
 #include "rgw_object_expirer_core.h"
 
+#include "cls/lock/cls_lock_client.h"
+
 #define dout_subsys ceph_subsys_rgw
 
+static string objexp_lock_name = "gc_process";
+
 int RGWObjectExpirer::init_bucket_info(const string& bucket_name,
                                     const string& bucket_id,
                                     RGWBucketInfo& bucket_info)
@@ -132,9 +136,23 @@ void RGWObjectExpirer::proceed_single_shard(const string& shard,
   CephContext *cct = store->ctx();
   int num_entries = cct->_conf->rgw_objexp_chunk_size;
 
+  int max_secs = cct->_conf->rgw_objexp_gc_interval;
+  utime_t end = ceph_clock_now(cct);
+  end += max_secs;
+
+  rados::cls::lock::Lock l(objexp_lock_name);
+
+  utime_t time(max_secs, 0);
+  l.set_duration(time);
+
+  int ret = l.lock_exclusive(&store->objexp_pool_ctx, shard);
+  if (ret == -EBUSY) { /* already locked by another processor */
+    dout(5) << __func__ << "(): failed to acquire lock on " << shard << dendl;
+    return;
+  }
   do {
     list<cls_timeindex_entry> entries;
-    int ret = store->objexp_hint_list(shard, last_run, round_start,
+    ret = store->objexp_hint_list(shard, last_run, round_start,
                                       num_entries, marker, entries,
                                       &out_marker, &truncated);
     if (ret < 0) {
@@ -149,9 +167,15 @@ void RGWObjectExpirer::proceed_single_shard(const string& shard,
       trim_chunk(shard, last_run, round_start);
     }
 
+    utime_t now = ceph_clock_now(g_ceph_context);
+    if (now >= end) {
+      break;
+    }
+
     marker = out_marker;
   } while (truncated);
 
+  l.unlock(&store->objexp_pool_ctx, shard);
   return;
 }
 
diff --git a/src/rgw/rgw_rados.h b/src/rgw/rgw_rados.h
index 791fa9ce1a06..121bfa58c22c 100644
--- a/src/rgw/rgw_rados.h
+++ b/src/rgw/rgw_rados.h
@@ -1199,6 +1199,7 @@ class Finisher;
 class RGWRados
 {
   friend class RGWGC;
+  friend class RGWObjectExpirer;
   friend class RGWStateLog;
   friend class RGWReplicaLogger;