From: Samuel Just <sjust@redhat.com>
Date: Wed, 6 May 2015 17:54:31 +0000 (-0700)
Subject: OSD: add remove_wq suicide timeout
X-Git-Tag: v9.0.2~188^2~1
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=f2fbfa32a16666be46359f0eab7b04ca80a753f5;p=ceph.git

OSD: add remove_wq suicide timeout

Signed-off-by: Samuel Just <sjust@redhat.com>
---

diff --git a/src/common/config_opts.h b/src/common/config_opts.h
index c7ed2234a06..e7c26122918 100644
--- a/src/common/config_opts.h
+++ b/src/common/config_opts.h
@@ -594,6 +594,7 @@ OPTION(osd_scrub_thread_suicide_timeout, OPT_INT, 60)
 OPTION(osd_scrub_finalize_thread_timeout, OPT_INT, 60*10)
 OPTION(osd_scrub_invalid_stats, OPT_BOOL, true)
 OPTION(osd_remove_thread_timeout, OPT_INT, 60*60)
+OPTION(osd_remove_thread_suicide_timeout, OPT_INT, 10*60*60)
 OPTION(osd_command_thread_timeout, OPT_INT, 10*60)
 OPTION(osd_command_thread_suicide_timeout, OPT_INT, 15*60)
 OPTION(osd_heartbeat_addr, OPT_ADDR, entity_addr_t())
diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index ac6eb0471d4..1c2b2edc04e 100644
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -1542,7 +1542,11 @@ OSD::OSD(CephContext *cct_, ObjectStore *store_,
     cct->_conf->osd_scrub_thread_timeout,
     cct->_conf->osd_scrub_thread_suicide_timeout,
     &disk_tp),
-  remove_wq(store, cct->_conf->osd_remove_thread_timeout, &disk_tp),
+  remove_wq(
+    store,
+    cct->_conf->osd_remove_thread_timeout,
+    cct->_conf->osd_remove_thread_suicide_timeout,
+    &disk_tp),
   service(this)
 {
   monc->set_messenger(client_messenger);
diff --git a/src/osd/OSD.h b/src/osd/OSD.h
index 8b05f8a0d5f..7c5f05b16c9 100644
--- a/src/osd/OSD.h
+++ b/src/osd/OSD.h
@@ -2227,9 +2227,9 @@ protected:
     public ThreadPool::WorkQueueVal<pair<PGRef, DeletingStateRef> > {
     ObjectStore *&store;
     list<pair<PGRef, DeletingStateRef> > remove_queue;
-    RemoveWQ(ObjectStore *&o, time_t ti, ThreadPool *tp)
+    RemoveWQ(ObjectStore *&o, time_t ti, time_t si, ThreadPool *tp)
       : ThreadPool::WorkQueueVal<pair<PGRef, DeletingStateRef> >(
-	"OSD::RemoveWQ", ti, 0, tp),
+	"OSD::RemoveWQ", ti, si, tp),
 	store(o) {}
 
     bool _empty() {