Contents

describe :socket_recv_nonblock, :shared => true do
  not_supported_on :jruby do
    before :each do
      @s1 = Socket.new(Socket::AF_INET, Socket::SOCK_DGRAM, 0)
      @s2 = Socket.new(Socket::AF_INET, Socket::SOCK_DGRAM, 0)
    end

    after :each do
      @s1.close unless @s1.closed?
      @s2.close unless @s2.closed?
    end

    it "raises EAGAIN if there's no data available" do
      @s1.bind(Socket.pack_sockaddr_in(SocketSpecs.port, "127.0.0.1"))
      lambda { @s1.recv_nonblock(5)}.should raise_error(Errno::EAGAIN)
    end

    it "receives data after it's ready" do
      @s1.bind(Socket.pack_sockaddr_in(SocketSpecs.port, "127.0.0.1"))
      @s2.send("aaa", 0, @s1.getsockname)
      IO.select([@s1], nil, nil, 2)
      @s1.recv_nonblock(5).should == "aaa"
    end

    it "does not block if there's no data available" do
      @s1.bind(Socket.pack_sockaddr_in(SocketSpecs.port, "127.0.0.1"))
      @s2.send("a", 0, @s1.getsockname)
      IO.select([@s1], nil, nil, 2)
      @s1.recv_nonblock(1).should == "a"
      lambda { @s1.recv_nonblock(5)}.should raise_error(Errno::EAGAIN)
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
rubysl-socket-1.0.1	spec/shared/recv_nonblock.rb
rubysl-socket-2.0.1	spec/shared/recv_nonblock.rb
rubysl-socket-1.0.0	spec/shared/recv_nonblock.rb
rubysl-socket-2.0.0	spec/shared/recv_nonblock.rb