We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9d9f248 commit 9433175Copy full SHA for 9433175
test/internals_test.rb
@@ -160,6 +160,23 @@ def test_connection_timeout
160
assert (Time.now - start_time) <= opts[:timeout]
161
end
162
163
+ driver(:ruby) do
164
+ def test_write_timeout
165
+ server = TCPServer.new("127.0.0.1", 0)
166
+ port = server.addr[1]
167
+
168
+ # Hacky, but we need the buffer size
169
+ val = TCPSocket.new("127.0.0.1", port).getsockopt(Socket::SOL_SOCKET, Socket::SO_SNDBUF).unpack("i")[0]
170
171
+ assert_raise(Redis::TimeoutError) do
172
+ Timeout.timeout(1) do
173
+ redis = Redis.new(:port => port, :timeout => 5, :write_timeout => 0.1)
174
+ redis.set("foo", "1" * val*2)
175
+ end
176
177
178
179
180
def close_on_ping(seq, options = {})
181
$request = 0
182
0 commit comments