Contents

class ProconBypassMan::Runner
  include ProconBypassMan::SignalHandler

  def initialize(gadget: , procon: )
    @gadget = gadget
    @procon = procon
  end

  def run
    self_read, self_write = IO.pipe
    %w(TERM INT USR2).each do |sig|
      begin
        trap sig do
          self_write.puts(sig)
        end
      rescue ArgumentError
        ProconBypassMan::SendErrorCommand.execute(error: "Signal #{sig} not supported")
      end
    end

    loop do
      child_pid = Kernel.fork do
        $will_terminate_token = false
        ProconBypassMan.after_fork_on_bypass_process
        ProconBypassMan::BypassCommand.new(gadget: @gadget, procon: @procon).execute # ここでblockingする
        next
      end

      begin
        # TODO 子プロセスが消滅した時に、メインプロセスは生き続けてしまい、何もできなくなる問題がある
        while(readable_io = IO.select([self_read]))
          signal = readable_io.first[0].gets.strip
          handle_signal(signal)
        end
      rescue ProconBypassMan::InterruptForRestart
        ProconBypassMan::PrintMessageCommand.execute(text: "設定ファイルの再読み込みを開始します")
        Process.kill("USR2", child_pid)
        Process.wait
        begin
          ProconBypassMan::ButtonsSettingConfiguration::Loader.reload_setting
          ProconBypassMan::SendReloadConfigEventCommand.execute
        rescue ProconBypassMan::CouldNotLoadConfigError => error
          ProconBypassMan::SendErrorCommand.execute(error: "設定ファイルが不正です。再読み込みができませんでした")
          ProconBypassMan::ReportErrorReloadConfigJob.perform_async(error.message)
        end
        ProconBypassMan::PrintMessageCommand.execute(text: "バイパス処理を再開します")
      rescue Interrupt
        puts
        ProconBypassMan::PrintMessageCommand.execute(text: "処理を終了します")
        Process.kill("TERM", child_pid)
        Process.wait
        break
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
procon_bypass_man-0.3.3.1	lib/procon_bypass_man/runner.rb
procon_bypass_man-0.3.3	lib/procon_bypass_man/runner.rb
procon_bypass_man-0.3.2	lib/procon_bypass_man/runner.rb
procon_bypass_man-0.3.1	lib/procon_bypass_man/runner.rb