Contents

module DeepTest
  module Distributed
    class RemoteWorkerServer
      include DRb::DRbUndumped

      MERCY_KILLING_GRACE_PERIOD = 10 * 60 unless defined?(MERCY_KILLING_GRACE_PERIOD)

      def initialize(base_path, workers)
        @base_path = base_path
        @workers = workers
      end

      def launch_mercy_killer(grace_period)
        Thread.new do
          sleep grace_period
          exit(0) unless workers_started?
        end
      end

      def load_files(files)
        Dir.chdir @base_path
        resolver = FilenameResolver.new(@base_path)
        files.each do |file|
          load resolver.resolve(file)
        end
      end

      def start_all
        @workers_started = true
        @workers.start_all
      end

      def stop_all
        Thread.new do
          @workers.stop_all
        end
      end

      def workers_started?
        @workers_started
      end

      def self.warlock
        @warlock ||= DeepTest::Warlock.new
      end

      def self.running_server_count
        @warlock.demon_count if @warlock
      end

      def self.stop_all
        @warlock.stop_all if @warlock
      end

      def self.start(address, base_path, workers, grace_period = MERCY_KILLING_GRACE_PERIOD)
        innie, outie = IO.pipe

        warlock.start("RemoteWorkerServer") do
          innie.close

          server = new(base_path, workers)

          DRb.start_service("drubyall://#{address}:0", server)
          DeepTest.logger.info "RemoteWorkerServer started at #{DRb.uri}"

          outie.write DRb.uri
          outie.close

          server.launch_mercy_killer(grace_period)

          DRb.thread.join
        end

        outie.close
        uri = innie.gets
        innie.close
        DRbObject.new_with_uri(uri)
      end

    end
  end
end

Version data entries

9 entries across 9 versions & 3 rubygems

Version	Path
jperkins-deep_test-1.2.2	lib/deep_test/distributed/remote_worker_server.rb
jstorimer-deep-test-1.4.0	lib/deep_test/distributed/remote_worker_server.rb
jstorimer-deep-test-1.3.0	lib/deep_test/distributed/remote_worker_server.rb
jstorimer-deep-test-1.2.0	lib/deep_test/distributed/remote_worker_server.rb
jstorimer-deep-test-1.1.0	lib/deep_test/distributed/remote_worker_server.rb
jstorimer-deep-test-1.0.0	lib/deep_test/distributed/remote_worker_server.rb
deep_test-1.2.1	lib/deep_test/distributed/remote_worker_server.rb
deep_test-1.2.2	lib/deep_test/distributed/remote_worker_server.rb
deep_test-1.2.0	lib/deep_test/distributed/remote_worker_server.rb