test/test_pool.rb in random-port-0.6.0 vs test/test_pool.rb in random-port-0.7.0
- old
+ new
@@ -1,10 +1,10 @@
# frozen_string_literal: true
# (The MIT License)
#
-# Copyright (c) 2018 Yegor Bugayenko
+# Copyright (c) 2018-2024 Yegor Bugayenko
#
# Permission is hereby granted, free of charge, to any person obtaining a copy
# of this software and associated documentation files (the 'Software'), to deal
# in the Software without restriction, including without limitation the rights
# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
@@ -22,21 +22,22 @@
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
# SOFTWARE.
require 'minitest/autorun'
require 'threads'
+require 'socket'
require_relative '../lib/random-port/pool'
# Pool test.
# Author:: Yegor Bugayenko (yegor256@gmail.com)
-# Copyright:: Copyright (c) 2018 Yegor Bugayenko
+# Copyright:: Copyright (c) 2018-2024 Yegor Bugayenko
# License:: MIT
class RandomPort::TestPool < Minitest::Test
def test_acquires_and_releases
pool = RandomPort::Pool.new
port = pool.acquire
- server = TCPServer.new(port)
+ server = TCPServer.new('localhost', port)
server.close
assert(!port.nil?)
assert(port.positive?)
pool.release(port)
end
@@ -44,11 +45,11 @@
def test_acquires_and_releases_three_ports
pool = RandomPort::Pool.new(limit: 3)
assert_equal(0, pool.size)
ports = pool.acquire(3, timeout: 16)
ports.each do |p|
- server = TCPServer.new(p)
+ server = TCPServer.new('localhost', p)
server.close
end
assert_equal(3, pool.size)
assert_equal(3, ports.count)
pool.release(ports)
@@ -61,11 +62,11 @@
pool.acquire(3, timeout: 16) do |ports|
assert(ports.is_a?(Array))
assert_equal(3, ports.count)
assert_equal(3, pool.size)
ports.each do |p|
- server = TCPServer.new(p)
+ server = TCPServer.new('localhost', p)
server.close
end
end
assert_equal(0, pool.size)
end
@@ -82,10 +83,10 @@
def test_acquires_and_releases_in_threads
pool = RandomPort::Pool.new
Threads.new(100).assert do
pool.acquire(5) do |ports|
ports.each do |p|
- server = TCPServer.new(p)
+ server = TCPServer.new('localhost', p)
server.close
end
end
end
end