Class: DeepTest::DRbBindAllTCPSocket

Inherits:
DRb::DRbTCPSocket
  • Object
show all
Defined in:
lib/deep_test/extensions/drb_extension.rb

Class Method Summary collapse

Class Method Details

.open_server(uri, config) ⇒ Object

Open a server listening for connections at uri using configuration config.



17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/deep_test/extensions/drb_extension.rb', line 17

def self.open_server(uri, config)
  
  DeepTest.logger.debug "drubyall open_server with args: #{uri.inspect} #{config.inspect}"
  
  uri = 'drubyall://:0' unless uri
  host, port, opt = parse_uri(uri)

  if host.size == 0
    host = getservername
  end

  DeepTest.logger.debug("Listening on port #{port}, all addresses.")
 soc = TCPServer.open('0.0.0.0', port)  	    
  port = soc.addr[1] if port == 0
  uri = "druby://#{host}:#{port}"
  self.new(uri, soc, config)
  
rescue Exception => e
  unless DRb::DRbBadURI === e or DRb::DRbBadScheme === e
    DeepTest.logger.debug "drubyall open_server exception: #{e.message}\n#{e.backtrace.join("\n")}"
  end
  raise
end

.parse_uri(uri) ⇒ Object 



3
4
5
6
7
8
9
10
11
12
13
 
# File 'lib/deep_test/extensions/drb_extension.rb', line 3

def self.parse_uri(uri)
  if uri =~ /^drubyall:\/\/(.*?):(\d+)(\?(.*))?$/
  	host = $1
  	port = $2.to_i
  	option = $4
  	[host, port, option]
  else
  	raise(DRb::DRbBadScheme, uri) unless uri =~ /^drubyall:/
  	raise(DRb::DRbBadURI, 'can\'t parse uri:' + uri)
	end
end