Contents

module Specjour
  class Printer < GServer
    include Protocol
    RANDOM_PORT = 0

    attr_accessor :worker_size, :specs_to_run, :completed_workers

    def initialize
      super(
        port = RANDOM_PORT,
        host = "0.0.0.0",
        max_connections = 100,
        stdlog = $stderr,
        audit = true,
        debug = true
      )
      @completed_workers = 0
    end

    def serve(client)
      client = Connection.wrap client
      client.each(TERMINATOR) do |data|
        process load_object(data), client
      end
    end

    def ready(client)
      client.print specs_to_run.shift
      client.flush
    end

    def done(client)
      self.completed_workers += 1
    end

    def worker_summary=(client, summary)
      report.add(summary)
    end

    protected

    def disconnecting(client_port)
      if completed_workers == worker_size
        stop
      end
    end

    def log(msg)
      # noop
    end

    def process(message, client)
      if message.is_a?(String)
        $stdout.print message
        $stdout.flush
      elsif message.is_a?(Array)
        send(message.first, client, *message[1..-1])
      end
    end

    def report
      @report ||= FinalReport.new
    end

    def stopping
      report.summarize
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
specjour-0.1.18	lib/specjour/printer.rb
specjour-0.1.17	lib/specjour/printer.rb
specjour-0.1.16	lib/specjour/printer.rb
specjour-0.1.15	lib/specjour/printer.rb
specjour-0.1.14	lib/specjour/printer.rb
specjour-0.1.13	lib/specjour/printer.rb
specjour-0.1.12	lib/specjour/printer.rb