Class: DeepTest::Server

Inherits:
Object
  • Object
show all
Includes:
DRbUndumped
Defined in:
lib/deep_test/server.rb

Defined Under Namespace

Classes: NoWorkUnitsAvailableError, NoWorkUnitsRemainingError, ResultOverdueError

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ Server

Returns a new instance of Server.



28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/deep_test/server.rb', line 28

def initialize(options)
  @options = options
  @work_queue = Queue.new
  @result_queue = Queue.new

  if Metrics::Gatherer.enabled?
    require File.dirname(__FILE__) + "/metrics/queue_lock_wait_time_measurement"
    @work_queue.extend Metrics::QueueLockWaitTimeMeasurement
    @result_queue.extend Metrics::QueueLockWaitTimeMeasurement
    Metrics::Gatherer.section("server queue lock wait times") do |s|
      s.measurement("work queue total pop wait time", @work_queue.total_pop_time)
      s.measurement("work queue total push wait time", @work_queue.total_push_time)
      s.measurement("result queue total pop wait time", @result_queue.total_pop_time)
      s.measurement("result queue total push wait time", @result_queue.total_push_time)
    end
  end
end

Class Method Details

.remote_reference(address, port) ⇒ Object 



21
22
23
24
25
26
 
# File 'lib/deep_test/server.rb', line 21

def self.remote_reference(address, port)
  DRb.start_service("drbfire://#{address}:#{port}", nil, DRbFire::ROLE => DRbFire::CLIENT)
  blackboard = DRbObject.new_with_uri("drbfire://#{address}:#{port}")
  DeepTest.logger.debug "Connecting to DeepTest server at #{blackboard.__drburi}"
  blackboard
end

.start(options) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
 
# File 'lib/deep_test/server.rb', line 5

def self.start(options)
  server = new(options)
  
  # start_sevice if running locally, otherise we only want to use the RemoteWorkerClient connection
  if options.distributed_server.nil?
    DRb.start_service("drbfire://0.0.0.0:#{options.server_port}", server, DRbFire::ROLE => DRbFire::SERVER)
    DeepTest.logger.info "Started DeepTest service at #{DRb.uri}"
  end
  
  server
end

.stop ⇒ Object 



17
18
19
 
# File 'lib/deep_test/server.rb', line 17

def self.stop
  DRb.stop_service
end

Instance Method Details

#done_with_work ⇒ Object 



46
47
48
 
# File 'lib/deep_test/server.rb', line 46

def done_with_work
  @done_with_work = true
end

#take_result ⇒ Object 



50
51
52
53
54
 
# File 'lib/deep_test/server.rb', line 50

def take_result
  Timeout.timeout(@options.timeout_in_seconds, ResultOverdueError) do
    @result_queue.pop
  end
end

#take_work ⇒ Object 



56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/deep_test/server.rb', line 56

def take_work
  raise NoWorkUnitsRemainingError if @done_with_work

  @work_queue.pop(true)
rescue ThreadError => e
  if e.message == "queue empty"
    raise NoWorkUnitsAvailableError
  else
    raise
  end
end

#write_result(result) ⇒ Object 



68
69
70
71
 
# File 'lib/deep_test/server.rb', line 68

def write_result(result)
  @result_queue.push result
  nil
end

#write_work(work_unit) ⇒ Object 



73
74
75
76
 
# File 'lib/deep_test/server.rb', line 73

def write_work(work_unit)
  @work_queue.push work_unit
  nil
end