Contents

require 'json'
require 'socket'

module Zeus
  class Server
    class Acceptor
      attr_accessor :aliases, :description, :action, :name
      def initialize(server)
        @server = server
      end

      def descendent_acceptors
        self
      end

      def run
        register_with_client_handler(Process.pid)
        Zeus.ui.info("starting #{process_type} `#{@name}`")
        Zeus.thread_with_backtrace_on_error { runloop! }
      end

      private

      def command_runner
        CommandRunner.new(name, action, @s_acceptor)
      end

      def register_with_client_handler(pid)
        @s_client_handler, @s_acceptor = UNIXSocket.pair
        @s_acceptor.puts registration_data(pid)
        at_exit { @s_client_handler.close ; @s_acceptor.close }
        @server.__CHILD__register_acceptor(@s_client_handler)
      end

      def registration_data(pid)
        {type: 'registration', pid: pid, commands: [name, *aliases], description: description}.to_json
      end

      def accept_connection
        terminal = @s_acceptor.recv_io # blocking
        exit_status_socket = @s_acceptor.recv_io
        arguments = JSON.parse(@s_acceptor.readline.chomp)

        [terminal, exit_status_socket, arguments]
      end

      def process_type
        "acceptor"
      end

      def runloop!
        loop do
          terminal, exit_status_socket, arguments = accept_connection # blocking
          command_runner.run(terminal, exit_status_socket, arguments)
        end
      end

      module ErrorState
        NOT_A_PID = 0
        attr_accessor :error

        def process_type
          "error-state acceptor"
        end

        def runloop!
          loop do
            terminal = @s_acceptor.recv_io
            _ = @s_acceptor.readline
            @s_acceptor << NOT_A_PID << "\n"
            ErrorPrinter.new(@error).write_to(terminal)
            terminal.close
          end
        end

      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
zeus-0.4.6	lib/zeus/server/acceptor.rb