From b2536cf67cbd960d260c564a7bc5d7643d25e2f7 Mon Sep 17 00:00:00 2001
From: Adam <shmali81@gmail.com>
Date: Fri, 22 Apr 2016 14:57:11 -0500
Subject: [PATCH 1/2] Add support for grouping cluster restarts

---
 lib/thin/controllers/cluster.rb | 38 +++++++++++++++++++++++++++------
 lib/thin/runner.rb              |  1 +
 lib/thin/version.rb             |  2 +-
 3 files changed, 33 insertions(+), 8 deletions(-)

diff --git a/lib/thin/controllers/cluster.rb b/lib/thin/controllers/cluster.rb
index 33692c11..1afae52c 100644
--- a/lib/thin/controllers/cluster.rb
+++ b/lib/thin/controllers/cluster.rb
@@ -12,7 +12,7 @@ module Controllers
     class Cluster < Controller
       # Cluster only options that should not be passed in the command sent
       # to the indiviual servers.
-      CLUSTER_OPTIONS = [:servers, :only, :onebyone, :wait]
+      CLUSTER_OPTIONS = [:servers, :only, :onebyone, :xbyx, :wait]
       
       # Maximum wait time for the server to be restarted
       DEFAULT_WAIT_TIME = 30    # seconds
@@ -32,6 +32,7 @@ def log_file;   @options[:log]      end
       def size;       @options[:servers]  end
       def only;       @options[:only]     end
       def onebyone;   @options[:onebyone] end
+      def xbyx;       @options[:xbyx]     end
       def wait;       @options[:wait]     end
       
       def swiftiply?
@@ -64,18 +65,41 @@ def stop_server(number)
     
       # Stop and start the servers.
       def restart
-        unless onebyone
-          # Let's do a normal restart by defaults
-          stop
-          sleep 0.1 # Let's breath a bit shall we ?
-          start
-        else
+        if onebyone
+          #Stop/Start each server, on by one
           with_each_server do |n| 
             stop_server(n)
             sleep 0.1 # Let's breath a bit shall we ?
             start_server(n)
             wait_until_server_started(n)
+          end           
+        elsif !xbyx.nil? and xbyx > 0
+          #Stop up to xbyx servers at a time in the cluster, then start them.
+          #Repeat until all servers have been restarted. Allows us to speed up large clusters while maintaining service
+          q=[]
+          #build total queue in reverse order so we can pop servers off the end
+          with_each_server do |n|
+            q=[n]+q
+          end
+          while q.length > 0
+            bq=[]
+            #build our batch queue to process
+            while bq.length < xbyx and q.length > 0
+               bq << q.pop
+            end
+            bq.each do |server|
+              stop_server(server)
+            end
+            sleep 0.1 #if xbyx is small give just a moment for process to finish
+            bq.each do |server|
+              start_server(server)
+            end
           end
+        else
+          # Let's do a normal restart by default
+          stop
+          sleep 0.1 # Let's breath a bit shall we ?
+          start
         end
       end
       
diff --git a/lib/thin/runner.rb b/lib/thin/runner.rb
index 64804507..5c713d2d 100644
--- a/lib/thin/runner.rb
+++ b/lib/thin/runner.rb
@@ -108,6 +108,7 @@ def parser
           opts.on("-C", "--config FILE", "Load options from config file")               { |file| @options[:config] = file }
           opts.on(      "--all [DIR]", "Send command to each config files in DIR")      { |dir| @options[:all] = dir } if Thin.linux?
           opts.on("-O", "--onebyone", "Restart the cluster one by one (only works with restart command)") { @options[:onebyone] = true }
+          opts.on("-X", "--xbyx NUM", "Restart the cluster in batches up to X servers at a time (only works with restart command)") { |num| @options[:xbyx] = num.to_i }
           opts.on("-w", "--wait NUM", "Maximum wait time for server to be started in seconds (use with -O)") { |time| @options[:wait] = time.to_i }
         end
 
diff --git a/lib/thin/version.rb b/lib/thin/version.rb
index 967b0a3e..c7bbb329 100644
--- a/lib/thin/version.rb
+++ b/lib/thin/version.rb
@@ -6,7 +6,7 @@ class PlatformNotSupported < RuntimeError; end
   module VERSION #:nodoc:
     MAJOR    = 1
     MINOR    = 6
-    TINY     = 4
+    TINY     = 5
     
     STRING   = [MAJOR, MINOR, TINY].join('.')
     

From 8d60fcc6746fad609b23c6e332b6d45d0003699b Mon Sep 17 00:00:00 2001
From: Adam <shmali81@gmail.com>
Date: Fri, 22 Apr 2016 14:59:22 -0500
Subject: [PATCH 2/2] update readme with additional option

---
 README.md | 1 +
 1 file changed, 1 insertion(+)

diff --git a/README.md b/README.md
index 89ff96c3..c1c70c3a 100644
--- a/README.md
+++ b/README.md
@@ -129,6 +129,7 @@ Cluster options:
     -C, --config FILE                Load options from config file
         --all [DIR]                  Send command to each config files in DIR
     -O, --onebyone                   Restart the cluster one by one (only works with restart command)
+    -X, --xbyx                       Restart the cluster in batches up to X servers at a time (only works with restart command)
     -w, --wait NUM                   Maximum wait time for server to be started in seconds (use with -O)
 
 Tuning options: