Class: UDPSocket

Inherits:

IPSocket

• Object
• IO
• BasicSocket
• IPSocket
• UDPSocket

Defined in:

lib/rubysl/socket.rb

Constant Summary

FFI =

Rubinius::FFI

Instance Method Summary

• #bind(host, port) ⇒ Object
• #connect(host, port) ⇒ Object
• #initialize(socktype = Socket::AF_INET) ⇒ UDPSocket constructor

  A new instance of UDPSocket.

• #inspect ⇒ Object
• #send(message, flags, *to) ⇒ Object

Methods inherited from IPSocket

#addr, getaddress, #peeraddr, #recvfrom, #recvfrom_nonblock

Methods inherited from BasicSocket

#close_read, #close_write, do_not_reverse_lookup, #do_not_reverse_lookup, do_not_reverse_lookup=, #do_not_reverse_lookup=, for_fd, from_descriptor, #from_descriptor, #getpeername, #getsockname, #getsockopt, #recv, #recv_nonblock, #recvfrom, #setsockopt, #shutdown

Constructor Details

#initialize(socktype = Socket::AF_INET) ⇒ UDPSocket

Returns a new instance of UDPSocket.

# File 'lib/rubysl/socket.rb', line 1276

def initialize(socktype = Socket::AF_INET)
  @no_reverse_lookup = self.class.do_not_reverse_lookup
  @socktype = socktype
  status = Socket::Foreign.socket @socktype,
                                  Socket::SOCK_DGRAM,
                                  Socket::IPPROTO_UDP
  Errno.handle 'socket(2)' if status < 0

  IO.setup self, status, nil, true
end

Instance Method Details

#bind(host, port) ⇒ Object

# File 'lib/rubysl/socket.rb', line 1287

def bind(host, port)
  @host = host.to_s if host
  @port = port.to_s if port

  addrinfos = Socket::Foreign.getaddrinfo(@host,
                                         @port,
                                         @socktype,
                                         Socket::SOCK_DGRAM, 0,
                                         Socket::AI_PASSIVE)

  status = -1

  addrinfos.each do |addrinfo|
    flags, family, socket_type, protocol, sockaddr, canonname = addrinfo

    status = Socket::Foreign.bind descriptor, sockaddr

    break if status >= 0
  end

  if status < 0
    Errno.handle 'bind(2)'
  end

  status
end

#connect(host, port) ⇒ Object

# File 'lib/rubysl/socket.rb', line 1314

def connect(host, port)
  sockaddr = Socket::Foreign.pack_sockaddr_in host, port, @socktype, Socket::SOCK_DGRAM, 0

  syscall = 'connect(2)'
  status = Socket::Foreign.connect descriptor, sockaddr

  if status < 0
    Errno.handle syscall
  end

  0
end

#inspect ⇒ Object

# File 'lib/rubysl/socket.rb', line 1342

def inspect
  "#<#{self.class}:0x#{object_id.to_s(16)} #{@host}:#{@port}>"
end

#send(message, flags, *to) ⇒ Object

# File 'lib/rubysl/socket.rb', line 1327

def send(message, flags, *to)
  connect *to unless to.empty?

  bytes = message.bytesize
  bytes_sent = 0

  FFI::MemoryPointer.new :char, bytes + 1 do |buffer|
    buffer.write_string message, bytes
    bytes_sent = Socket::Foreign.send(descriptor, buffer, bytes, flags)
    Errno.handle 'send(2)' if bytes_sent < 0
  end

  bytes_sent
end