Contents

# frozen_string_literal: true

module Polyphony
  module Process
    class << self
      def watch(cmd = nil, &block)
        terminated = nil
        pid = cmd ? Kernel.spawn(cmd) : Polyphony.fork(&block)
        watcher = Gyro::Child.new(pid)
        watcher.await
        terminated = true
      ensure
        kill_process(pid) unless terminated || pid.nil?
      end
      
      def kill_process(pid)
        cancel_after(5) do
          kill_and_await('TERM', pid)
        end
      rescue Polyphony::Cancel
        kill_and_await(-9, pid)
      end
      
      def kill_and_await(sig, pid)
        ::Process.kill(sig, pid)
        Gyro::Child.new(pid).await
      rescue SystemCallError
        # ignore
        puts 'SystemCallError in kill_and_await'
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
polyphony-0.40	lib/polyphony/adapters/process.rb
polyphony-0.39	lib/polyphony/adapters/process.rb
polyphony-0.38	lib/polyphony/adapters/process.rb