diff options
| author | Andrew Konchin <[email protected]> | 2025-01-30 17:39:10 +0200 |
|---|---|---|
| committer | Benoit Daloze <[email protected]> | 2025-01-30 20:43:46 +0100 |
| commit | d7a5ad2a21f7d2c45e3fea674ff077bb0e2cadae (patch) | |
| tree | d49629b969bb4d13b74fd1bfeebf15553cc3d5d2 /spec/ruby/library/socket/basicsocket/recvmsg_nonblock_spec.rb | |
| parent | ea2dd5b80e26036af83e7b37d722f4a106188555 (diff) | |
Update to ruby/spec@affef93
Notes
Notes:
Merged: https://github.com/ruby/ruby/pull/12679
Diffstat (limited to 'spec/ruby/library/socket/basicsocket/recvmsg_nonblock_spec.rb')
| -rw-r--r-- | spec/ruby/library/socket/basicsocket/recvmsg_nonblock_spec.rb | 68 |
1 files changed, 68 insertions, 0 deletions
diff --git a/spec/ruby/library/socket/basicsocket/recvmsg_nonblock_spec.rb b/spec/ruby/library/socket/basicsocket/recvmsg_nonblock_spec.rb index cc4275c417..8d5f541a8e 100644 --- a/spec/ruby/library/socket/basicsocket/recvmsg_nonblock_spec.rb +++ b/spec/ruby/library/socket/basicsocket/recvmsg_nonblock_spec.rb @@ -222,3 +222,71 @@ describe 'BasicSocket#recvmsg_nonblock' do end end end + +describe 'BasicSocket#recvmsg_nonblock' do + context "when recvfrom(2) returns 0 (if no messages are available to be received and the peer has performed an orderly shutdown)" do + describe "stream socket" do + before :each do + @server = TCPServer.new('127.0.0.1', 0) + @port = @server.addr[1] + end + + after :each do + @server.close unless @server.closed? + end + + ruby_version_is ""..."3.3" do + quarantine! do # May fail with "IO::EAGAINWaitReadable: Resource temporarily unavailable - recvfrom(2) would block" error + it "returns an empty String as received data on a closed stream socket" do + ready = false + + t = Thread.new do + client = @server.accept + + Thread.pass while !ready + client.recvmsg_nonblock(10) + ensure + client.close if client + end + + Thread.pass while t.status and t.status != "sleep" + t.status.should_not be_nil + + socket = TCPSocket.new('127.0.0.1', @port) + socket.close + ready = true + + t.value.should.is_a? Array + t.value[0].should == "" + end + end + end + + ruby_version_is "3.3" do + platform_is_not :windows do + it "returns nil on a closed stream socket" do + ready = false + + t = Thread.new do + client = @server.accept + + Thread.pass while !ready + client.recvmsg_nonblock(10) + ensure + client.close if client + end + + Thread.pass while t.status and t.status != "sleep" + t.status.should_not be_nil + + socket = TCPSocket.new('127.0.0.1', @port) + socket.close + ready = true + + t.value.should be_nil + end + end + end + end + end +end |