Move some more processes' concerns under processes/

Author: rosa

lib/solid_queue.rb

@@ -7,9 +7,9 @@
 require "solid_queue/app_executor"
 require "solid_queue/processes/supervised"
 require "solid_queue/processes/registrable"
-require "solid_queue/interruptible"
-require "solid_queue/pidfile"
-require "solid_queue/procline"
+require "solid_queue/processes/interruptible"
+require "solid_queue/processes/pidfile"
+require "solid_queue/processes/procline"
 require "solid_queue/processes/base"
 require "solid_queue/processes/runnable"
 require "solid_queue/signals"

lib/solid_queue/interruptible.rb

@@ -0,0 +1,37 @@
+# frozen_string_literal: true
+
+module SolidQueue::Processes
+  module Interruptible
+    def wake_up
+      interrupt
+    end
+
+    private
+      SELF_PIPE_BLOCK_SIZE = 11
+
+      def interrupt
+        self_pipe[:writer].write_nonblock( "." )
+      rescue Errno::EAGAIN, Errno::EINTR
+        # Ignore writes that would block and retry
+        # if another signal arrived while writing
+        retry
+      end
+
+      def interruptible_sleep(time)
+        if time > 0 && self_pipe[:reader].wait_readable(time)
+          loop { self_pipe[:reader].read_nonblock(SELF_PIPE_BLOCK_SIZE) }
+        end
+      rescue Errno::EAGAIN, Errno::EINTR
+      end
+
+      # Self-pipe for signal-handling (http://cr.yp.to/docs/selfpipe.html)
+      def self_pipe
+        @self_pipe ||= create_self_pipe
+      end
+
+      def create_self_pipe
+        reader, writer = IO.pipe
+        { reader: reader, writer: writer }
+      end
+  end
+end

lib/solid_queue/processes/interruptible.rb

@@ -1,6 +1,6 @@
 # frozen_string_literal: true
 
-module SolidQueue
+module SolidQueue::Processes
   class Pidfile
     def initialize(path)
       @path = path

lib/solid_queue/pidfile.rb renamed to lib/solid_queue/processes/pidfile.rb

@@ -1,6 +1,6 @@
 # frozen_string_literal: true
 
-module SolidQueue
+module SolidQueue::Processes
   module Procline
     # Sets the procline ($0)
     # solid-queue-supervisor(0.1.0): <string>

lib/solid_queue/procline.rb renamed to lib/solid_queue/processes/procline.rb

@@ -7,10 +7,6 @@ class ImmediateTerminationRequested < Interrupt; end
   module Signals
     extend ActiveSupport::Concern
 
-    included do
-      include Interruptible
-    end
-
     private
       SIGNALS = %i[ QUIT INT TERM ]
 

lib/solid_queue/signals.rb

@@ -59,7 +59,7 @@ def sync_std_streams
 
       def setup_pidfile
         @pidfile = if SolidQueue.supervisor_pidfile
-          Pidfile.new(SolidQueue.supervisor_pidfile).tap(&:setup)
+          Processes::Pidfile.new(SolidQueue.supervisor_pidfile).tap(&:setup)
         end
       end