feat: debug test failure

Author: elasticspoon

app/models/solid_queue/process.rb

@@ -11,6 +11,7 @@ class SolidQueue::Process < SolidQueue::Record
   def self.register(**attributes)
     SolidQueue.instrument :register_process, **attributes do |payload|
       create!(attributes.merge(last_heartbeat_at: Time.current)).tap do |process|
+        puts "Registered #{Process.pid} #{$0}"
         payload[:process_id] = process.id
       end
     rescue Exception => error

lib/solid_queue/processes/interruptible.rb

@@ -10,6 +10,7 @@ def wake_up
       SELF_PIPE_BLOCK_SIZE = 11
 
       def interrupt
+        puts "Sending TERM to w: #{self_pipe[:writer].fileno} (r: #{self_pipe[:reader].fileno}) from #{$0}"
         self_pipe[:writer].write_nonblock(".")
       rescue Errno::EAGAIN, Errno::EINTR
         # Ignore writes that would block and retry
@@ -18,6 +19,7 @@ def interrupt
       end
 
       def interruptible_sleep(time)
+        puts "PID #{Process.pid} #{$0} sleeping. waiting on pipe r: #{self_pipe[:reader].fileno} (w: #{self_pipe[:writer].fileno})"
         if time > 0 && self_pipe[:reader].wait_readable(time)
           loop { self_pipe[:reader].read_nonblock(SELF_PIPE_BLOCK_SIZE) }
         end
@@ -30,6 +32,7 @@ def self_pipe
       end
 
       def create_self_pipe
+        puts "Creating pipe for #{$0}"
         reader, writer = IO.pipe
         { reader: reader, writer: writer }
       end

lib/solid_queue/supervisor/signals.rb

@@ -49,6 +49,7 @@ def handle_signal(signal)
 
         def signal_processes(pids, signal)
           pids.each do |pid|
+            puts "Killing #{pid}" if signal == :QUIT
             signal_process pid, signal
           end
         end