diff options
author | eregon <eregon@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2017-05-07 12:04:49 +0000 |
---|---|---|
committer | eregon <eregon@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2017-05-07 12:04:49 +0000 |
commit | a3736e97a6ca517c2cd7d3d93a8f2ef86e39e5b5 (patch) | |
tree | 9eef7f720314ebaff56845a74e203770e62284e4 /spec/rubyspec/library/socket/tcpserver | |
parent | 52df1d0d3370919711c0577aaa42d1a864709885 (diff) | |
download | ruby-a3736e97a6ca517c2cd7d3d93a8f2ef86e39e5b5.tar.gz |
Add in-tree mspec and ruby/spec
* For easier modifications of ruby/spec by MRI developers.
* .gitignore: track changes under spec.
* spec/mspec, spec/rubyspec: add in-tree mspec and ruby/spec.
These files can therefore be updated like any other file in MRI.
Instructions are provided in spec/README.
[Feature #13156] [ruby-core:79246]
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@58595 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'spec/rubyspec/library/socket/tcpserver')
8 files changed, 295 insertions, 0 deletions
diff --git a/spec/rubyspec/library/socket/tcpserver/accept_nonblock_spec.rb b/spec/rubyspec/library/socket/tcpserver/accept_nonblock_spec.rb new file mode 100644 index 0000000000..d0f2673af3 --- /dev/null +++ b/spec/rubyspec/library/socket/tcpserver/accept_nonblock_spec.rb @@ -0,0 +1,49 @@ +require File.expand_path('../../../../spec_helper', __FILE__) +require File.expand_path('../../fixtures/classes', __FILE__) + +describe "Socket::TCPServer.accept_nonblock" do + before :each do + @server = TCPServer.new("127.0.0.1", SocketSpecs.port) + end + + after :each do + @server.close unless @server.closed? + end + + it "accepts non blocking connections" do + @server.listen(5) + lambda { + @server.accept_nonblock + }.should raise_error(IO::WaitReadable) + + c = TCPSocket.new("127.0.0.1", SocketSpecs.port) + sleep 0.1 + s = @server.accept_nonblock + + port, address = Socket.unpack_sockaddr_in(s.getsockname) + + port.should == SocketSpecs.port + address.should == "127.0.0.1" + s.should be_kind_of(TCPSocket) + + c.close + s.close + end + + it "raises an IOError if the socket is closed" do + @server.close + lambda { @server.accept }.should raise_error(IOError) + end + + describe 'without a connected client' do + it 'raises error' do + lambda { @server.accept_nonblock }.should raise_error(IO::WaitReadable) + end + + ruby_version_is '2.3' do + it 'returns :wait_readable in exceptionless mode' do + @server.accept_nonblock(exception: false).should == :wait_readable + end + end + end +end diff --git a/spec/rubyspec/library/socket/tcpserver/accept_spec.rb b/spec/rubyspec/library/socket/tcpserver/accept_spec.rb new file mode 100644 index 0000000000..cf1fbbd873 --- /dev/null +++ b/spec/rubyspec/library/socket/tcpserver/accept_spec.rb @@ -0,0 +1,66 @@ +require File.expand_path('../../../../spec_helper', __FILE__) +require File.expand_path('../../fixtures/classes', __FILE__) + + +describe "TCPServer#accept" do + before :each do + @server = TCPServer.new("127.0.0.1", SocketSpecs.port) + end + + after :each do + @server.close unless @server.closed? + end + + it "accepts a connection and returns a TCPSocket" do + data = nil + t = Thread.new do + client = @server.accept + client.should be_kind_of(TCPSocket) + data = client.read(5) + client << "goodbye" + client.close + end + Thread.pass while t.status and t.status != "sleep" + + socket = TCPSocket.new('127.0.0.1', SocketSpecs.port) + socket.write('hello') + socket.shutdown(1) # we are done with sending + socket.read.should == 'goodbye' + t.join + data.should == 'hello' + socket.close + end + + it "can be interrupted by Thread#kill" do + t = Thread.new { @server.accept } + + Thread.pass while t.status and t.status != "sleep" + + # kill thread, ensure it dies in a reasonable amount of time + t.kill + a = 1 + while a < 2000 + break unless t.alive? + Thread.pass + sleep 0.2 + a += 1 + end + a.should < 2000 + end + + it "can be interrupted by Thread#raise" do + t = Thread.new { @server.accept } + + Thread.pass while t.status and t.status != "sleep" + + # raise in thread, ensure the raise happens + ex = Exception.new + t.raise ex + lambda { t.join }.should raise_error(Exception) + end + + it "raises an IOError if the socket is closed" do + @server.close + lambda { @server.accept }.should raise_error(IOError) + end +end diff --git a/spec/rubyspec/library/socket/tcpserver/gets_spec.rb b/spec/rubyspec/library/socket/tcpserver/gets_spec.rb new file mode 100644 index 0000000000..2f8e699a53 --- /dev/null +++ b/spec/rubyspec/library/socket/tcpserver/gets_spec.rb @@ -0,0 +1,16 @@ +require File.expand_path('../../../../spec_helper', __FILE__) +require File.expand_path('../../fixtures/classes', __FILE__) + +describe "TCPServer#gets" do + before :each do + @server = TCPServer.new(SocketSpecs.hostname, SocketSpecs.port) + end + + after :each do + @server.close + end + + it "raises Errno::ENOTCONN on gets" do + lambda { @server.gets }.should raise_error(Errno::ENOTCONN) + end +end diff --git a/spec/rubyspec/library/socket/tcpserver/listen_spec.rb b/spec/rubyspec/library/socket/tcpserver/listen_spec.rb new file mode 100644 index 0000000000..5e9b9c1090 --- /dev/null +++ b/spec/rubyspec/library/socket/tcpserver/listen_spec.rb @@ -0,0 +1,18 @@ +require File.expand_path('../../../../spec_helper', __FILE__) +require File.expand_path('../../fixtures/classes', __FILE__) + +require 'socket' + +describe 'TCPServer#listen' do + before :each do + @server = TCPServer.new(SocketSpecs.hostname, SocketSpecs.port) + end + + after :each do + @server.close unless @server.closed? + end + + it 'returns 0' do + @server.listen(10).should == 0 + end +end diff --git a/spec/rubyspec/library/socket/tcpserver/new_spec.rb b/spec/rubyspec/library/socket/tcpserver/new_spec.rb new file mode 100644 index 0000000000..4b7f53a397 --- /dev/null +++ b/spec/rubyspec/library/socket/tcpserver/new_spec.rb @@ -0,0 +1,97 @@ +require File.expand_path('../../../../spec_helper', __FILE__) +require File.expand_path('../../fixtures/classes', __FILE__) + +describe "TCPServer.new" do + after :each do + @server.close if @server && !@server.closed? + end + + it "binds to a host and a port" do + @server = TCPServer.new('127.0.0.1', SocketSpecs.port) + addr = @server.addr + addr[0].should == 'AF_INET' + addr[1].should be_kind_of(Fixnum) + # on some platforms (Mac), MRI + # returns comma at the end. + addr[2].should =~ /^#{SocketSpecs.hostname}\b/ + addr[3].should == '127.0.0.1' + end + + it "binds to localhost and a port with either IPv4 or IPv6" do + @server = TCPServer.new(SocketSpecs.hostname, SocketSpecs.port) + addr = @server.addr + if addr[0] == 'AF_INET' + addr[1].should == SocketSpecs.port + addr[2].should =~ /^#{SocketSpecs.hostname}\b/ + addr[3].should == '127.0.0.1' + else + addr[1].should == SocketSpecs.port + addr[2].should =~ /^#{SocketSpecs.hostnamev6}\b/ + addr[3].should == '::1' + end + end + + it "binds to INADDR_ANY if the hostname is empty" do + @server = TCPServer.new('', SocketSpecs.port) + addr = @server.addr + addr[0].should == 'AF_INET' + addr[1].should == SocketSpecs.port + addr[2].should == '0.0.0.0' + addr[3].should == '0.0.0.0' + end + + it "binds to INADDR_ANY if the hostname is empty and the port is a string" do + @server = TCPServer.new('', SocketSpecs.port.to_s) + addr = @server.addr + addr[0].should == 'AF_INET' + addr[1].should == SocketSpecs.port + addr[2].should == '0.0.0.0' + addr[3].should == '0.0.0.0' + end + + it "coerces port to string, then determines port from that number or service name" do + t = Object.new + lambda { TCPServer.new(SocketSpecs.hostname, t) }.should raise_error(TypeError) + + def t.to_str; SocketSpecs.port.to_s; end + + @server = TCPServer.new(SocketSpecs.hostname, t) + addr = @server.addr + addr[1].should == SocketSpecs.port + + # TODO: This should also accept strings like 'https', but I don't know how to + # pick such a service port that will be able to reliably bind... + end + + it "raises Errno::EADDRNOTAVAIL when the adress is unknown" do + lambda { TCPServer.new("1.2.3.4", 4000) }.should raise_error(Errno::EADDRNOTAVAIL) + end + + # There is no way to make this fail-proof on all machines, because + # DNS servers like opendns return A records for ANY host, including + # traditionally invalidly named ones. + quarantine! do + it "raises a SocketError when the host is unknown" do + lambda { + TCPServer.new("--notavalidname", 4000) + }.should raise_error(SocketError) + end + end + + it "raises Errno::EADDRINUSE when address is already in use" do + lambda { + @server = TCPServer.new('127.0.0.1', SocketSpecs.port) + @server = TCPServer.new('127.0.0.1', SocketSpecs.port) + }.should raise_error(Errno::EADDRINUSE) + end + + platform_is_not :windows, :aix do + # A known bug in AIX. getsockopt(2) does not properly set + # the fifth argument for SO_REUSEADDR. + it "sets SO_REUSEADDR on the resulting server" do + @server = TCPServer.new('127.0.0.1', SocketSpecs.port) + @server.getsockopt(:SOCKET, :REUSEADDR).data.should_not == "\x00\x00\x00\x00" + @server.getsockopt(:SOCKET, :REUSEADDR).int.should_not == 0 + end + end +end diff --git a/spec/rubyspec/library/socket/tcpserver/output_spec.rb b/spec/rubyspec/library/socket/tcpserver/output_spec.rb new file mode 100644 index 0000000000..b193bb83ea --- /dev/null +++ b/spec/rubyspec/library/socket/tcpserver/output_spec.rb @@ -0,0 +1,9 @@ +require File.expand_path('../../../../spec_helper', __FILE__) +require File.expand_path('../../fixtures/classes', __FILE__) + +describe "TCPServer#<<" do + after :each do + @server.close if @server + @socket.close if @socket + end +end diff --git a/spec/rubyspec/library/socket/tcpserver/readpartial_spec.rb b/spec/rubyspec/library/socket/tcpserver/readpartial_spec.rb new file mode 100644 index 0000000000..35d07a0309 --- /dev/null +++ b/spec/rubyspec/library/socket/tcpserver/readpartial_spec.rb @@ -0,0 +1,9 @@ +require File.expand_path('../../../../spec_helper', __FILE__) +require File.expand_path('../../fixtures/classes', __FILE__) + +describe "TCPServer#readpartial" do + after :each do + @server.close if @server + @socket.close if @socket + end +end diff --git a/spec/rubyspec/library/socket/tcpserver/sysaccept_spec.rb b/spec/rubyspec/library/socket/tcpserver/sysaccept_spec.rb new file mode 100644 index 0000000000..1cd1c1c719 --- /dev/null +++ b/spec/rubyspec/library/socket/tcpserver/sysaccept_spec.rb @@ -0,0 +1,31 @@ +require File.expand_path('../../../../spec_helper', __FILE__) +require File.expand_path('../../fixtures/classes', __FILE__) + +require 'socket' + +describe "TCPServer#sysaccept" do + before :each do + @server = TCPServer.new(SocketSpecs.hostname, SocketSpecs.port) + end + + after :each do + @server.close unless @server.closed? + end + + it 'blocks if no connections' do + lambda { @server.sysaccept }.should block_caller + end + + it 'returns file descriptor of an accepted connection' do + begin + sock = TCPSocket.new(SocketSpecs.hostname, SocketSpecs.port) + + fd = @server.sysaccept + + fd.should be_an_instance_of(Fixnum) + ensure + sock.close if sock && !sock.closed? + IO.for_fd(fd).close if fd + end + end +end |