Contents

module Henry

  class ExecutionService

    # Uri where the service will be listening.
    DRB_URI = 'druby://localhost'

    # Range of ports to be used.
    DRB_PORTS = (8800..9000)

    # Starts the result service sharing the given result.
    #
    # @param [Execution] execution the Execution to be shared.
    def self.start(execution)
      10.times do
        begin
          drb_uri = "#{DRB_URI}:#{rand(DRB_PORTS)}"
          DRb.start_service(drb_uri, execution)
          ENV['DRB_EXECUTION_URI'] = drb_uri 
        rescue Errno::EADDRINUSE
        end
      end
      
      return false
    end

    # Stops the result service.
    def self.stop
      DRb.stop_service
    rescue
      return false
    end

  end

end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
henry-container-0.1.82	lib/henry/execution_service.rb
henry-container-0.1.81	lib/henry/execution_service.rb
henry-container-0.1.80	lib/henry/execution_service.rb
henry-container-0.1.79	lib/henry/execution_service.rb
henry-container-0.1.78	lib/henry/execution_service.rb
henry-container-0.1.77	lib/henry/execution_service.rb
henry-container-0.1.76	lib/henry/execution_service.rb