1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
# frozen_string_literal: true
require_relative 'helper'
describe 'Dalli::Socket::TCP' do
describe '.supports_connect_timeout?' do
before do
# Clear the cached value before each test
Dalli::Socket::TCP.remove_instance_variable(:@supports_connect_timeout) if
Dalli::Socket::TCP.instance_variable_defined?(:@supports_connect_timeout)
end
it 'returns true for unmodified TCPSocket on MRI Ruby 3.0+' do
skip 'Ruby 3.0+ required' if RUBY_VERSION < '3.0'
skip 'MRI-specific test' if RUBY_ENGINE != 'ruby'
# Assuming TCPSocket hasn't been monkey-patched in test environment
# TruffleRuby and JRuby have different TCPSocket#initialize signatures
assert_predicate Dalli::Socket::TCP, :supports_connect_timeout?
end
it 'returns false for Ruby < 3.0' do
skip 'Only testable on Ruby < 3.0' if RUBY_VERSION >= '3.0'
refute_predicate Dalli::Socket::TCP, :supports_connect_timeout?
end
it 'caches the result' do
skip
# First call
result1 = Dalli::Socket::TCP.supports_connect_timeout?
# Verify it's cached
assert Dalli::Socket::TCP.instance_variable_defined?(:@supports_connect_timeout)
# Second call should return same value
result2 = Dalli::Socket::TCP.supports_connect_timeout?
assert_equal result1, result2
end
it 'detects when TCPSocket#initialize parameters have changed' do
skip 'Ruby 3.0+ required' if RUBY_VERSION < '3.0'
# Get the expected native parameters
native_params = [[:rest]]
actual_params = TCPSocket.instance_method(:initialize).parameters
# This test documents the expected behavior
if actual_params == native_params
assert_predicate Dalli::Socket::TCP, :supports_connect_timeout?,
'Should support connect_timeout when TCPSocket is unmodified'
else
refute_predicate Dalli::Socket::TCP, :supports_connect_timeout?,
'Should not support connect_timeout when TCPSocket is modified'
end
end
end
describe '.create_socket_with_timeout' do
it 'yields a socket when connection succeeds' do
memcached(:meta, rand(21_500..21_600)) do |_, port|
socket_yielded = false
Dalli::Socket::TCP.create_socket_with_timeout('127.0.0.1', port, socket_timeout: 5) do |sock|
socket_yielded = true
assert_kind_of TCPSocket, sock
end
assert socket_yielded, 'Block should have been yielded to'
end
end
it 'raises on connection timeout to non-existent server' do
# Use a port that's unlikely to be listening
assert_raises(Errno::ECONNREFUSED, Timeout::Error) do
Dalli::Socket::TCP.create_socket_with_timeout('127.0.0.1', 59_999, socket_timeout: 1) do |_sock|
flunk 'Should not yield socket for failed connection'
end
end
end
end
end
|
