From: Samuel Just <sjust@redhat.com>
Date: Wed, 6 May 2015 17:49:00 +0000 (-0700)
Subject: OSD: add command_wq suicide timeout
X-Git-Tag: v0.80.11~2^2~6
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=f85ec2a52e969f9a7927d0cfacda6a1cc6f2898c;p=ceph.git

OSD: add command_wq suicide timeout

Signed-off-by: Samuel Just <sjust@redhat.com>
(cherry picked from commit df4e5de819c30003cfbe50a071c49039cf534419)

Conflicts:
	src/common/config_opts.h
           place OPTION(osd_command_thread_suicide_timeout, ...)
           directly after OPTION(osd_command_thread_timeout, ...)
---

diff --git a/src/common/config_opts.h b/src/common/config_opts.h
index 527b2806e33..5ca307102d5 100644
--- a/src/common/config_opts.h
+++ b/src/common/config_opts.h
@@ -484,6 +484,7 @@ 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_command_thread_timeout, OPT_INT, 10*60)
+OPTION(osd_command_thread_suicide_timeout, OPT_INT, 15*60)
 OPTION(osd_age, OPT_FLOAT, .8)
 OPTION(osd_age_time, OPT_INT, 0)
 OPTION(osd_heartbeat_addr, OPT_ADDR, entity_addr_t())
diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index d2c0a341ab8..6fbc7d89997 100644
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -953,7 +953,11 @@ OSD::OSD(CephContext *cct_, ObjectStore *store_,
   pg_stat_queue_lock("OSD::pg_stat_queue_lock"),
   osd_stat_updated(false),
   pg_stat_tid(0), pg_stat_tid_flushed(0),
-  command_wq(this, cct->_conf->osd_command_thread_timeout, &command_tp),
+  command_wq(
+    this,
+    cct->_conf->osd_command_thread_timeout,
+    cct->_conf->osd_command_thread_suicide_timeout,
+    &command_tp),
   recovery_ops_active(0),
   recovery_wq(this, cct->_conf->osd_recovery_thread_timeout, &recovery_tp),
   replay_queue_lock("OSD::replay_queue_lock"),
diff --git a/src/osd/OSD.h b/src/osd/OSD.h
index daa18ca5e0c..26474e4cd09 100644
--- a/src/osd/OSD.h
+++ b/src/osd/OSD.h
@@ -1599,8 +1599,8 @@ protected:
   list<Command*> command_queue;
   struct CommandWQ : public ThreadPool::WorkQueue<Command> {
     OSD *osd;
-    CommandWQ(OSD *o, time_t ti, ThreadPool *tp)
-      : ThreadPool::WorkQueue<Command>("OSD::CommandWQ", ti, 0, tp), osd(o) {}
+    CommandWQ(OSD *o, time_t ti, time_t si, ThreadPool *tp)
+      : ThreadPool::WorkQueue<Command>("OSD::CommandWQ", ti, si, tp), osd(o) {}
 
     bool _empty() {
       return osd->command_queue.empty();