Class: TCPServer

Inherits:
Object show all
Defined in:
lib/rwd/net.rb

Class Method Summary collapse

Class Method Details

.freeport(from, to, remote = false) ⇒ Object 



31
32
33
34
35
36
37
 
# File 'lib/rwd/net.rb', line 31

def self.freeport(from, to, remote=false)
  if windows? or cygwin?
    TCPServer.freeport_windows(from, to, remote)
  else
    TCPServer.freeport_linux(from, to, remote)
  end
end

.freeport_linux(from, to, remote) ⇒ Object 



39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/rwd/net.rb', line 39

def self.freeport_linux(from, to, remote)
  ports = (from..to).to_a
  port  = nil
  res   = nil

  while res.nil? and not ports.empty?
    begin
      port  = ports[0]
      ports.delete(port)

      io  = TCPServer.new(remote ? "0.0.0.0" : "localhost", port)

      res = [port, io]
    rescue
    end
  end

  res = [nil, nil]  if res.nil?

  port, io  = res

  return port, io
end

.freeport_windows(from, to, remote) ⇒ Object 



63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
 
# File 'lib/rwd/net.rb', line 63

def self.freeport_windows(from, to, remote)
  ports = (from..to).to_a
  port  = nil
  res   = nil

  while res.nil? and not ports.empty?
    begin
      port  = ports.any
      ports.delete(port)

      io  = TCPSocket.new("localhost", port)
      io.close
    rescue
      res = port
    end
  end

  port, io  = res

  return port, io
end

.freeport_windows2(from, to, remote) ⇒ Object 



85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
 
# File 'lib/rwd/net.rb', line 85

def self.freeport_windows2(from, to, remote)
  res = nil
  port  = from

  while res.nil? and port <= to
    begin
      io  = TCPSocket.new("localhost", port)
      io.close

      port += 1
    rescue
      res = port
    end
  end

  return res
end

.usedports(from, to) ⇒ Object 



103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
 
# File 'lib/rwd/net.rb', line 103

def self.usedports(from, to)
  threads = []
  res   = []

  from.upto(to) do |port|
    threads << Thread.new do
      begin
        io  = TCPSocket.new("localhost", port)
        io.close

        port
      rescue
        nil
      end
    end
  end

  threads.each do |thread|
    port  = thread.value
    res << port unless port.nil?
  end

  return res
end